|
|
@@ -94,7 +94,7 @@ public:
|
|
|
|
|
|
void on_message(std::shared_ptr<client> clt,const char*data,size_t len)
|
|
|
{
|
|
|
-// m_serv.on_message(clt,data,len);
|
|
|
+ m_serv.on_message(clt,data,len);
|
|
|
}
|
|
|
|
|
|
void close_all()
|
|
|
@@ -321,7 +321,8 @@ struct sock_client:fd_io,client_ex
|
|
|
void on_recv_timeout()
|
|
|
{
|
|
|
m_ic.on_recv_timeout(shared_from_this());
|
|
|
- log_info("socket %s recv timeout.",m_name.c_str());
|
|
|
+ logn_warn(1,"socket %s recv timeout.",m_name.c_str());
|
|
|
+ close_impl();
|
|
|
}
|
|
|
|
|
|
std::string name()
|
|
|
@@ -369,7 +370,7 @@ struct sock_client:fd_io,client_ex
|
|
|
}
|
|
|
else if(rc==-1)
|
|
|
{
|
|
|
- logn_errno(1,"hava a error on socket %d(%s)",m_fd,m_name.c_str());
|
|
|
+ logn_warn(1,"hava a error on socket %d(%s)",m_fd,m_name.c_str());
|
|
|
}
|
|
|
return -1;
|
|
|
}
|
|
|
@@ -384,7 +385,7 @@ struct sock_client:fd_io,client_ex
|
|
|
fd_io::stop();
|
|
|
m_ic.on_close(shared_from_this());
|
|
|
|
|
|
- log_info("socket %s closed.",m_name.c_str());
|
|
|
+ logn_info(1,"socket %s closed.",m_name.c_str());
|
|
|
}
|
|
|
|
|
|
size_t calc_length(uint8_t*b)const
|
|
|
@@ -562,7 +563,7 @@ struct sock_listen: fd_io
|
|
|
{
|
|
|
sock_listen(io_context&ic,int fd):fd_io(ic,fd){}
|
|
|
|
|
|
- int recv_time_out=config.get("service.recv_timeout",30);
|
|
|
+ int recv_time_out=config.get("service.recv_timeout",10);
|
|
|
int max_package_size=config.get("service.max_package",2048);
|
|
|
|
|
|
void operator()(ev::io &w, int)
|
zzj