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

Public Member Functions

def canJoin
 
def join
 
def reservePlatform
 
def releasePlatform
 
def expandCmdString
 
def returnResults
 
def run
 
def isRunning
 
def finish
 
def killLocked
 
def signalMainThread
 

Public Attributes

 condVar
 
 cmd
 
 rundir
 
 originatingServer
 
 executable
 
 platform
 
 addArgs
 
 used
 
 id
 
 workerDir
 
 cputimeMultiplier
 
 hbi
 
 joinedTo
 
 running
 
 failed
 
 realTimeSpent
 
 args
 
 returncode
 
 subprocess
 

Detailed Description

The description of a single command with run directory and originating
   server.

Member Function Documentation

def cpc.worker.workload.WorkLoad.canJoin (   self,
  other 
)
Check whether two workloads can be joined.
   other = the other workload to test.
def cpc.worker.workload.WorkLoad.expandCmdString (   self,
  additionalRunVars 
)
Expand an argument string's variables.
def cpc.worker.workload.WorkLoad.finish (   self,
  plugin,
  pluginArgs 
)
Run the platform plugin with finish when needed.
def cpc.worker.workload.WorkLoad.isRunning (   self)
def cpc.worker.workload.WorkLoad.join (   self,
  others 
)
Join this workload to a list of others:
   others = a list of workloads.
def cpc.worker.workload.WorkLoad.killLocked (   self)
Kill the process associated with this run. Assumes a locked 
   runCondVar
def cpc.worker.workload.WorkLoad.releasePlatform (   self)
Release a reservation from the platform.
def cpc.worker.workload.WorkLoad.reservePlatform (   self)
Reserve this workload's resources from the platform.
def cpc.worker.workload.WorkLoad.returnResults (   self)
def cpc.worker.workload.WorkLoad.run (   self,
  plugin,
  pluginArgs 
)
Run the workload in a separate thread. Signal the condvar when
   done. Run platfrom plugin with run command when neccesary.
def cpc.worker.workload.WorkLoad.signalMainThread (   self,
  startTime,
  endTime 
)

Member Data Documentation

cpc.worker.workload.WorkLoad.addArgs
cpc.worker.workload.WorkLoad.args
cpc.worker.workload.WorkLoad.cmd
cpc.worker.workload.WorkLoad.condVar
cpc.worker.workload.WorkLoad.cputimeMultiplier
cpc.worker.workload.WorkLoad.executable
cpc.worker.workload.WorkLoad.failed
cpc.worker.workload.WorkLoad.hbi
cpc.worker.workload.WorkLoad.id
cpc.worker.workload.WorkLoad.joinedTo
cpc.worker.workload.WorkLoad.originatingServer
cpc.worker.workload.WorkLoad.platform
cpc.worker.workload.WorkLoad.realTimeSpent
cpc.worker.workload.WorkLoad.returncode
cpc.worker.workload.WorkLoad.rundir
cpc.worker.workload.WorkLoad.running
cpc.worker.workload.WorkLoad.subprocess
cpc.worker.workload.WorkLoad.used
cpc.worker.workload.WorkLoad.workerDir

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