Copernicus  2.0
 All Classes Namespaces Files Functions Variables
cpc.worker.heartbeat.HeartbeatSender Class Reference
Inheritance diagram for cpc.worker.heartbeat.HeartbeatSender:

Public Member Functions

def addWorkloads
 
def delWorkloads
 
def stop
 
def getRun
 
def setRun
 
def sendHeartbeat
 

Public Attributes

 lock
 
 runCondVar
 
 workerID
 
 workerDir
 
 worker
 
 run
 
 cmdsChanged
 
 thread
 
 randomFileCreated
 
 randomFile
 

Member Function Documentation

def cpc.worker.heartbeat.HeartbeatSender.addWorkloads (   self,
  workloads 
)
Add a workload list.
def cpc.worker.heartbeat.HeartbeatSender.delWorkloads (   self,
  workloads 
)
Remove a workload list.
def cpc.worker.heartbeat.HeartbeatSender.getRun (   self)
Check whether the heartbeat thread should run.
def cpc.worker.heartbeat.HeartbeatSender.sendHeartbeat (   self,
  first 
)
Try to send a hearbeat signal (if we're still supposed to be running)
   and return the number of seconds to wait. If the run has finished,
   return None.
   first: whether this is the first heartbeat signal
def cpc.worker.heartbeat.HeartbeatSender.setRun (   self,
  run 
)
Set whether the heartbeat thread should run.
def cpc.worker.heartbeat.HeartbeatSender.stop (   self)
Tell the hearbeat thread to stop running.

Member Data Documentation

cpc.worker.heartbeat.HeartbeatSender.cmdsChanged
cpc.worker.heartbeat.HeartbeatSender.lock
cpc.worker.heartbeat.HeartbeatSender.randomFile
cpc.worker.heartbeat.HeartbeatSender.randomFileCreated
cpc.worker.heartbeat.HeartbeatSender.run
cpc.worker.heartbeat.HeartbeatSender.runCondVar
cpc.worker.heartbeat.HeartbeatSender.thread
cpc.worker.heartbeat.HeartbeatSender.worker
cpc.worker.heartbeat.HeartbeatSender.workerDir
cpc.worker.heartbeat.HeartbeatSender.workerID

The documentation for this class was generated from the following file: