X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FProcess.php;h=40f0c52bdb4e361b9a3ef8f5d8bd57e890cf9b8c;hb=8d0f4710a4e4646c9dcc99cf8b4c0c36650c8efd;hp=99d5af543b4c255de66e16786a7fe2a429c0965a;hpb=dc366bf1f7b5b7b0fc1c1a86772783074b301993;p=friendica.git diff --git a/src/Model/Process.php b/src/Model/Process.php index 99d5af543b..40f0c52bdb 100644 --- a/src/Model/Process.php +++ b/src/Model/Process.php @@ -5,11 +5,10 @@ namespace Friendica\Model; use Friendica\BaseObject; -use Friendica\Util\Temporal; -use dba; +use Friendica\Database\DBA; +use Friendica\Util\DateTimeFormat; require_once 'include/dba.php'; -require_once 'include/datetime.php'; /** * @brief functions for interacting with a process @@ -31,13 +30,13 @@ class Process extends BaseObject $pid = getmypid(); } - dba::transaction(); + DBA::transaction(); - if (!dba::exists('process', ['pid' => $pid])) { - $return = dba::insert('process', ['pid' => $pid, 'command' => $command, 'created' => Temporal::convert()]); + if (!DBA::exists('process', ['pid' => $pid])) { + $return = DBA::insert('process', ['pid' => $pid, 'command' => $command, 'created' => DateTimeFormat::utcNow()]); } - dba::commit(); + DBA::commit(); return $return; } @@ -54,7 +53,7 @@ class Process extends BaseObject $pid = getmypid(); } - return dba::delete('process', ['pid' => $pid]); + return DBA::delete('process', ['pid' => $pid]); } /** @@ -62,15 +61,15 @@ class Process extends BaseObject */ public static function deleteInactive() { - dba::transaction(); + DBA::transaction(); - $processes = dba::select('process', ['pid']); - while($process = dba::fetch($processes)) { + $processes = DBA::select('process', ['pid']); + while($process = DBA::fetch($processes)) { if (!posix_kill($process['pid'], 0)) { self::deleteByPid($process['pid']); } } - dba::commit(); + DBA::commit(); } }