Utilities/BackgroundService.py

changeset 4221
c9fdc07753a7
parent 4218
f542ad1f76c5
child 4235
81278aff6af9
--- a/Utilities/BackgroundService.py	Fri Apr 17 18:57:38 2015 +0200
+++ b/Utilities/BackgroundService.py	Sat Apr 18 19:14:15 2015 +0200
@@ -132,6 +132,7 @@
             header = struct.pack(
                 b'!II', len(packedData), adler32(packedData) & 0xffffffff)
             connection.write(header)
+            connection.write(b'JOB   ')    # 6 character message type
             connection.write(packedData)
 
     def __receive(self, lang):
@@ -142,7 +143,7 @@
         """
         connection = self.connections[lang]
         while connection.bytesAvailable():
-            header = connection.read(8)
+            header = connection.read(struct.calcsize(b'!II'))
             length, datahash = struct.unpack(b'!II', header)
             
             packedData = b''
@@ -290,6 +291,20 @@
                 self.__queue.append(args)
         self.__processQueue()
     
+    def requestCancel(self, lang):
+        """
+        Public method to ask a batch job to terminate.
+        
+        @param lang language to connect to (str)
+        """
+        connection = self.connections.get(lang)
+        if connection is None:
+            return
+        else:
+            header = struct.pack(b'!II', 0, 0)
+            connection.write(header)
+            connection.write(b'CANCEL')    # 6 character message type
+    
     def serviceConnect(
             self, fx, lang, modulepath, module, callback,
             onErrorCallback=None, onBatchDone=None):

eric ide

mercurial