diff --git a/src/multi_socket_client.c b/src/multi_socket_client.c index 98d1e54..d32434b 100644 --- a/src/multi_socket_client.c +++ b/src/multi_socket_client.c @@ -295,7 +295,7 @@ static int fast_multi_sock_client_deal_io(FastMultiSockClient *client) while (client->pulling_count > 0) { remain_timeout = client->deadline_time - get_current_time(); - if (remain_timeout <= 0) { //timeout + if (remain_timeout < 0) { //timeout break; } diff --git a/src/multi_socket_client.h b/src/multi_socket_client.h index 3f6fb1b..5763c53 100644 --- a/src/multi_socket_client.h +++ b/src/multi_socket_client.h @@ -40,10 +40,10 @@ typedef struct fast_multi_sock_entry { ConnectionInfo *conn; //the socket must be non-block socket FastBuffer *send_buffer; //send buffer for internal use fast_multi_sock_client_io_func io_callback; //for internal use - FastBuffer recv_buffer; //recv buffer + FastBuffer recv_buffer; //recv buffer for response package int error_no; //0 for success, != 0 fail int remain; //remain bytes, for internal use - FastMultiSockRecvStage recv_stage; + FastMultiSockRecvStage recv_stage; //for internal use bool done; //for internal use } FastMultiSockEntry;