Package flumotion :: Package worker :: Module worker :: Class JobAvatar
[hide private]

Class JobAvatar

source code

twisted.spread.pb.Avatar --+
                           |
     common.log.Loggable --+
                           |
                          JobAvatar

I am an avatar for the job living in the worker.

Instance Methods [hide private]
 
__init__(self, heaven, avatarId) source code
boolean
hasRemoteReference(self)
Check if the avatar has a remote reference to the peer.
source code
 
attached(self, *args, **kwargs) source code
 
logout(self) source code
 
stop(self)
returns: a deferred marking completed stop.
source code
 
remote_ready(self) source code
 
logTo(self, stdout, stderr)
Tell the feeder to log to the given file descriptors.
source code
 
sendFeed(self, feedName, fd, eaterId)
Tell the feeder to send the given feed to the given fd.
source code
 
receiveFeed(self, feedId, fd)
Tell the feeder to receive the given feed from the given fd.
source code
 
perspective_cleanShutdown(self)
This notification from the job process will be fired when it is shutting down, so that although the process might still be around, we know it's OK to accept new start requests for this avatar ID.
source code

Inherited from twisted.spread.pb.Avatar: __providedBy__, perspectiveMessageReceived

Inherited from common.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure

Class Variables [hide private]
  logCategory = 'job-avatar'
Implementors can provide a category to log their messages under.

Inherited from twisted.spread.pb.Avatar: __implemented__, __provides__

Method Details [hide private]

__init__(self, heaven, avatarId)
(Constructor)

source code 
Parameters:

attached(self, *args, **kwargs)

source code 
Parameters:
  • mind (twisted.spread.pb.RemoteReference

    I am scheduled from the dispatcher's requestAvatar method.

    ) - reference to the job's JobMedium on which we can call

sendFeed(self, feedName, fd, eaterId)

source code 

Tell the feeder to send the given feed to the given fd.

Returns:
whether the fd was successfully handed off to the component.

receiveFeed(self, feedId, fd)

source code 

Tell the feeder to receive the given feed from the given fd.

Returns:
whether the fd was successfully handed off to the component.