start timer for particular msg

source/client/src/clientEnv.c

@@ -111,7 +111,9 @@ static bool clientRpcRfp(int32_t code, tmsg_t msgType) {
 
 // start timer for particular msgType
 static bool clientRpcTfp(int32_t code, tmsg_t msgType) {
-  //
+  if (msgType == TDMT_VND_SUBMIT || msgType == TDMT_VND_CREATE_TABLE) {
+    return true;
+  }
   return false;
 }
 

source/libs/transport/inc/transComm.h

@@ -94,10 +94,10 @@ typedef void* queue[2];
 /* Return the structure holding the given element. */
 #define QUEUE_DATA(e, type, field) ((type*)((void*)((char*)(e)-offsetof(type, field))))
 
-#define TRANS_RETRY_COUNT_LIMIT 100  // retry count limit
-#define TRANS_RETRY_INTERVAL    15   // retry interval (ms)
-#define TRANS_CONN_TIMEOUT      3    // connect timeout (s)
-#define TRANS_READ_TIMEOUT      200  // read timeout  (ms)
+#define TRANS_RETRY_COUNT_LIMIT 100   // retry count limit
+#define TRANS_RETRY_INTERVAL    15    // retry interval (ms)
+#define TRANS_CONN_TIMEOUT      3     // connect timeout (s)
+#define TRANS_READ_TIMEOUT      3000  // read timeout  (ms)
 
 typedef SRpcMsg      STransMsg;
 typedef SRpcCtx      STransCtx;