aboutsummaryrefslogtreecommitdiffstats
path: root/Zotlabs/Lib/Queue.php
diff options
context:
space:
mode:
authorMario <mario@mariovavti.com>2023-05-17 13:28:23 +0000
committerMario <mario@mariovavti.com>2023-05-17 13:28:23 +0000
commit65d98af24c3c7b784f7e2c95998df65901011ce3 (patch)
treed7d6a60698d7a0c3704ea55cb71c543285186b17 /Zotlabs/Lib/Queue.php
parenta57739c462a7991bf2130e8eca0c383eb276f0cd (diff)
parent62d35627f35537d0056482047e74a27ad837c3cf (diff)
downloadvolse-hubzilla-65d98af24c3c7b784f7e2c95998df65901011ce3.tar.gz
volse-hubzilla-65d98af24c3c7b784f7e2c95998df65901011ce3.tar.bz2
volse-hubzilla-65d98af24c3c7b784f7e2c95998df65901011ce3.zip
Merge branch '8.4RC'8.4
Diffstat (limited to 'Zotlabs/Lib/Queue.php')
-rw-r--r--Zotlabs/Lib/Queue.php24
1 files changed, 5 insertions, 19 deletions
diff --git a/Zotlabs/Lib/Queue.php b/Zotlabs/Lib/Queue.php
index 348a2a079..942a633ef 100644
--- a/Zotlabs/Lib/Queue.php
+++ b/Zotlabs/Lib/Queue.php
@@ -57,7 +57,6 @@ class Queue {
outq_priority = outq_priority + %d,
outq_scheduled = '%s'
WHERE outq_hash = '%s'",
-
dbesc(datetime_convert()),
intval($add_priority),
dbesc($next),
@@ -85,29 +84,16 @@ class Queue {
// entries still exist for it. This fixes an issue where one immediate delivery left everything
// else for that site undeliverable since all the other entries had been pushed far into the future.
- $x = null;
- $sql_quirks = ((get_config('system', 'db_skip_locked_supported')) ? 'SKIP LOCKED' : 'NOWAIT');
-
- q("START TRANSACTION");
-
- $r = q("SELECT outq_hash FROM outq WHERE outq_posturl = '%s' LIMIT 1 FOR UPDATE $sql_quirks",
+ $r = q("SELECT outq_hash, outq_posturl FROM outq WHERE outq_posturl = '%s' LIMIT 1",
dbesc($record[0]['outq_posturl'])
);
if ($r) {
- $x = q("UPDATE outq SET outq_scheduled = '%s' WHERE outq_hash = '%s'",
- dbesc(datetime_convert()),
- dbesc($r[0]['outq_hash'])
+ $hashes = ids_to_querystr($r, 'outq_hash', true);
+ $x = q("UPDATE outq SET outq_scheduled = '%s' WHERE outq_hash IN ($hashes)",
+ dbesc(datetime_convert())
);
}
-
- if ($x) {
- q("COMMIT");
- }
- else {
- q("ROLLBACK");
- }
-
}
}
@@ -260,7 +246,7 @@ class Queue {
if($result['success']) {
logger('deliver: remote zot delivery succeeded to ' . $outq['outq_posturl']);
- Libzot::process_response($outq['outq_posturl'],$result, $outq);
+ Libzot::process_response($outq['outq_posturl'], $result, $outq);
}
else {
logger('deliver: remote zot delivery failed to ' . $outq['outq_posturl']);