Package flumotion :: Package worker :: Module base :: Class BaseJobHeaven
[hide private]

Class BaseJobHeaven

source code

 twisted.spread.jelly.Jellyable --+            
twisted.spread.flavors.Serializable --+        
   twisted.spread.flavors.Referenceable --+    
                twisted.spread.flavors.Root --+
                    extern.log.log.Loggable --+
Known Subclasses:

I am similar to but not quite the same as a manager-side Heaven. I manage avatars inside the worker for job processes spawned by the worker.

Instance Methods [hide private]
__init__(self, brain) source code
listen(self) source code
requestAvatar(self, avatarId, mind, *interfaces) source code
removeAvatar(self, avatarId) source code
Gets the name of the worker that spawns the process.
source code
addJobInfo(self, processId, jobInfo) source code
getJobInfo(self, processId) source code
getJobInfos(self) source code
getJobPids(self) source code
rotateChildLogFDs(self) source code
jobStopped(self, pid) source code
shutdown(self) source code
kill(self, signum=9) source code
killJobByPid(self, pid, signum) source code
killJob(self, avatarId, signum) source code

Inherited from twisted.spread.flavors.Root: rootObject

Inherited from twisted.spread.flavors.Referenceable: jellyFor, remoteMessageReceived

Inherited from twisted.spread.flavors.Serializable: processUniqueID

Inherited from twisted.spread.jelly.Jellyable: __providedBy__, getStateFor

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

Class Variables [hide private]
  logCategory = 'job-heaven'
Implementors can provide a category to log their messages under.
  avatarClass = None
  __implemented__ = <implementedBy flumotion.worker.base.BaseJob...
  __provides__ = <zope.interface.declarations.ClassProvides obje...

Inherited from twisted.spread.flavors.Referenceable: perspective

Instance Variables [hide private]
dict of str -> base.BaseJobAvatar avatars
dict of avatarId -> avatar
worker.WorkerBrain brain
the worker brain
Method Details [hide private]

__init__(self, brain)

source code 

Class Variable Details [hide private]


<implementedBy flumotion.worker.base.BaseJobHeaven>


<zope.interface.declarations.ClassProvides object at 0xa8b644c>