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