Rename mopidy.process.BaseProcess.{_run => run_inside_try}

mopidy/mixers/nad.py

@@ -83,7 +83,7 @@ class NadTalker(BaseProcess):
         self.pipe = pipe
         self._device = None
 
-    def _run(self):
+    def run_inside_try(self):
         self._open_connection()
         self._set_device_to_known_state()
         while self.pipe.poll(None):

mopidy/outputs/gstreamer.py

@@ -40,7 +40,7 @@ class GStreamerProcess(BaseProcess):
         self.gst_volume = None
         self.gst_sink = None
 
-    def _run(self):
+    def run_inside_try(self):
         self.setup()
         while True:
             message = self.core_queue.get()
@@ -133,7 +133,8 @@ class GStreamerProcess(BaseProcess):
         :type state_name: string
         :rtype: :class:`True` or :class:`False`
         """
-        result = self.gst_uri_src.set_state(getattr(gst, 'STATE_' + state_name)
+        result = self.gst_uri_src.set_state(
+            getattr(gst, 'STATE_' + state_name))
         if result == gst.STATE_CHANGE_SUCCESS:
             logger.debug('Setting GStreamer state to %s: OK', state_name)
             return True

mopidy/process.py

@@ -21,7 +21,7 @@ def unpickle_connection(pickled_connection):
 class BaseProcess(multiprocessing.Process):
     def run(self):
         try:
-            self._run()
+            self.run_inside_try()
         except KeyboardInterrupt:
             logger.info(u'Interrupted by user')
             sys.exit(0)
@@ -29,7 +29,7 @@ class BaseProcess(multiprocessing.Process):
             logger.error(e.message)
             sys.exit(1)
 
-    def _run(self):
+    def run_inside_try(self):
         raise NotImplementedError
 
 
@@ -40,7 +40,7 @@ class CoreProcess(BaseProcess):
         self._backend = None
         self._frontend = None
 
-    def _run(self):
+    def run_inside_try(self):
         self._setup()
         while True:
             message = self.core_queue.get()