mcmandelbrot.wire.MandelbrotWorkerUniverse(WireWorkerUniverse) class documentation
Part of mcmandelbrot.wire
(View In Hierarchy)
I run on the remote Python interpreter to run a runner from there,
accepting commands from your RemoteRunner
via run,
done
and cancel
and sending the results and iterations to it.
| Method | setup | Undocumented |
| Method | shutdown | Undocumented |
| Method | run | No summary |
| Method | getNext | Gets the next chunk of data to have been written to the Writable for the
run identified by ID. |
| Method | done | Gets the runtime and number of points done in the run and removes my references to it in my pendingRuns dict. |
| Method | cancel | Cancels a pending run ID. Nothing is returned, and no exception is raised for calling with reference to an unknown or already canceled/completed run. |
Inherited from WireWorkerUniverse:
| Class Method | check | Undocumented |
| Method | __init__ | Undocumented |
| Method | runTask | No summary |
def
run(self, Nx, cr, ci, crPM, ciPM, requester=None):
Does an image-generation run for the specified parameters, storing a
Deferred dRun to the result in a
namedtuple along with a reference fh to a new Writable that will
have the image data written to it and a Deferred
dCancel that can have its callback fired to cancel the run.
| Returns | A unique string ID identifying the run. | |
def
getNext(self, ID):
Gets the next chunk of data to have been written to the Writable for the
run identified by ID.
| Returns | A Deferred that fires with the data chunk when it is received,
or an immediate None object if the run isn't pending. | |
def
done(self, ID):
Gets the runtime and number of points done in the run and removes my references to it in my pendingRuns dict.
| Returns | A Deferred that fires with the runtime and number of points
when the run is done, or an immediate None object if there
never was any such run or this method was called with this ID
already. | |