diff options
| author | M.Dent <dentm42@dm42.net> | 2018-10-25 10:12:03 -0400 |
|---|---|---|
| committer | M.Dent <dentm42@dm42.net> | 2018-10-25 10:12:03 -0400 |
| commit | aef212ada9ff61326ae56c5c17ff8873b7cc4c69 (patch) | |
| tree | eaf7415849f0bb9711701f19b1dbedd9e8ae84e4 | |
| parent | 9cedc864c296ad3fb394692440551c97bc644522 (diff) | |
| download | volse-hubzilla-aef212ada9ff61326ae56c5c17ff8873b7cc4c69.tar.gz volse-hubzilla-aef212ada9ff61326ae56c5c17ff8873b7cc4c69.tar.bz2 volse-hubzilla-aef212ada9ff61326ae56c5c17ff8873b7cc4c69.zip | |
Add entropy to queue worker - and fix requeuing of expired tasks
| -rw-r--r-- | Zotlabs/Daemon/Master.php | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Zotlabs/Daemon/Master.php b/Zotlabs/Daemon/Master.php index 3a71ee578..0656ca05b 100644 --- a/Zotlabs/Daemon/Master.php +++ b/Zotlabs/Daemon/Master.php @@ -60,7 +60,8 @@ class Master { $k = explode('_',$worker['k']); q("delete from config where cat='queueworkers' and k='%s'", 'workerstarted_'.$k[1]); - q("update config set k='workitem' where cat='queuework' and k='%s'", + q("update config set k='%s' where cat='queuework' and k='%s'", + dbesc(uniqid('workitem:',true)), 'workitem_'.$k[1]); unset($workers[$idx]); } @@ -69,7 +70,7 @@ class Master { return false; } } - return uniqid(); + return uniqid('',true); } |