From f188e8a34687d632205b74d15fe513bd342defe6 Mon Sep 17 00:00:00 2001
From: slguan <slguan@taosdata.com>
Date: Mon, 23 Mar 2020 21:27:38 +0800
Subject: [PATCH] [TD-46]

---
 src/rpc/src/trpc.c | 4 ++--
 src/rpc/src/tudp.c | 3 +--
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/rpc/src/trpc.c b/src/rpc/src/trpc.c
index 87506861b1..9e0b5dab0f 100755
--- a/src/rpc/src/trpc.c
+++ b/src/rpc/src/trpc.c
@@ -239,8 +239,8 @@ char *taosBuildReqHeader(void *param, char type, char *msg) {
   pHeader->spi = 0;
   pHeader->tcp = 0;
   pHeader->encrypt = 0;
-  pHeader->tranId = atomic_add_fetch_16(&pConn->tranId, 1);
-  if (pHeader->tranId == 0) pHeader->tranId = atomic_add_fetch_16(&pConn->tranId, 1);
+  pHeader->tranId = atomic_add_fetch_32(&pConn->tranId, 1);
+  if (pHeader->tranId == 0) pHeader->tranId = atomic_add_fetch_32(&pConn->tranId, 1);
 
   pHeader->sourceId = pConn->ownId;
   pHeader->destId = pConn->peerId;
diff --git a/src/rpc/src/tudp.c b/src/rpc/src/tudp.c
index c2a6ad2fb8..a782f5eb10 100644
--- a/src/rpc/src/tudp.c
+++ b/src/rpc/src/tudp.c
@@ -481,8 +481,7 @@ void *taosInitUdpConnection(char *ip, uint16_t port, char *label, int threads, v
   sprintf(udplabel, "%s.b", label);
   pSet->tmrCtrl = taosTmrInit(RPC_MAX_UDP_CONNS * threads, 5, 5000, udplabel);
   if (pSet->tmrCtrl == NULL) {
-    tError("%s failed to initialize tmrCtrl", label);
-    taosCleanUpUdpConnection(pSet);
+    tError("%s failed to initialize tmrCtrl") taosCleanUpUdpConnection(pSet);
     return NULL;
   }
   //  }
-- 
GitLab