##// END OF EJS Templates
Messing with newlines.
Brian Granger -
Show More
@@ -400,6 +400,7 b' class EngineService(object, service.Service):'
400
400
401 # The IEngine methods. See the interface for documentation.
401 # The IEngine methods. See the interface for documentation.
402
402
403 @profile
403 def execute(self, lines):
404 def execute(self, lines):
404 msg = {'engineid':self.id,
405 msg = {'engineid':self.id,
405 'method':'execute',
406 'method':'execute',
@@ -693,7 +694,7 b' class QueuedEngine(object):'
693 @queue
694 @queue
694 def execute(self, lines):
695 def execute(self, lines):
695 pass
696 pass
696
697
697 @queue
698 @queue
698 def push(self, namespace):
699 def push(self, namespace):
699 pass
700 pass
@@ -552,6 +552,7 b' class SynchronousMultiEngine(PendingDeferredManager):'
552 # Decorated pending deferred methods
552 # Decorated pending deferred methods
553 #---------------------------------------------------------------------------
553 #---------------------------------------------------------------------------
554
554
555 @profile
555 @two_phase
556 @two_phase
556 def execute(self, lines, targets='all'):
557 def execute(self, lines, targets='all'):
557 d = self.multiengine.execute(lines, targets)
558 d = self.multiengine.execute(lines, targets)
@@ -131,7 +131,7 b' class FCSynchronousMultiEngineFromMultiEngine(Referenceable):'
131 def _addDeferredIDCallback(self, did, callback, *args, **kwargs):
131 def _addDeferredIDCallback(self, did, callback, *args, **kwargs):
132 self._deferredIDCallbacks[did] = (callback, args, kwargs)
132 self._deferredIDCallbacks[did] = (callback, args, kwargs)
133 return did
133 return did
134
134
135 #---------------------------------------------------------------------------
135 #---------------------------------------------------------------------------
136 # IEngineMultiplexer related methods
136 # IEngineMultiplexer related methods
137 #---------------------------------------------------------------------------
137 #---------------------------------------------------------------------------
@@ -346,7 +346,7 b' class FCFullSynchronousMultiEngineClient(object):'
346 #---------------------------------------------------------------------------
346 #---------------------------------------------------------------------------
347 # IEngineMultiplexer related methods
347 # IEngineMultiplexer related methods
348 #---------------------------------------------------------------------------
348 #---------------------------------------------------------------------------
349
349
350 def execute(self, lines, targets='all', block=True):
350 def execute(self, lines, targets='all', block=True):
351 d = self.remote_reference.callRemote('execute', lines, targets, block)
351 d = self.remote_reference.callRemote('execute', lines, targets, block)
352 d.addCallback(self.unpackage)
352 d.addCallback(self.unpackage)
General Comments 0
You need to be logged in to leave comments. Login now