}
use \Friendica\Core\Config;
-use \Friendica\Core\PConfig;
require_once("boot.php");
unset($db_host, $db_user, $db_pass, $db_data);
};
+ Config::load();
+
// Quit when in maintenance
- if (get_config('system', 'maintenance', true))
+ if (Config::get('system', 'maintenance', true)) {
return;
+ }
+
+ $a->set_baseurl(Config::get('system', 'url'));
+
+ load_hooks();
$a->start_process();
- if ($a->max_processes_reached())
+ if (poller_max_connections_reached()) {
return;
+ }
- if (poller_max_connections_reached())
+ if ($a->maxload_reached()) {
return;
+ }
+
+ if(($argc <= 1) OR ($argv[1] != "no_cron")) {
+ poller_run_cron();
+ }
- if (App::maxload_reached())
+ if ($a->max_processes_reached()) {
return;
+ }
// Checking the number of workers
if (poller_too_much_workers()) {
return;
}
- if(($argc <= 1) OR ($argv[1] != "no_cron")) {
- poller_run_cron();
- } else
- // Sleep four seconds before checking for running processes again to avoid having too many workers
- sleep(4);
-
- // Checking number of workers
- if (poller_too_much_workers())
- return;
-
$starttime = time();
while ($r = poller_worker_process()) {
$mypid = getmypid();
- $cooldown = Config::get("system", "worker_cooldown", 0);
-
// Quit when in maintenance
- if (get_config('system', 'maintenance', true)) {
+ if (Config::get('system', 'maintenance', true)) {
return false;
}
$argv = json_decode($queue["parameter"]);
- $argc = count($argv);
-
// Check for existance and validity of the include file
$include = $argv[0];
$funcname = str_replace(".php", "", basename($argv[0]))."_run";
if (function_exists($funcname)) {
- logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." ".$queue["parameter"]);
-
- // For better logging create a new process id for every worker call
- // But preserve the old one for the worker
- $old_process_id = $a->process_id;
- $a->process_id = uniqid("wrk", true);
-
- $funcname($argv, $argc);
-
- $a->process_id = $old_process_id;
- if ($cooldown > 0) {
- logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." - in cooldown for ".$cooldown." seconds");
- sleep($cooldown);
- }
-
- logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." - done");
+ poller_exec_function($queue, $funcname, $argv);
q("DELETE FROM `workerqueue` WHERE `id` = %d", intval($queue["id"]));
} else {
return true;
}
+/**
+ * @brief Execute a function from the queue
+ *
+ * @param array $queue Workerqueue entry
+ * @param string $funcname name of the function
+ * @param array $argv Array of values to be passed to the function
+ */
+function poller_exec_function($queue, $funcname, $argv) {
+
+ $a = get_app();
+
+ $mypid = getmypid();
+
+ $argc = count($argv);
+
+ logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." ".$queue["parameter"]);
+
+ $stamp = (float)microtime(true);
+
+ // We use the callstack here to analyze the performance of executed worker entries.
+ // For this reason the variables have to be initialized.
+ if (Config::get("system", "profiler")) {
+ $a->performance["start"] = microtime(true);
+ $a->performance["database"] = 0;
+ $a->performance["database_write"] = 0;
+ $a->performance["network"] = 0;
+ $a->performance["file"] = 0;
+ $a->performance["rendering"] = 0;
+ $a->performance["parser"] = 0;
+ $a->performance["marktime"] = 0;
+ $a->performance["markstart"] = microtime(true);
+ $a->callstack = array();
+ }
+
+ // For better logging create a new process id for every worker call
+ // But preserve the old one for the worker
+ $old_process_id = $a->process_id;
+ $a->process_id = uniqid("wrk", true);
+
+ $funcname($argv, $argc);
+
+ $a->process_id = $old_process_id;
+
+ $duration = number_format(microtime(true) - $stamp, 3);
+
+ logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." - done in ".$duration." seconds.");
+
+ // Write down the performance values into the log
+ if (Config::get("system", "profiler")) {
+ $duration = microtime(true)-$a->performance["start"];
+
+ if (Config::get("rendertime", "callstack")) {
+ if (isset($a->callstack["database"])) {
+ $o = "\nDatabase Read:\n";
+ foreach ($a->callstack["database"] AS $func => $time) {
+ $time = round($time, 3);
+ if ($time > 0)
+ $o .= $func.": ".$time."\n";
+ }
+ }
+ if (isset($a->callstack["database_write"])) {
+ $o .= "\nDatabase Write:\n";
+ foreach ($a->callstack["database_write"] AS $func => $time) {
+ $time = round($time, 3);
+ if ($time > 0)
+ $o .= $func.": ".$time."\n";
+ }
+ }
+ if (isset($a->callstack["network"])) {
+ $o .= "\nNetwork:\n";
+ foreach ($a->callstack["network"] AS $func => $time) {
+ $time = round($time, 3);
+ if ($time > 0)
+ $o .= $func.": ".$time."\n";
+ }
+ }
+ } else {
+ $o = '';
+ }
+
+ logger("ID ".$queue["id"].": ".$funcname.": ".sprintf("DB: %s/%s, Net: %s, I/O: %s, Other: %s, Total: %s".$o,
+ number_format($a->performance["database"] - $a->performance["database_write"], 2),
+ number_format($a->performance["database_write"], 2),
+ number_format($a->performance["network"], 2),
+ number_format($a->performance["file"], 2),
+ number_format($duration - ($a->performance["database"] + $a->performance["network"] + $a->performance["file"]), 2),
+ number_format($duration, 2)),
+ LOGGER_DEBUG);
+ }
+
+ $cooldown = Config::get("system", "worker_cooldown", 0);
+
+ if ($cooldown > 0) {
+ logger("Process ".$mypid." - Prio ".$queue["priority"]." - ID ".$queue["id"].": ".$funcname." - in cooldown for ".$cooldown." seconds");
+ sleep($cooldown);
+ }
+}
+
/**
* @brief Checks if the number of database connections has reached a critical limit.
*
function poller_max_connections_reached() {
// Fetch the max value from the config. This is needed when the system cannot detect the correct value by itself.
- $max = get_config("system", "max_connections");
+ $max = Config::get("system", "max_connections");
// Fetch the percentage level where the poller will get active
- $maxlevel = get_config("system", "max_connections_level");
- if ($maxlevel == 0)
- $maxlevel = 75;
+ $maxlevel = Config::get("system", "max_connections_level", 75);
if ($max == 0) {
// the maximum number of possible user connections can be a system variable
// The processlist only shows entries of the current user
if ($max != 0) {
$r = q("SHOW PROCESSLIST");
- if (!$r)
+ if (!dbm::is_result($r))
return false;
$used = count($r);
* @return bool Are there too much workers running?
*/
function poller_too_much_workers() {
-
-
- $queues = get_config("system", "worker_queues");
-
- if ($queues == 0)
- $queues = 4;
+ $queues = Config::get("system", "worker_queues", 4);
$maxqueues = $queues;
// Decrease the number of workers at higher load
$load = current_load();
if($load) {
- $maxsysload = intval(get_config('system','maxloadavg'));
- if($maxsysload < 1)
- $maxsysload = 50;
+ $maxsysload = intval(Config::get("system", "maxloadavg", 50));
$maxworkers = $queues;
logger("Load: ".$load."/".$maxsysload." - processes: ".$active."/".$entries." (".$processlist.") - maximum: ".$queues."/".$maxqueues, LOGGER_DEBUG);
// Are there fewer workers running as possible? Then fork a new one.
- if (!get_config("system", "worker_dont_fork") AND ($queues > ($active + 1)) AND ($entries > 1)) {
+ if (!Config::get("system", "worker_dont_fork") AND ($queues > ($active + 1)) AND ($entries > 1)) {
logger("Active workers: ".$active."/".$queues." Fork a new worker.", LOGGER_DEBUG);
- $args = array("php", "include/poller.php", "no_cron");
+ $args = array("include/poller.php", "no_cron");
$a = get_app();
$a->proc_run($args);
}
* @brief Call the front end worker
*/
function call_worker() {
- if (!get_config("system", "frontend_worker")) {
+ if (!Config::get("system", "frontend_worker")) {
return;
}
- $url = get_app()->get_baseurl()."/worker";
+ $url = App::get_baseurl()."/worker";
fetch_url($url, false, $redirects, 1);
}
* @brief Call the front end worker if there aren't any active
*/
function call_worker_if_idle() {
- if (!get_config("system", "frontend_worker")) {
+ if (!Config::get("system", "frontend_worker")) {
return;
}
+ // Do we have "proc_open"? Then we can fork the poller
+ if (function_exists("proc_open")) {
+ // When was the last time that we called the worker?
+ // Less than one minute? Then we quit
+ if ((time() - Config::get("system", "worker_started")) < 60) {
+ return;
+ }
+
+ set_config("system", "worker_started", time());
+
+ // Do we have enough running workers? Then we quit here.
+ if (poller_too_much_workers()) {
+ // Cleaning dead processes
+ poller_kill_stale_workers();
+ get_app()->remove_inactive_processes();
+
+ return;
+ }
+
+ poller_run_cron();
+
+ logger('Call poller', LOGGER_DEBUG);
+
+ $args = array("include/poller.php", "no_cron");
+ $a = get_app();
+ $a->proc_run($args);
+ return;
+ }
+
+ // We cannot execute background processes.
+ // We now run the processes from the frontend.
+ // This won't work with long running processes.
poller_run_cron();
clear_worker_processes();
* @brief Runs the cron processes
*/
function poller_run_cron() {
+ logger('Add cron entries', LOGGER_DEBUG);
+
+ // Check for spooled items
+ proc_run(PRIORITY_HIGH, "include/spool_post.php");
+
// Run the cron job that calls all other jobs
proc_run(PRIORITY_MEDIUM, "include/cron.php");
projects / friendica.git / blobdiff