Package flumotion :: Package worker :: Module job :: Class ComponentJobAvatar
[hide private]

Class ComponentJobAvatar

source code

twisted.spread.pb.Avatar --+        
                           |        
 extern.log.log.Loggable --+        
                           |        
           twisted.pb.Avatar --+    
                               |    
     extern.log.log.Loggable --+    
                               |    
              base.BaseJobAvatar --+
                                   |
                                  ComponentJobAvatar

Instance Methods [hide private]
 
haveMind(self) source code
 
stop(self)
returns: a deferred marking completed stop.
source code
 
sendFeed(self, feedName, fd, eaterId)
Tell the feeder to send the given feed to the given fd.
source code
 
receiveFeed(self, eaterAlias, fd, feedId)
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 base.BaseJobAvatar: __init__, logTo, logout, setMind

Inherited from base.BaseJobAvatar (private): _sendFileDescriptor

Inherited from twisted.pb.Avatar: disconnect, mindCallRemote, mindCallRemoteLogging, perspectiveMessageReceived, perspectiveMessageReceivedUnserialised

Inherited from twisted.spread.pb.Avatar: __providedBy__

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

Class Variables [hide private]

Inherited from base.BaseJobAvatar: logCategory

Inherited from twisted.pb.Avatar: remoteLogName

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

Method Details [hide private]

haveMind(self)

source code 
Overrides: base.BaseJobAvatar.haveMind

stop(self)

source code 

returns: a deferred marking completed stop.

Overrides: base.BaseJobAvatar.stop

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, eaterAlias, fd, feedId)

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.