class QueueManager

Class QueueManager

File: QueueManager.inc

Properties

$queue
- Public mixed $queue
$freeServer
- Public mixed $freeServer
$job
- Public mixed $job
$shallStop
- Public mixed $shallStop
$stopTime
- Public mixed $stopTime
$nping
- Public mixed $nping

Functions

QueueManager()
- Public void QueueManager()
executeScript(mixed $job)
- Public void executeScript(mixed $job)
copyImagesToServer(mixed $job, mixed $server_hostname)
- Public void copyImagesToServer(mixed $job, mixed $server_hostname)
nextJobFromQueue()
- Public void nextJobFromQueue()
cleanUpFileServer(mixed $job)
- Public void cleanUpFileServer(mixed $job)
restoreOwnership(mixed $username)
- Public void restoreOwnership(mixed $username)
updateJobAndServerStatus()
- Public void updateJobAndServerStatus()
makeWithdrawal(mixed $user, mixed $client, mixed $startTime, mixed $stopTime, mixed $credit, mixed $group)
- Public void makeWithdrawal(mixed $user, mixed $client, mixed $startTime, mixed $stopTime, mixed $credit, mixed $group)
writeParameterFile(mixed $job, mixed $startTime, mixed $logFile, mixed $errorFile)
- Public void writeParameterFile(mixed $job, mixed $startTime, mixed $logFile, mixed $errorFile)
errorOccured(mixed $job)
- Public void errorOccured(mixed $job)
notifySuccess(mixed $job, mixed $startTime)
- Public void notifySuccess(mixed $job, mixed $startTime)
notifyError(mixed $job, mixed $message, mixed $startTime)
- Public void notifyError(mixed $job, mixed $message, mixed $startTime)
notifyWarning(mixed $job, mixed $message, mixed $startTime)
- Public void notifyWarning(mixed $job, mixed $message, mixed $startTime)
notifyPingError(mixed $name)
- Public void notifyPingError(mixed $name)
parameterText(mixed $job)
- Public void parameterText(mixed $job)
getFreeServer()
- Public void getFreeServer()
incNPing(mixed $name)
- Public void incNPing(mixed $name)
stop()
- Public void stop()
shallStop()
- Public void shallStop()
waitForDatabaseConnection()
- Public void waitForDatabaseConnection()
readHuCoreVersion()
- Public void readHuCoreVersion()
run()
- Public void run()