From e00105d649d4a8e3ff89820563470cdd5d742ab9 Mon Sep 17 00:00:00 2001 From: Michael Date: Tue, 6 Jun 2017 11:59:38 +0000 Subject: [PATCH] Don't fork a new worker --- include/queue.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/include/queue.php b/include/queue.php index b21bf676ba..6b42cf31e0 100644 --- a/include/queue.php +++ b/include/queue.php @@ -27,7 +27,7 @@ function queue_run(&$argv, &$argc){ logger('queue: start'); // Handling the pubsubhubbub requests - proc_run(PRIORITY_HIGH,'include/pubsubpublish.php'); + proc_run(array('priority' => PRIORITY_HIGH, 'dont_fork' => true), 'include/pubsubpublish.php'); $r = q("SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue` INNER JOIN `contact` ON `queue`.`cid` = `contact`.`id` @@ -50,7 +50,7 @@ function queue_run(&$argv, &$argc){ if (dbm::is_result($r)) { foreach ($r as $q_item) { logger('Call queue for id '.$q_item['id']); - proc_run(PRIORITY_LOW, "include/queue.php", $q_item['id']); + proc_run(array('priority' => PRIORITY_LOW, 'dont_fork' => true), "include/queue.php", $q_item['id']); } } return;