Friendica/friendica-github
1
0
Fork 0
mirror of https://github.com/friendica/friendica synced 2025-04-23 23:50:12 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update functions and calls

Browse source 
update function names and calls
This commit is contained in:
Adam Magness 2018-01-15 20:12:07 -05:00
parent a5b3f4b2ba
commit 33ac7a529f
4 changed files with 38 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

22
src/Model/Queue.php
View file

@ -13,13 +13,19 @@ require_once 'include/datetime.php';
class Queue
{
function update_queue_time($id)
/**
* @param string $id id
*/
public static function updateTime($id)
{
logger('queue: requeue item ' . $id);
dba::update('queue', ['last' => datetime_convert()], ['id' => $id]);
}
function remove_queue_item($id)
/**
* @param string $id id
*/
public static function removeItem($id)
{
logger('queue: remove queue item ' . $id);
dba::delete('queue', ['id' => $id]);
@ -32,7 +38,7 @@ class Queue
*
* @return bool The communication with this contact has currently problems
*/
function was_recently_delayed($cid)
public static function wasDelayed($cid)
{
// Are there queue entries that were recently added?
$r = q("SELECT `id` FROM `queue` WHERE `cid` = %d
@ -54,8 +60,13 @@ class Queue
return $was_delayed;
}
function add_to_queue($cid, $network, $msg, $batch = false)
/**
* @param string $cid cid
* @param string $network network
* @param string $msg message
* @param boolean $batch batch, default false
*/
public static function add($cid, $network, $msg, $batch = false)
{
$max_queue = Config::get('system', 'max_contact_queue');
@ -72,6 +83,7 @@ class Queue
WHERE `queue`.`cid` = %d AND `contact`.`self` = 0 ",
intval($cid)
);
if (DBM::is_result($r)) {
if ($batch && ($r[0]['total'] > $batch_queue)) {
logger('add_to_queue: too many queued items for batch server ' . $cid . ' - discarding message');