From d366aa6492b284d0fd7b4c9225f3f33c522f3acb Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Tue, 24 Sep 2019 10:20:49 +0800
Subject: [PATCH] multi_socket_client: fix timeout check

---
 src/multi_socket_client.c | 2 +-
 src/multi_socket_client.h | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

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;