|
@@ -191,10 +191,11 @@ struct sock_client:fd_io,client_ex
|
|
:fd_io(ic,fd,EV_READ|EV_WRITE)
|
|
:fd_io(ic,fd,EV_READ|EV_WRITE)
|
|
,m_ic(ic)
|
|
,m_ic(ic)
|
|
,m_name(name)
|
|
,m_name(name)
|
|
|
|
+ ,m_recv_timer(ic)
|
|
{
|
|
{
|
|
m_max_package_size=max_package_size;
|
|
m_max_package_size=max_package_size;
|
|
|
|
|
|
- m_recv_timer.set(ic);
|
|
|
|
|
|
+// m_recv_timer.set(ic);
|
|
m_recv_timer.set(recv_time_out,0);
|
|
m_recv_timer.set(recv_time_out,0);
|
|
m_recv_timer.set<sock_client,&sock_client::on_recv_timeout>(this);
|
|
m_recv_timer.set<sock_client,&sock_client::on_recv_timeout>(this);
|
|
m_recv_timer.start();
|
|
m_recv_timer.start();
|
|
@@ -469,7 +470,7 @@ struct signal_w:ev::sig
|
|
signal_w(io_context&ic, int s)
|
|
signal_w(io_context&ic, int s)
|
|
:m_ic(ic)
|
|
:m_ic(ic)
|
|
{
|
|
{
|
|
- this->set(m_ic);
|
|
|
|
|
|
+// this->set(m_ic);
|
|
this->set(this);
|
|
this->set(this);
|
|
this->set(s);
|
|
this->set(s);
|
|
this->start();
|
|
this->start();
|