Package NetworkRender :: Module Listener :: Class Listener
[hide private]
[frames] | no frames]

Class Listener

source code

        object --+        
                 |        
threading._Verbose --+    
                     |    
      threading.Thread --+
                         |
                        Listener

Implements a listener process that listens to announcements of remote renderservers and spawns a RenderThread if it detects a new one.

Instance Methods [hide private]
 
__init__(self, scenename, context, name, fqueue, squeue, threadfactory, *args)
Initialize a Listener instance.
source code
 
run(self)
Listen and spawn new worker threads if appropriate.
source code
 
requestStop(self)
Request this thread to stop.
source code
 
getRemotethreads(self)
Returns: a list of previously spawned workerthreads.
source code

Inherited from threading.Thread: __repr__, getName, isAlive, isDaemon, join, setDaemon, setName, start

Inherited from threading.Thread (private): _set_daemon

Inherited from threading._Verbose (private): _note

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __setattr__, __str__

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, scenename, context, name, fqueue, squeue, threadfactory, *args)
(Constructor)

source code 

Initialize a Listener instance.

Parameters:
  • scenename (string) - name of current scene
  • context (Blender.Renderdata) - rendercontext of current scene
  • name (string) - filename of saved .blend file
  • fqueue (Queue.queue) - worklist queue
  • squeue (Queue.queue) - statistics queue
  • threadfactory (NetworkRender.Renderthread) - a classfactory to spawn worker threads
  • args - additional arguments to be given to the threadfactory
Overrides: object.__init__

run(self)

source code 

Listen and spawn new worker threads if appropriate.

Overridden from Thread. Implements a stoppable loop (stops when requestStop is called on this thread) and records with workerthreads were spawned.

Overrides: threading.Thread.run

getRemotethreads(self)

source code 
Returns:
a list of previously spawned workerthreads.