Trees | Index | Help |
---|
Package flumotion :: Package worker :: Module worker :: Class WorkerBrain |
|
Loggable
--+
|
WorkerBrain
Method Summary | |
---|---|
| |
callRemote(self,
methodName,
*args,
**kwargs)
| |
twisted.internet.defer.Deferred
|
Create and register a deferred for creating the given component. |
Notify the caller that a create has failed, and remove the create from the list of pending creates. | |
Check if a deferred create has been registered for the given avatarId. | |
Trigger a previously registered deferred for creating up the given component. | |
twisted.internet.defer.Deferred
|
Create and register a deferred for notifying the worker of a clean job shutdown. |
Check if a deferred shutdown has been registered for the given avatarId. | |
Trigger a previously registered deferred for creating up the given component. | |
Called from the FeedAvatar to pass a file descriptor on to the job running the given component. | |
Called from the FeedAvatar to pass a file descriptor on to the job running the component for this feeder. | |
Start listening on FeedServer (incoming eater requests) and JobServer (through which we communicate with our children) ports | |
login(self,
authenticator)
| |
shutdownHandler(self)
| |
Clean up after setup() | |
Inherited from Loggable | |
Log a debug message. | |
dict |
Log a message at the given level, with the possibility of going higher up in the stack. |
Log an error. | |
Log an informational message. | |
Log a log message. | |
Overridable log function. | |
Overridable object name function. | |
Log a warning. | |
Log a warning about a Failure. |
Instance Variable Summary | |
---|---|
authenticator : authenticator worker used to log in to manager @type authenticator
flumotion.twisted.pb.Authenticator | |
int | feedServerPort : TCP port the Feed Server is listening on |
JobHeaven |
jobHeaven : |
Kindergarten |
kindergarten : |
WorkerMedium |
medium : |
WorkerClientFactory |
workerClientFactory : |
Class Variable Summary | |
---|---|
Implements |
__implemented__ = <implementedBy flumotion.worker.worker...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
str |
logCategory : Implementors can provide a category to log their messages under. |
Inherited from Loggable | |
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
Method Details |
---|
__init__(self,
options)
|
deferredCreate(self, avatarId)Create and register a deferred for creating the given component. This deferred will be fired when the JobAvatar has instructed the job to create the component.
|
deferredCreateFailed(self, avatarId, exception)Notify the caller that a create has failed, and remove the create from the list of pending creates. |
deferredCreateRegistered(self, avatarId)Check if a deferred create has been registered for the given avatarId. |
deferredCreateTrigger(self, avatarId)Trigger a previously registered deferred for creating up the given component. |
deferredShutdown(self, avatarId)Create and register a deferred for notifying the worker of a clean job shutdown. This deferred will be fired when the job is reaped.
|
deferredShutdownRegistered(self, avatarId)Check if a deferred shutdown has been registered for the given avatarId. |
deferredShutdownTrigger(self, avatarId)Trigger a previously registered deferred for creating up the given component. |
eatFromFD(self, componentId, feedId, fd)Called from the FeedAvatar to pass a file descriptor on to the job running the given component.
|
feedToFD(self, componentId, feedName, fd, eaterId)Called from the FeedAvatar to pass a file descriptor on to the job running the component for this feeder.
|
listen(self)Start listening on FeedServer (incoming eater requests) and JobServer (through which we communicate with our children) ports
|
teardown(self)Clean up after setup()
|
Instance Variable Details |
---|
authenticatorauthenticator worker used to log in to manager @type authenticatorflumotion.twisted.pb.Authenticator
|
feedServerPortTCP port the Feed Server is listening on
|
jobHeaven
|
kindergarten
|
medium
|
workerClientFactory
|
Class Variable Details |
---|
__implemented__
|
__provides__
|
logCategoryImplementors can provide a category to log their messages under.
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Mon Oct 1 03:51:55 2007 | http://epydoc.sf.net |