summaryrefslogtreecommitdiffstats
path: root/inc/taskmanager.inc.php
diff options
context:
space:
mode:
authorSimon Rettberg2018-05-24 15:35:46 +0200
committerSimon Rettberg2018-05-24 15:35:46 +0200
commit5e786faa6c577abfd48976a6839f61d08b0a6e5e (patch)
tree510e88641bbd80f23256c8e33a9027c059a0f8d8 /inc/taskmanager.inc.php
parent[serversetup-bwlp] Tweak help text (diff)
downloadslx-admin-5e786faa6c577abfd48976a6839f61d08b0a6e5e.tar.gz
slx-admin-5e786faa6c577abfd48976a6839f61d08b0a6e5e.tar.xz
slx-admin-5e786faa6c577abfd48976a6839f61d08b0a6e5e.zip
Introduce proper constants for taskmanager status
Diffstat (limited to 'inc/taskmanager.inc.php')
-rw-r--r--inc/taskmanager.inc.php27
1 files changed, 15 insertions, 12 deletions
diff --git a/inc/taskmanager.inc.php b/inc/taskmanager.inc.php
index 54821e59..dab950ed 100644
--- a/inc/taskmanager.inc.php
+++ b/inc/taskmanager.inc.php
@@ -6,6 +6,13 @@
class Taskmanager
{
+ const NO_SUCH_TASK = 'NO_SUCH_TASK';
+ const TASK_FINISHED = 'TASK_FINISHED';
+ const TASK_ERROR = 'TASK_ERROR';
+ const TASK_WAITING = 'TASK_WAITING';
+ const NO_SUCH_INSTANCE = 'NO_SUCH_INSTANCE';
+ const TASK_PROCESSING = 'TASK_PROCESSING';
+
/**
* UDP socket used for communication with the task manager
* @var resource
@@ -49,7 +56,7 @@ class Taskmanager
if ($async)
return true;
$reply = self::readReply($seq);
- if ($reply === false || !is_array($reply) || !isset($reply['id']) || (isset($reply['statusCode']) && $reply['statusCode'] === NO_SUCH_TASK)) {
+ if ($reply === false || !is_array($reply) || !isset($reply['id']) || (isset($reply['statusCode']) && $reply['statusCode'] === Taskmanager::NO_SUCH_TASK)) {
self::addErrorMessage($reply);
return false;
}
@@ -82,7 +89,7 @@ class Taskmanager
/**
* Checks whether the given task id corresponds to a known task in the taskmanager.
* Returns true iff the taskmanager is reachable and the status of the task
- * is different from NO_SUCH_INSTANCE/_TASK.
+ * is different from Taskmanager::NO_SUCH_INSTANCE/_TASK.
* If you pass an array it is assumed that it was already queried and is evaluated
* directly.
*
@@ -96,8 +103,8 @@ class Taskmanager
if (is_string($task)) {
$task = self::status($task);
}
- return isset($task['statusCode']) && $task['statusCode'] !== NO_SUCH_INSTANCE
- && $task['statusCode'] !== NO_SUCH_TASK;
+ return isset($task['statusCode']) && $task['statusCode'] !== Taskmanager::NO_SUCH_INSTANCE
+ && $task['statusCode'] !== Taskmanager::NO_SUCH_TASK;
}
/**
@@ -110,7 +117,7 @@ class Taskmanager
public static function waitComplete($task, $timeout = 2500)
{
if (is_array($task) && isset($task['id'])) {
- if ($task['statusCode'] !== TASK_PROCESSING && $task['statusCode'] !== TASK_WAITING) {
+ if ($task['statusCode'] !== Taskmanager::TASK_PROCESSING && $task['statusCode'] !== Taskmanager::TASK_WAITING) {
self::release($task['id']);
return $task;
}
@@ -124,7 +131,7 @@ class Taskmanager
$status = self::status($task);
if (!isset($status['statusCode']))
break;
- if ($status['statusCode'] !== TASK_PROCESSING && $status['statusCode'] !== TASK_WAITING) {
+ if ($status['statusCode'] !== Taskmanager::TASK_PROCESSING && $status['statusCode'] !== Taskmanager::TASK_WAITING) {
$done = true;
break;
}
@@ -147,7 +154,7 @@ class Taskmanager
{
if (!is_array($task) || !isset($task['statusCode']) || !isset($task['id']))
return true;
- if ($task['statusCode'] !== TASK_WAITING && $task['statusCode'] !== TASK_PROCESSING && $task['statusCode'] !== TASK_FINISHED)
+ if ($task['statusCode'] !== Taskmanager::TASK_WAITING && $task['statusCode'] !== Taskmanager::TASK_PROCESSING && $task['statusCode'] !== Taskmanager::TASK_FINISHED)
return true;
return false;
}
@@ -163,7 +170,7 @@ class Taskmanager
{
if (!is_array($task) || !isset($task['statusCode']) || !isset($task['id']))
return false;
- if ($task['statusCode'] !== TASK_WAITING && $task['statusCode'] !== TASK_PROCESSING)
+ if ($task['statusCode'] !== Taskmanager::TASK_WAITING && $task['statusCode'] !== Taskmanager::TASK_PROCESSING)
return true;
return false;
}
@@ -244,7 +251,3 @@ class Taskmanager
}
}
-
-foreach (array('TASK_FINISHED', 'TASK_ERROR', 'TASK_WAITING', 'NO_SUCH_TASK', 'NO_SUCH_INSTANCE', 'TASK_PROCESSING') as $i) {
- define($i, $i);
-}