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