if ($age > 1) {
$stamp = (float)microtime(true);
- dba::update('workerqueue', ['executed' => Temporal::convert()], ['pid' => $mypid, 'done' => false]);
+ dba::update('workerqueue', ['executed' => Temporal::utcNow()], ['pid' => $mypid, 'done' => false]);
self::$db_duration += (microtime(true) - $stamp);
}
$stamp = (float)microtime(true);
if (dba::update('workerqueue', ['done' => true], ['id' => $queue["id"]])) {
- Config::set('system', 'last_poller_execution', Temporal::convert());
+ Config::set('system', 'last_poller_execution', Temporal::utcNow());
}
self::$db_duration = (microtime(true) - $stamp);
if ($age > 1) {
$stamp = (float)microtime(true);
- dba::update('workerqueue', ['executed' => Temporal::convert()], ['pid' => $mypid, 'done' => false]);
+ dba::update('workerqueue', ['executed' => Temporal::utcNow()], ['pid' => $mypid, 'done' => false]);
self::$db_duration += (microtime(true) - $stamp);
}
$stamp = (float)microtime(true);
if (dba::update('workerqueue', ['done' => true], ['id' => $queue["id"]])) {
- Config::set('system', 'last_poller_execution', Temporal::convert());
+ Config::set('system', 'last_poller_execution', Temporal::utcNow());
}
self::$db_duration = (microtime(true) - $stamp);
} else {
}
dba::update(
'workerqueue',
- ['executed' => NULL_DATE, 'created' => Temporal::convert(), 'priority' => $new_priority, 'pid' => 0],
+ ['executed' => NULL_DATE, 'created' => Temporal::utcNow(), 'priority' => $new_priority, 'pid' => 0],
['id' => $entry["id"]]
);
} else {
if ($found) {
$condition = "`id` IN (".substr(str_repeat("?, ", count($ids)), 0, -2).") AND `pid` = 0 AND NOT `done`";
array_unshift($ids, $condition);
- dba::update('workerqueue', ['executed' => Temporal::convert(), 'pid' => $mypid], $ids);
+ dba::update('workerqueue', ['executed' => Temporal::utcNow(), 'pid' => $mypid], $ids);
}
return $found;
$priority = PRIORITY_MEDIUM;
$dont_fork = Config::get("system", "worker_dont_fork");
- $created = Temporal::convert();
+ $created = Temporal::utcNow();
if (is_int($run_parameter)) {
$priority = $run_parameter;