Streams/streams
Streams/streams
1
0
Fork 0
mirror of https://codeberg.org/streams/streams.git synced 2024-09-20 02:15:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'dev' of codeberg.org:streams/streams into dev

Browse source
This commit is contained in:
Mike Macgirvin 2023-02-06 12:52:07 -08:00
commit 1289f2eb6b
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
Code/Daemon/Queue.php
View file

@ -34,6 +34,8 @@ class Queue implements DaemonInterface
}
}
logger('Removing ' . count($oldqItems) . ' old queue entries');
logger('Removing ' . count($oldqItems) . ' old queue entries');
q("DELETE FROM outq WHERE outq_created < %s - INTERVAL %s",
db_utcnow(),
db_quoteinterval('3 DAY')
@ -43,6 +45,7 @@ class Queue implements DaemonInterface
$qItems = q("SELECT * FROM outq WHERE outq_hash = '%s' LIMIT 1",
dbesc($queue_id)
);
logger('queue deliver: ' . $qItems[0]['outq_hash'] . ' to ' . $qItems[0]['outq_posturl'], LOGGER_DEBUG);
Zlib\Queue::deliver(array_shift($qItems));
}
else {
@ -52,6 +55,7 @@ class Queue implements DaemonInterface
db_utcnow()
);
if ($qItems) {
logger('queue deliver: ' . $qItems[0]['outq_hash'] . ' to ' . $qItems[0]['outq_posturl'], LOGGER_DEBUG);
Zlib\Queue::deliver(array_shift($qItems));
}
} while ($qItems);

2
include/network.php
View file

@ -799,7 +799,7 @@ function do_delivery($deliveries, $force = false)
// catch any stragglers
if ($deliver) {
Run::Summon([ 'Deliver',$deliver ]);
Run::Summon(['Deliver', $deliver]);
}
}