Zotlabs/Daemon/Cache_query.php


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

<?php

namespace Zotlabs\Daemon;

use Zotlabs\Lib\Cache;
use Zotlabs\Lib\Config;

class Cache_query {

	static public function run($argc, $argv) {

		if(! $argc == 3)
			return;

		$r = null;
		$key = $argv[1];

		$pid = Config::Get('procid', $key, false);
		if ($pid && (function_exists('posix_kill') ? posix_kill($pid, 0) : true)) {
			logger($key . ': procedure already run with pid ' . $pid, LOGGER_DEBUG);
			return;
		}

		$pid = getmypid();
		Config::Set('procid', $key, $pid);

		array_shift($argv);
		array_shift($argv);

		$arr = json_decode(base64_decode($argv[0]), true);

		$r = call_user_func_array('q', $arr);

		if(is_array($r)) {
			Cache::set($key, serialize($r));
		}

		Config::Delete('procid', $key);

		return;
	}
}