From: Michael <heluecht@pirati.ca>
Date: Sat, 29 Aug 2020 11:26:40 +0000 (+0000)
Subject: Unclaim on end / don't refetch
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=8148d9dc9db8599ed92e6698930e9020854e455e;p=friendica.git

Unclaim on end / don't refetch
---

diff --git a/src/Core/Worker.php b/src/Core/Worker.php
index f4df322492..bbb6f57b2a 100644
--- a/src/Core/Worker.php
+++ b/src/Core/Worker.php
@@ -96,7 +96,8 @@ class Worker
 
 		// We fetch the next queue entry that is about to be executed
 		while ($r = self::workerProcess()) {
-			$refetched = false;
+			// Don't refetch when a worker fetches tasks for multiple workers
+			$refetched = DI::config()->get('system', 'worker_multiple_fetch');
 			foreach ($r as $entry) {
 				// Assure that the priority is an integer value
 				$entry['priority'] = (int)$entry['priority'];
@@ -143,6 +144,7 @@ class Worker
 			// Quit the worker once every cron interval
 			if (time() > ($starttime + (DI::config()->get('system', 'cron_interval') * 60))) {
 				Logger::info('Process lifetime reached, respawning.');
+				self::unclaimProcess();
 				self::spawnWorker();
 				return;
 			}