diff options
| author | Mario <mario@mariovavti.com> | 2020-11-13 13:49:39 +0000 |
|---|---|---|
| committer | Mario <mario@mariovavti.com> | 2020-11-13 13:49:39 +0000 |
| commit | 685c569eaf094fd7f354bd3fa8026ecefadfa590 (patch) | |
| tree | cbb96917c668859dcb82770da987d92471dde125 /include | |
| parent | b6e34695197191275d6d9f4f63f7f976bcf89a2d (diff) | |
| download | volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.tar.gz volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.tar.bz2 volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.zip | |
minor queue adjustments
Diffstat (limited to 'include')
| -rw-r--r-- | include/network.php | 5 | ||||
| -rw-r--r-- | include/zot.php | 4 |
2 files changed, 5 insertions, 4 deletions
diff --git a/include/network.php b/include/network.php index 9d4c00ee8..bcd66cf85 100644 --- a/include/network.php +++ b/include/network.php @@ -2,6 +2,7 @@ use Zotlabs\Lib\Zotfinger; use Zotlabs\Lib\Libzot; +use Zotlabs\Lib\Queue; /** * @file include/network.php @@ -1437,10 +1438,10 @@ function do_delivery($deliveries, $force = false) { $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',300)) && (! $force)) { + if(intval($x[0]['total']) > intval(get_config('system','force_queue_threshold',3000)) && (! $force)) { logger('immediate delivery deferred.', LOGGER_DEBUG, LOG_INFO); foreach($deliveries as $d) { - update_queue_item($d); + Queue::update($d); } return; } diff --git a/include/zot.php b/include/zot.php index 8a2177de7..d61873ba2 100644 --- a/include/zot.php +++ b/include/zot.php @@ -3452,7 +3452,7 @@ function build_sync_packet($uid = 0, $packet = null, $groups_changed = false) { $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',300))) { + if(intval($x[0]['total']) > intval(get_config('system','force_queue_threshold',3000))) { logger('immediate delivery deferred.', LOGGER_DEBUG, LOG_INFO); update_queue_item($hash); continue; @@ -4286,7 +4286,7 @@ function zot_reply_message_request($data) { $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',300))) { + if(intval($x[0]['total']) > intval(get_config('system','force_queue_threshold',3000))) { logger('immediate delivery deferred.', LOGGER_DEBUG, LOG_INFO); update_queue_item($hash); continue; |