I am the main object in the worker process, managing jobs and
everything related. I live in the main worker process.
|
|
|
listen(self)
Start listening on FeedServer (incoming eater requests) and JobServer
(through which we communicate with our children) ports |
source code
|
|
|
|
|
|
|
|
|
|
|
callRemote(self,
methodName,
*args,
**kwargs) |
source code
|
|
|
|
twisted.internet.defer.Deferred
|
|
|
deferredCreateTrigger(self,
avatarId)
Trigger a previously registered deferred for creating up the given
component. |
source code
|
|
|
deferredCreateFailed(self,
avatarId,
exception)
Notify the caller that a create has failed, and remove the create
from the list of pending creates. |
source code
|
|
|
deferredCreateRegistered(self,
avatarId)
Check if a deferred create has been registered for the given
avatarId. |
source code
|
|
twisted.internet.defer.Deferred
|
|
|
deferredShutdownTrigger(self,
avatarId)
Trigger a previously registered deferred for creating up the given
component. |
source code
|
|
|
deferredShutdownRegistered(self,
avatarId)
Check if a deferred shutdown has been registered for the given
avatarId. |
source code
|
|
|
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. |
source code
|
|
|
eatFromFD(self,
componentId,
feedId,
fd)
Called from the FeedAvatar to pass a file descriptor on to the job
running the given component. |
source code
|
|
Inherited from common.log.Loggable :
__providedBy__ ,
debug ,
doLog ,
error ,
info ,
log ,
logFunction ,
logObjectName ,
warning ,
warningFailure
|