[gnome-music/wip/mschraal/artrework: 13/17] albumartcache: Higher priority for I/O processes

[Marinus Schraal <mschraal src gnome org>]

commit 540a78b047d6a7d1cf6a7c94b0420976ad96aeab
Author: Marinus Schraal <mschraal gnome org>
Date:   Wed Jan 31 16:12:36 2018 +0100

    albumartcache: Higher priority for I/O processes
    
    Test solution for closing files quicker in the art cache process to stop
    running into open file limits.
    
    Closes: #121

 gnomemusic/albumartcache.py | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)
---
diff --git a/gnomemusic/albumartcache.py b/gnomemusic/albumartcache.py
index a9cdb77..92fe26c 100644
--- a/gnomemusic/albumartcache.py
+++ b/gnomemusic/albumartcache.py
@@ -400,7 +400,7 @@ class Cache(GObject.GObject):
         if (success
                 and thumb_file.query_exists()):
             thumb_file.read_async(
-                GLib.PRIORITY_LOW, None, self._open_stream, None)
+                GLib.PRIORITY_HIGH, None, self._open_stream, None)
             return
 
         self.emit('miss')
@@ -412,7 +412,7 @@ class Cache(GObject.GObject):
         except GLib.Error as error:
             logger.warn("Error: {}, {}".format(error.domain, error.message))
             stream.close_async(
-                GLib.PRIORITY_LOW, None, self._close_stream, None)
+                GLib.PRIORITY_HIGH, None, self._close_stream, None)
             self.emit('miss')
             return
 
@@ -426,11 +426,11 @@ class Cache(GObject.GObject):
         except GLib.Error as error:
             logger.warn("Error: {}, {}".format(error.domain, error.message))
             stream.close_async(
-                GLib.PRIORITY_LOW, None, self._close_stream, None)
+                GLib.PRIORITY_HIGH, None, self._close_stream, None)
             self.emit('miss')
             return
 
-        stream.close_async(GLib.PRIORITY_LOW, None, self._close_stream, None)
+        stream.close_async(GLib.PRIORITY_HIGH, None, self._close_stream, None)
         self.emit('hit', pixbuf)
 
     @log
@@ -571,7 +571,7 @@ class EmbeddedArt(GObject.GObject):
         self._media_art.uri_async(
             MediaArt.Type.ALBUM, MediaArt.ProcessFlags.NONE,
             self._media.get_url(), self._artist, self._album,
-            GLib.PRIORITY_LOW, None, self._uri_async_cb, None)
+            GLib.PRIORITY_HIGH, None, self._uri_async_cb, None)
 
     @log
     def _uri_async_cb(self, src, result, data):
@@ -638,7 +638,7 @@ class RemoteArt(GObject.GObject):
         tmp_file, iostream = data
 
         iostream.close_async(
-            GLib.PRIORITY_LOW, None, self._close_iostream_callback, None)
+            GLib.PRIORITY_HIGH, None, self._close_iostream_callback, None)
 
         try:
             src.splice_finish(result)
@@ -665,7 +665,7 @@ class RemoteArt(GObject.GObject):
         self.emit('retrieved')
 
         tmp_file.delete_async(
-            GLib.PRIORITY_LOW, None, self._delete_callback, None)
+            GLib.PRIORITY_HIGH, None, self._delete_callback, None)
 
     @log
     def _close_iostream_callback(self, src, result, data):
@@ -695,7 +695,7 @@ class RemoteArt(GObject.GObject):
         # closed. PyGI specific issue?
         ostream.splice_async(
             istream, Gio.OutputStreamSpliceFlags.CLOSE_SOURCE |
-            Gio.OutputStreamSpliceFlags.CLOSE_TARGET, GLib.PRIORITY_LOW,
+            Gio.OutputStreamSpliceFlags.CLOSE_TARGET, GLib.PRIORITY_HIGH,
             None, self._splice_callback, [tmp_file, iostream])
 
     @log
@@ -713,4 +713,4 @@ class RemoteArt(GObject.GObject):
 
         src = Gio.File.new_for_uri(thumb_uri)
         src.read_async(
-            GLib.PRIORITY_LOW, None, self._read_callback, None)
+            GLib.PRIORITY_HIGH, None, self._read_callback, None)