|
@@ -54,7 +54,6 @@ function subscribe_message(&$quit, &$redis, $channels)
|
|
|
Log::record("subscribe_message start quit=" . strbool($quit),Log::DEBUG);
|
|
|
if(!$redis->connected) {
|
|
|
$ret = $redis->connect(C('coroutine.redis_host'), C('coroutine.redis_port'));
|
|
|
- Log::record("subscribe_message redis connected = {$redis->connected}",Log::DEBUG);
|
|
|
}
|
|
|
else {
|
|
|
$ret = true;
|
|
@@ -101,7 +100,6 @@ function subscribe_message(&$quit, &$redis, $channels)
|
|
|
Log::record("subscribe_message recv mgs:{$sub_type}-{$channel}-{$type}",Log::DEBUG);
|
|
|
}
|
|
|
}
|
|
|
- Log::record("subscribe_message redis recv timeout",Log::DEBUG);
|
|
|
}
|
|
|
else {
|
|
|
Log::record("subscribe_message subscribe error",Log::ERR);
|