diff options
| author | Mario <mario@mariovavti.com> | 2022-12-02 19:22:19 +0000 |
|---|---|---|
| committer | Mario <mario@mariovavti.com> | 2022-12-02 19:22:19 +0000 |
| commit | 2bb58843ab303ba3e1a4a2c0c5a64138852ebbe0 (patch) | |
| tree | 1e85f560122aae0b30dfe5a55c3de90fbce64ed1 /Zotlabs/Lib/Libsync.php | |
| parent | d16b6c3838cd76eb7ce336444cbd37774857b64f (diff) | |
| download | volse-hubzilla-2bb58843ab303ba3e1a4a2c0c5a64138852ebbe0.tar.gz volse-hubzilla-2bb58843ab303ba3e1a4a2c0c5a64138852ebbe0.tar.bz2 volse-hubzilla-2bb58843ab303ba3e1a4a2c0c5a64138852ebbe0.zip | |
move queueworker to core and bump version
Diffstat (limited to 'Zotlabs/Lib/Libsync.php')
| -rw-r--r-- | Zotlabs/Lib/Libsync.php | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/Zotlabs/Lib/Libsync.php b/Zotlabs/Lib/Libsync.php index fd9886f71..b02ae4c69 100644 --- a/Zotlabs/Lib/Libsync.php +++ b/Zotlabs/Lib/Libsync.php @@ -135,8 +135,10 @@ class Libsync { $info['collection_members'] = $r; } + /* $interval = ((get_config('system', 'delivery_interval') !== false) ? intval(get_config('system', 'delivery_interval')) : 2); + */ logger('Packet: ' . print_r($info, true), LOGGER_DATA, LOG_DEBUG); @@ -155,19 +157,24 @@ class Libsync { ]); + /* $x = q("select count(outq_hash) as total from outq where outq_delivered = 0"); + if (intval($x[0]['total']) > intval(get_config('system', 'force_queue_threshold', 3000))) { logger('immediate delivery deferred.', LOGGER_DEBUG, LOG_INFO); Queue::update($hash); continue; } - + */ Master::Summon(['Deliver', $hash]); + + /* $total = $total - 1; if ($interval && $total) @time_sleep_until(microtime(true) + (float)$interval); + */ } } |