mirror of
https://git.sekbaer.de/Friendica/friendica.git
synced 2025-06-17 04:15:15 +02:00
Merge pull request #2975 from annando/1611-frontend-worker
The worker can now run from the frontend as well
This commit is contained in:
commit
d55d500e35
6 changed files with 332 additions and 94 deletions
47
mod/worker.php
Normal file
47
mod/worker.php
Normal file
|
@ -0,0 +1,47 @@
|
|||
<?php
|
||||
/**
|
||||
* @file mod/worker.php
|
||||
* @brief Module for running the poller as frontend process
|
||||
*/
|
||||
require_once("include/poller.php");
|
||||
|
||||
use \Friendica\Core\Config;
|
||||
use \Friendica\Core\PConfig;
|
||||
|
||||
function worker_init($a){
|
||||
|
||||
if (!Config::get("system", "frontend_worker")) {
|
||||
return;
|
||||
}
|
||||
|
||||
clear_worker_processes();
|
||||
|
||||
$workers = q("SELECT COUNT(*) AS `processes` FROM `process` WHERE `command` = 'worker.php'");
|
||||
|
||||
if ($workers[0]["processes"] > Config::get("system", "worker_queues", 4)) {
|
||||
return;
|
||||
}
|
||||
|
||||
$a->start_process();
|
||||
|
||||
logger("Front end worker started: ".getmypid());
|
||||
|
||||
call_worker();
|
||||
|
||||
if ($r = poller_worker_process()) {
|
||||
|
||||
// On most configurations this parameter wouldn't have any effect.
|
||||
// But since it doesn't destroy anything, we just try to get more execution time in any way.
|
||||
set_time_limit(0);
|
||||
|
||||
poller_execute($r[0]);
|
||||
}
|
||||
|
||||
call_worker();
|
||||
|
||||
$a->end_process();
|
||||
|
||||
logger("Front end worker ended: ".getmypid());
|
||||
|
||||
killme();
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue