atomic type error

dafdb50f · tanxuefeng · 5d68b273 · dafdb50f
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

src/rpc/src/trpc.c src/rpc/src/trpc.c +2 -2

未找到文件。
--- 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_32(&pConn->tranId, 1);
-  if (pHeader->tranId == 0) pHeader->tranId = atomic_add_fetch_32(&pConn->tranId, 1);
+  pHeader->tranId = atomic_add_fetch_16(&pConn->tranId, 1);
+  if (pHeader->tranId == 0) pHeader->tranId = atomic_add_fetch_16(&pConn->tranId, 1);

  pHeader->sourceId = pConn->ownId;
  pHeader->destId = pConn->peerId;