Package Biskit :: Package PVM :: Module PVMThread :: Class PVMThread
[hide private]
[frames] | no frames]

Class PVMThread

source code


a simple class binding incoming pvm-messages to methods.

Instance Methods [hide private]
  __init__(self, log=None)
  getTID(self)
int getParent(self)
Returns process ID of parent
  getBindings(self)
  bind(self, message_tag, tid, method)
  unbind(self, tid_message_tag)
  setMessageLoopDelay(self, delay)
time is in seconds
  getMessageLoopDelay(self)
  stopMessageLoop(self)
  startMessageLoop(self)
  messageLoopIsStopped(self)
  setPingTimeout(self, t)
  getPingTimeout(self)
  stop(self)
  isStopped(self)
  getTasks(self)
  nicknameFromTID(self, tid)
  spawn(self, pvm_task, nickname=None)
  send_primitive(self, tid, msg_tag, value)
  send(self, task, msg_tag, value=None)
if 'task' is a tuple, msg_tag is send to all the tids given in that list.
  sendToAll(self, msg_tag, value)
  run(self)
  ping(self, nickname)
  _ping(self, sender_tid)
  log(self)
  post(self, message)
  post_message_received(self, msg_tag, tid, params)
  post_message_sent(self, msg_tag, tid, params)
  post_execute_method(self, msg_tag, tid, params)
  rm_log(self)

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, log=None)
(Constructor)

source code 
Overrides: threading.Thread.__init__

getTID(self)

source code 

getParent(self)

source code 
Returns: int
process ID of parent

getBindings(self)

source code 

bind(self, message_tag, tid, method)

source code 

unbind(self, tid_message_tag)

source code 

setMessageLoopDelay(self, delay)

source code 

time is in seconds

getMessageLoopDelay(self)

source code 

stopMessageLoop(self)

source code 

startMessageLoop(self)

source code 

messageLoopIsStopped(self)

source code 

setPingTimeout(self, t)

source code 

getPingTimeout(self)

source code 

stop(self)

source code 

isStopped(self)

source code 

getTasks(self)

source code 

nicknameFromTID(self, tid)

source code 

spawn(self, pvm_task, nickname=None)

source code 

send_primitive(self, tid, msg_tag, value)

source code 

send(self, task, msg_tag, value=None)

source code 

if 'task' is a tuple, msg_tag is send to all the tids given in that list.

sendToAll(self, msg_tag, value)

source code 

run(self)

source code 
Overrides: threading.Thread.run

ping(self, nickname)

source code 

_ping(self, sender_tid)

source code 

log(self)

source code 

post(self, message)

source code 

post_message_received(self, msg_tag, tid, params)

source code 

post_message_sent(self, msg_tag, tid, params)

source code 

post_execute_method(self, msg_tag, tid, params)

source code 

rm_log(self)

source code