X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FProcess.php;h=4d50ecd4ebc180b7f4993d3e223fb43b685e9f90;hb=5aacb335ae0522abbc9bde6fb2684a5646a39fe7;hp=6b2d2fb64b66bc2824c6bc2a4450e37fa0b4e44f;hpb=78ac7afe9cb110fa92c0e600b15f8efdb76b2b52;p=friendica.git

diff --git a/src/Model/Process.php b/src/Model/Process.php
index 6b2d2fb64b..4d50ecd4eb 100644
--- a/src/Model/Process.php
+++ b/src/Model/Process.php
@@ -5,9 +5,8 @@
 namespace Friendica\Model;
 
 use Friendica\BaseObject;
-use dba;
-
-require_once 'include/dba.php';
+use Friendica\Database\DBA;
+use Friendica\Util\DateTimeFormat;
 
 /**
  * @brief functions for interacting with a process
@@ -23,13 +22,19 @@ class Process extends BaseObject
 	 */
 	public static function insert($command, $pid = null)
 	{
-		dba::transaction();
+		$return = true;
+
+		if (is_null($pid)) {
+			$pid = getmypid();
+		}
+
+		DBA::transaction();
 
-		if (!dba::exists('process', ['pid' => getmypid()])) {
-			$return = dba::insert('process', ['pid' => $pid, 'command' => $command, 'created' => datetime_convert()]);
+		if (!DBA::exists('process', ['pid' => $pid])) {
+			$return = DBA::insert('process', ['pid' => $pid, 'command' => $command, 'created' => DateTimeFormat::utcNow()]);
 		}
 
-		dba::commit();
+		DBA::commit();
 
 		return $return;
 	}
@@ -46,7 +51,7 @@ class Process extends BaseObject
 			$pid = getmypid();
 		}
 
-		return dba::delete('process', ['pid' => $pid]);
+		return DBA::delete('process', ['pid' => $pid]);
 	}
 
 	/**
@@ -54,15 +59,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();
 	}
 }