mirror of
https://github.com/friendica/friendica
synced 2024-12-23 00:40:15 +00:00
Delivery to other systems was needlessly deferred.
This commit is contained in:
parent
4eeb5a0a17
commit
ba1a304589
1 changed files with 23 additions and 10 deletions
|
@ -15,22 +15,35 @@ function remove_queue_item($id) {
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief Checks if the communication with a given contact had problems recently
|
||||||
|
*
|
||||||
|
* @param int $cid Contact id
|
||||||
|
*
|
||||||
|
* @return bool The communication with this contact has currently problems
|
||||||
|
*/
|
||||||
function was_recently_delayed($cid) {
|
function was_recently_delayed($cid) {
|
||||||
|
|
||||||
$r = q("SELECT `id` FROM `queue` WHERE `cid` = %d
|
$was_delayed = false;
|
||||||
and last > UTC_TIMESTAMP() - interval 15 minute limit 1",
|
|
||||||
|
// Are there queue entries that were recently added?
|
||||||
|
$r = q("SELECT `id` FROM `queue` WHERE `cid` = %d
|
||||||
|
AND `last` > UTC_TIMESTAMP() - interval 15 minute LIMIT 1",
|
||||||
intval($cid)
|
intval($cid)
|
||||||
);
|
);
|
||||||
if(count($r))
|
|
||||||
return true;
|
|
||||||
|
|
||||||
$r = q("select `term-date` from contact where id = %d and `term-date` != '' and `term-date` != '0000-00-00 00:00:00' limit 1",
|
$was_delayed = dbm::is_result($r);
|
||||||
intval($cid)
|
|
||||||
);
|
|
||||||
if(count($r))
|
|
||||||
return true;
|
|
||||||
|
|
||||||
return false;
|
// We set "term-date" to a current date if the communication has problems.
|
||||||
|
// If the communication works again we reset this value.
|
||||||
|
if ($was_delayed) {
|
||||||
|
$r = q("SELECT `term-date` FROM `contact` WHERE `id` = %d AND `term-date` <= '1000-01-01' LIMIT 1",
|
||||||
|
intval($cid)
|
||||||
|
);
|
||||||
|
$was_delayed = !dbm::is_result($r);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $was_delayed;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue