eric: comparison Utilities/BackgroundService.py

-:38e8903f9c2f
+:f542ad1f76c5
 class BackgroundService(QTcpServer):
 """
 Class implementing the main part of the background service.
 """
 serviceNotAvailable = pyqtSignal(str, str, str, str)
+batchJobDone = pyqtSignal(str, str)
 def __init__(self):
 """
 Constructor of the BackgroundService class.
 """
 Private method to receive the response from the clients.
 @param lang language of the incomming connection (str)
 """
 connection = self.connections[lang]
-header = connection.read(8)
+while connection.bytesAvailable():
-length, datahash = struct.unpack(b'!II', header)
+header = connection.read(8)
+length, datahash = struct.unpack(b'!II', header)
-packedData = b''
-while len(packedData) < length:
+packedData = b''
-connection.waitForReadyRead(50)
+while len(packedData) < length:
-packedData += connection.read(length - len(packedData))
+connection.waitForReadyRead(50)
+packedData += connection.read(length - len(packedData))
-assert adler32(packedData) & 0xffffffff == datahash, 'Hashes not equal'
-if sys.version_info[0] == 3:
+assert adler32(packedData) & 0xffffffff == datahash, \
-packedData = packedData.decode('utf-8')
+'Hashes not equal'
-# "check" if is's a tuple of 3 values
+if sys.version_info[0] == 3:
-fx, fn, data = json.loads(packedData)
+packedData = packedData.decode('utf-8')
+# "check" if is's a tuple of 3 values
-if fx == 'INIT':
+fx, fn, data = json.loads(packedData)
-pass
-elif fx == 'EXCEPTION':
+if fx == 'INIT':
-# Remove connection because it'll close anyway
+pass
-self.connections.pop(lang, None)
+elif fx == 'EXCEPTION':
-# Call sys.excepthook(type, value, traceback) to emulate the
+# Remove connection because it'll close anyway
-# exception which was caught on the client
+self.connections.pop(lang, None)
-sys.excepthook(*data)
+# Call sys.excepthook(type, value, traceback) to emulate the
-res = E5MessageBox.question(
+# exception which was caught on the client
-None,
+sys.excepthook(*data)
-self.tr("Restart background client?"),
+res = E5MessageBox.question(
-self.tr(
+None,
-"<p>The background client for <b>{0}</b> has stopped"
+self.tr("Restart background client?"),
-" due to an exception. It's used by various plug-ins like"
+self.tr(
-" the different checkers.</p>"
+"<p>The background client for <b>{0}</b> has stopped"
-"<p>Select"
+" due to an exception. It's used by various plug-ins"
-"<ul>"
+" like the different checkers.</p>"
-"<li><b>'Yes'</b> to restart the client, but abort the"
+"<p>Select"
-" last job</li>"
+"<ul>"
-"<li><b>'Retry'</b> to restart the client and the last"
+"<li><b>'Yes'</b> to restart the client, but abort the"
-" job</li>"
+" last job</li>"
-"<li><b>'No'</b> to leave the client off.</li>"
+"<li><b>'Retry'</b> to restart the client and the last"
-"</ul></p>"
+" job</li>"
-"<p>Note: The client can be restarted by opening and"
+"<li><b>'No'</b> to leave the client off.</li>"
-" accepting the preferences dialog or reloading/changing"
+"</ul></p>"
-" the project.</p>").format(lang),
+"<p>Note: The client can be restarted by opening and"
-E5MessageBox.Yes | E5MessageBox.No | E5MessageBox.Retry,
+" accepting the preferences dialog or reloading/"
-E5MessageBox.Yes)
+"changing the project.</p>").format(lang),
+E5MessageBox.Yes | E5MessageBox.No | E5MessageBox.Retry,
-if res == E5MessageBox.Retry:
+E5MessageBox.Yes)
-self.enqueueRequest(*self.runningJob)
+if res == E5MessageBox.Retry:
+self.enqueueRequest(*self.runningJob)
+else:
+fx, lng, fn, data = self.runningJob
+self.services[(fx, lng)][3](fx, lng, fn, self.tr(
+'An error in Erics background client stopped the'
+' service.')
+)
+if res != E5MessageBox.No:
+self.isWorking = None
+self.restartService(lang, True)
+return
+elif data == 'Unknown service.':
+callback = self.services.get((fx, lang))
+if callback:
+callback[3](fx, lang, fn, data)
+elif fx.startswith("batch_"):
+fx = fx.replace("batch_", "")
+if data != "__DONE__":
+callback = self.services.get((fx, lang))
+if callback:
+callback[2](fn, *data)
+continue
+else:
+self.batchJobDone.emit(fx, lang)
 else:
-fx, lng, fn, data = self.runningJob
+callback = self.services.get((fx, lang))
-self.services[(fx, lng)][3](fx, lng, fn, self.tr(
+if callback:
-'An error in Erics background client stopped the service.')
+callback[2](fn, *data)
-)
-if res != E5MessageBox.No:
-self.isWorking = None
-self.restartService(lang, True)
-return
-elif data == 'Unknown service.':
-callback = self.services.get((fx, lang))
-if callback:
-callback[3](fx, lang, fn, data)
-else:
-callback = self.services.get((fx, lang))
-if callback:
-callback[2](fn, *data)
 self.isWorking = None
 self.__processQueue()
 def preferencesOrProjectChanged(self):
 self.__queue.append(args)
 self.__processQueue()
 def serviceConnect(
 self, fx, lang, modulepath, module, callback,
-onErrorCallback=None):
+onErrorCallback=None, onBatchDone=None):
 """
 Public method to announce a new service to the background
 service/client.
 @param fx function name of the service (str)
 @param lang language of the new service (str)
 @param modulepath full path to the module (str)
 @param module name to import (str)
-@param callback function on service response (function)
+@param callback function called on service response (function)
-@param onErrorCallback function if client isn't available (function)
+@param onErrorCallback function called, if client isn't available
+(function)
+@param onBatchDone function called when a batch job is done (function)
 """
 self.services[(fx, lang)] = \
 modulepath, module, callback, onErrorCallback
 self.enqueueRequest('INIT', lang, fx, [modulepath, module])
 if onErrorCallback:
 self.serviceNotAvailable.connect(onErrorCallback)
+if onBatchDone:
+self.batchJobDone.connect(onBatchDone)
 def serviceDisconnect(self, fx, lang):
 """
 Public method to remove the service from the service list.

Mercurial Repositories > eric / file comparison

comparison: Utilities/BackgroundService.py

Utilities/BackgroundService.py