@@ -252,9 +252,9 @@ void async_tcp_client::service()
252
252
// @pitfall: If still have data to read, only wait 1 millseconds.
253
253
get_wait_duration (timeout, this ->offset_ > 0 ? MAX_BUSY_DELAY : MAX_WAIT_DURATION);
254
254
255
- INET_LOG (" socket.select waiting... %ld milliseconds" , timeout.tv_sec * 1000 + timeout.tv_usec / 1000 );
255
+ INET_LOG (" socket.select maxfdp:%d waiting... %ld milliseconds" , maxfdp_ , timeout.tv_sec * 1000 + timeout.tv_usec / 1000 );
256
256
257
- int nfds = ::select (10000 , &(fdss_[read_op]), nullptr , nullptr , &timeout);
257
+ int nfds = ::select (maxfdp_ , &(fdss_[read_op]), nullptr , nullptr , &timeout);
258
258
259
259
INET_LOG (" socket.select waked up, retval=%d" , nfds);
260
260
@@ -491,7 +491,7 @@ bool async_tcp_client::connect(void)
491
491
492
492
this ->impl_ .set_optval (SOL_SOCKET, SO_REUSEADDR, 1 ); // set opt for p2p
493
493
494
- INET_LOG (" connect server: %s:%u succeed, fd=%d interrupterfd =%d" , address_.c_str (), port_, impl_.native_handle (), interrupter_.read_descriptor ());
494
+ INET_LOG (" connect server: %s:%u succeed, fd=%d interrupter_fd =%d" , address_.c_str (), port_, impl_.native_handle (), interrupter_.read_descriptor ());
495
495
496
496
#if 0 // provided as API
497
497
auto endp = this->impl_.local_endpoint();
0 commit comments