forked from GNUsocial/gnu-social
whitespace in dbqueuemanager
This commit is contained in:
parent
0dab5f5872
commit
f227006789
@ -89,7 +89,7 @@ class DBQueueManager extends QueueManager
|
|||||||
do {
|
do {
|
||||||
$qi = Queue_item::top($queue);
|
$qi = Queue_item::top($queue);
|
||||||
if (empty($qi)) {
|
if (empty($qi)) {
|
||||||
sleep(1);
|
sleep(1);
|
||||||
} else {
|
} else {
|
||||||
$notice = Notice::staticGet('id', $qi->notice_id);
|
$notice = Notice::staticGet('id', $qi->notice_id);
|
||||||
if (!empty($notice)) {
|
if (!empty($notice)) {
|
||||||
@ -120,7 +120,7 @@ class DBQueueManager extends QueueManager
|
|||||||
} else {
|
} else {
|
||||||
if (empty($qi->claimed)) {
|
if (empty($qi->claimed)) {
|
||||||
$this->_log(LOG_WARNING, 'Reluctantly releasing unclaimed queue item '.
|
$this->_log(LOG_WARNING, 'Reluctantly releasing unclaimed queue item '.
|
||||||
'for '.$notice->id.', queue '.$queue);
|
'for '.$notice->id.', queue '.$queue);
|
||||||
}
|
}
|
||||||
$qi->delete();
|
$qi->delete();
|
||||||
$qi->free();
|
$qi->free();
|
||||||
@ -147,7 +147,7 @@ class DBQueueManager extends QueueManager
|
|||||||
} else {
|
} else {
|
||||||
if (empty($qi->claimed)) {
|
if (empty($qi->claimed)) {
|
||||||
$this->_log(LOG_WARNING, 'Ignoring failure for unclaimed queue item '.
|
$this->_log(LOG_WARNING, 'Ignoring failure for unclaimed queue item '.
|
||||||
'for '.$notice->id.', queue '.$queue);
|
'for '.$notice->id.', queue '.$queue);
|
||||||
} else {
|
} else {
|
||||||
$orig = clone($qi);
|
$orig = clone($qi);
|
||||||
$qi->claimed = null;
|
$qi->claimed = null;
|
||||||
|
Loading…
Reference in New Issue
Block a user