harukin/core
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'patch-20181230a' into 'dev'

Browse Source 
Use subselect

See merge request hubzilla/core!1451
This commit is contained in:
Mario 2019-01-02 19:47:39 +01:00
commit c4400cf72a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Zotlabs/Daemon/Master.php
View File

@ -89,7 +89,7 @@ class Master {
$workersleep = ($workersleep) ? $workersleep : 5; $workersleep = ($workersleep) ? $workersleep : 5;
cli_startup(); cli_startup();
$work = q("update config set k='%s' where cat='queuework' and k like '%s' limit 1", $work = q("update config set k='%s' where id in (select id from config where cat='queuework' and k like '%s' limit 1)",
'workitem_'.self::$queueworker, 'workitem_'.self::$queueworker,
dbesc('workitem:%')); dbesc('workitem:%'));
$jobs = 0; $jobs = 0;
@ -122,9 +122,9 @@ class Master {
break; break;
} }
sleep ($workersleep); sleep ($workersleep);
$work = q("update config set k='%s' where cat='queuework' and k like '%s' limit 1", $work = q("update config set k='%s' where id in (select id from config where cat='queuework' and k like '%s' limit 1)",
'workitem_'.self::$queueworker, 'workitem_'.self::$queueworker,
dbesc('workitem:%')); dbesc('workitem:%'));
} }
logger('Master: Worker Thread: queue items processed:' . $jobs); logger('Master: Worker Thread: queue items processed:' . $jobs);