diff options
author | Simon Rettberg | 2016-06-09 18:06:06 +0200 |
---|---|---|
committer | Simon Rettberg | 2016-06-09 18:06:06 +0200 |
commit | eb448fcc611b87108b00b3d402188519a54b5764 (patch) | |
tree | 83d7d11049dd448e40a132106f0f6e1d24c9b41c /inc | |
parent | Fix some translations and page titles (diff) | |
download | slx-admin-eb448fcc611b87108b00b3d402188519a54b5764.tar.gz slx-admin-eb448fcc611b87108b00b3d402188519a54b5764.tar.xz slx-admin-eb448fcc611b87108b00b3d402188519a54b5764.zip |
Remove remaining references to schema version
Diffstat (limited to 'inc')
-rw-r--r-- | inc/taskmanagercallback.inc.php | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/inc/taskmanagercallback.inc.php b/inc/taskmanagercallback.inc.php index f40db297..c2a05609 100644 --- a/inc/taskmanagercallback.inc.php +++ b/inc/taskmanagercallback.inc.php @@ -29,15 +29,16 @@ class TaskmanagerCallback 'task' => $task, 'callback' => $callback, ); - if (Property::getCurrentSchemaVersion() >= 9) { - if (is_null($args)) - $data['args'] = ''; - else - $data['args'] = serialize($args); - Database::exec("INSERT INTO callback (taskid, dateline, cbfunction, args) VALUES (:task, UNIX_TIMESTAMP(), :callback, :args)", $data); + if (is_null($args)) { + $data['args'] = ''; } else { - Database::exec("INSERT INTO callback (taskid, dateline, cbfunction) VALUES (:task, UNIX_TIMESTAMP(), :callback)", $data); + $data['args'] = serialize($args); } + if (Database::exec("INSERT INTO callback (taskid, dateline, cbfunction, args)" + . " VALUES (:task, UNIX_TIMESTAMP(), :callback, :args)", $data, true) !== false) { + return; + } + Database::exec("INSERT INTO callback (taskid, dateline, cbfunction) VALUES (:task, UNIX_TIMESTAMP(), :callback)", $data); } /** @@ -47,10 +48,10 @@ class TaskmanagerCallback */ public static function getPendingCallbacks() { - if (Property::getCurrentSchemaVersion() < 9) + $res = Database::simpleQuery("SELECT taskid, cbfunction, args FROM callback", array(), true); + if ($res === false) return array(); $retval = array(); - $res = Database::simpleQuery("SELECT taskid, cbfunction, args FROM callback"); while ($row = $res->fetch(PDO::FETCH_ASSOC)) { $retval[$row['taskid']][] = $row; } |