|
|
@@ -67,7 +67,7 @@ void CMessagePush::KeepAlive()
|
|
|
{
|
|
|
//走到这里来说明心跳包发送失败了,socket失效了
|
|
|
std::string err = e.what();
|
|
|
- LOG_INFO("write err info:" << err.c_str());
|
|
|
+ //LOG_INFO("write err info:" << err.c_str());
|
|
|
|
|
|
//先把socket关闭掉
|
|
|
socket_.close();
|
|
|
@@ -90,7 +90,7 @@ void CMessagePush::KeepAlive()
|
|
|
{
|
|
|
//重新连接或者重新发送又失败了,可能是网络断了
|
|
|
std::string err = e.what();
|
|
|
- LOG_INFO("write err info:" << err.c_str());
|
|
|
+ //LOG_INFO("write err info:" << err.c_str());
|
|
|
|
|
|
//关闭无效的连接
|
|
|
socket_.close();
|
|
|
@@ -127,7 +127,7 @@ void CMessagePush::ReceiveMessage()
|
|
|
document.Parse(msg.c_str());
|
|
|
if (!document.IsObject())
|
|
|
{
|
|
|
- LOG_INFO("message 非法!");
|
|
|
+ //LOG_INFO("message 非法!");
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
@@ -175,7 +175,7 @@ void CMessagePush::ReceiveMessage()
|
|
|
catch (std::exception& e)
|
|
|
{
|
|
|
std::string err = e.what();
|
|
|
- LOG_INFO("read err:" << err.c_str());
|
|
|
+ //LOG_INFO("read err:" << err.c_str());
|
|
|
|
|
|
//如果这里异常了,说明socket失效了,等2秒重新读
|
|
|
CSystem::my_sleep(2);
|