We don't need _that_ noisy queue managers...
This commit is contained in:
parent
8fdc999be4
commit
eb5097aecb
@ -71,10 +71,10 @@ class DBQueueManager extends QueueManager
|
|||||||
*/
|
*/
|
||||||
public function poll()
|
public function poll()
|
||||||
{
|
{
|
||||||
$this->_log(LOG_DEBUG, 'Checking for notices...');
|
//$this->_log(LOG_DEBUG, 'Checking for notices...');
|
||||||
$qi = Queue_item::top($this->activeQueues());
|
$qi = Queue_item::top($this->activeQueues());
|
||||||
if (empty($qi)) {
|
if (empty($qi)) {
|
||||||
$this->_log(LOG_DEBUG, 'No notices waiting; idling.');
|
//$this->_log(LOG_DEBUG, 'No notices waiting; idling.');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -132,7 +132,7 @@ abstract class IoMaster
|
|||||||
$write = array();
|
$write = array();
|
||||||
$except = array();
|
$except = array();
|
||||||
$this->logState('listening');
|
$this->logState('listening');
|
||||||
common_log(LOG_DEBUG, "Waiting up to $timeout seconds for socket data...");
|
//common_debug("Waiting up to $timeout seconds for socket data...");
|
||||||
$ready = stream_select($read, $write, $except, $timeout, 0);
|
$ready = stream_select($read, $write, $except, $timeout, 0);
|
||||||
|
|
||||||
if ($ready === false) {
|
if ($ready === false) {
|
||||||
|
Loading…
Reference in New Issue
Block a user