GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

Always queue inbox distribution

Browse Source
This commit is contained in:
Mikael Nordfeldth 2014-03-06 01:50:54 +01:00
parent c0f65f6ea7
commit 00db57949f
2 changed files with 14 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
classes/Notice.php
View File

@ -2071,28 +2071,23 @@ class Notice extends Managed_DataObject
Inbox::insertNotice($this, $user->id);
}
if (common_config('queue', 'inboxes')) {
// If there's a failure, we want to _force_
// distribution at this point.
// If there's a failure, we want to _force_
// distribution at this point.
try {
$qm = QueueManager::get();
$qm->enqueue($this, 'distrib');
} catch (Exception $e) {
// If the exception isn't transient, this
// may throw more exceptions as DQH does
// its own enqueueing. So, we ignore them!
try {
$qm = QueueManager::get();
$qm->enqueue($this, 'distrib');
$handler = new DistribQueueHandler();
$handler->handle($this);
} catch (Exception $e) {
// If the exception isn't transient, this
// may throw more exceptions as DQH does
// its own enqueueing. So, we ignore them!
try {
$handler = new DistribQueueHandler();
$handler->handle($this);
} catch (Exception $e) {
common_log(LOG_ERR, "emergency redistribution resulted in " . $e->getMessage());
}
// Re-throw so somebody smarter can handle it.
throw $e;
common_log(LOG_ERR, "emergency redistribution resulted in " . $e->getMessage());
}
} else {
$handler = new DistribQueueHandler();
$handler->handle($this);
// Re-throw so somebody smarter can handle it.
throw $e;
}
}

1
lib/default.php
View File

@ -100,7 +100,6 @@ $default =
'softlimit' => '90%', // total size or % of memory_limit at which to restart queue threads gracefully
'spawndelay' => 1, // Wait at least N seconds between (re)spawns of child processes to avoid slamming the queue server with subscription startup
'debug_memory' => false, // true to spit memory usage to log
'inboxes' => true, // true to do inbox distribution & output queueing from in background via 'distrib' queue
'breakout' => array(), // List queue specifiers to break out when using Stomp queue.
// Default will share all queues for all sites within each group.
// Specify as <group>/<queue> or <group>/<queue>/<site>,