diff --git a/include/os/osSocket.h b/include/os/osSocket.h index 799a281269d066c64b4267e04bc5b1011d9a442a..2c7c579401c54fb74428dc90f972f817a010778c 100644 --- a/include/os/osSocket.h +++ b/include/os/osSocket.h @@ -169,8 +169,6 @@ void taosSetMaskSIGPIPE(); uint32_t taosInetAddr(const char *ipAddr); const char *taosInetNtoa(struct in_addr ipInt, char *dstStr, int32_t len); -uint64_t taosHton64(uint64_t val); -uint64_t taosNtoh64(uint64_t val); #ifdef __cplusplus } #endif diff --git a/source/libs/transport/inc/transComm.h b/source/libs/transport/inc/transComm.h index c3062b61202e0703e5d9babc3a51cea66f2f26ce..ac54749ae1d021624447debcbc2d9d0404f94e86 100644 --- a/source/libs/transport/inc/transComm.h +++ b/source/libs/transport/inc/transComm.h @@ -152,15 +152,14 @@ typedef struct { #pragma pack(push, 1) typedef struct { - char version : 4; // RPC version - char comp : 2; // compression algorithm, 0:no compression 1:lz4 - char noResp : 2; // noResp bits, 0: resp, 1: resp - char persist : 2; // persist handle,0: no persit, 1: persist handle - char release : 2; - char secured : 2; - char spi : 2; - char hasEpSet : 2; // contain epset or not, 0(default): no epset, 1: contain epset - uint64_t timestamp; + char version : 4; // RPC version + char comp : 2; // compression algorithm, 0:no compression 1:lz4 + char noResp : 2; // noResp bits, 0: resp, 1: resp + char persist : 2; // persist handle,0: no persit, 1: persist handle + char release : 2; + char secured : 2; + char spi : 2; + char hasEpSet : 2; // contain epset or not, 0(default): no epset, 1: contain epset char user[TSDB_UNI_LEN]; uint32_t magicNum; diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 7934fc29fca506b272133dd9da3aa26e33e8f104..55bfb57a827530569b56e90f53658392ca05460f 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -757,14 +757,6 @@ static void cliSendCb(uv_write_t* req, int status) { SCliConn* pConn = transReqQueueRemove(req); if (pConn == NULL) return; - SCliMsg* pMsg = !transQueueEmpty(&pConn->cliMsgs) ? transQueueGet(&pConn->cliMsgs, 0) : NULL; - if (pMsg != NULL) { - int64_t cost = taosGetTimestampUs() - pMsg->st; - if (cost > 1000) { - tWarn("%s conn %p send exception, cost:%dus", CONN_GET_INST_LABEL(pConn), pConn, (int)cost); - } - } - if (status == 0) { tTrace("%s conn %p data already was written out", CONN_GET_INST_LABEL(pConn), pConn); } else { @@ -813,7 +805,6 @@ void cliSend(SCliConn* pConn) { pHead->traceId = pMsg->info.traceId; pHead->magicNum = htonl(TRANS_MAGIC_NUM); } - pHead->timestamp = taosHton64(taosGetTimestampUs()); if (pHead->persist == 1) { CONN_SET_PERSIST_BY_APP(pConn); @@ -1576,7 +1567,6 @@ int transReleaseCliHandle(void* handle) { SCliMsg* cmsg = taosMemoryCalloc(1, sizeof(SCliMsg)); cmsg->msg = tmsg; - cmsg->st = taosGetTimestampUs(); cmsg->type = Release; cmsg->ctx = pCtx; diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index eab4e5edd7bc912c6f66b0340452502563a7f6d7..b7fe404a4ed8ffdd3cfd92f1fcb06b8caba05a9b 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -231,28 +231,14 @@ static bool uvHandleReq(SSvrConn* pConn) { } } STraceId* trace = &pHead->traceId; - - int64_t cost = taosGetTimestampUs() - taosNtoh64(pHead->timestamp); - static int64_t EXCEPTION_LIMIT_US = 100 * 1000; if (pConn->status == ConnNormal && pHead->noResp == 0) { transRefSrvHandle(pConn); - if (cost > EXCEPTION_LIMIT_US) { - tGWarn("%s conn %p %s received from %s, local info:%s, len:%d, cost:%dus, recv exception", transLabel(pTransInst), - pConn, TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen, (int)cost); - } else { - tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, cost:%dus", transLabel(pTransInst), pConn, - TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen, (int)cost); - } + + tGDebug("%s conn %p %s received from %s, local info:%s, len:%d", transLabel(pTransInst), pConn, + TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen); } else { - if (cost > EXCEPTION_LIMIT_US) { - tGWarn("%s conn %p %s received from %s, local info:%s, len:%d, resp:%d, code:%d, cost:%dus, recv exception", - transLabel(pTransInst), pConn, TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen, pHead->noResp, - transMsg.code, (int)cost); - } else { - tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, resp:%d, code:%d, cost:%dus", - transLabel(pTransInst), pConn, TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen, pHead->noResp, - transMsg.code, (int)cost); - } + tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, resp:%d, code:%d", transLabel(pTransInst), pConn, + TMSG_INFO(transMsg.msgType), pConn->dst, pConn->src, msgLen, pHead->noResp, transMsg.code); } // pHead->noResp = 1, diff --git a/source/os/src/osSocket.c b/source/os/src/osSocket.c index 5a97343e87aec88dafcfa29d70755f6de410ad1a..fd5bde90ba21b13f2bb3d2cbbeb7b9778b8929f4 100644 --- a/source/os/src/osSocket.c +++ b/source/os/src/osSocket.c @@ -1101,33 +1101,5 @@ void taosWinSocketInit() { } } #else - -#endif -} - -uint64_t taosHton64(uint64_t val) { -#if defined(WINDOWS) || defined(DARWIN) - return ((val & 0x00000000000000ff) << 7 * 8) | ((val & 0x000000000000ff00) << 5 * 8) | - ((val & 0x0000000000ff0000) << 3 * 8) | ((val & 0x00000000ff000000) << 1 * 8) | - ((val & 0x000000ff00000000) >> 1 * 8) | ((val & 0x0000ff0000000000) >> 3 * 8) | - ((val & 0x00ff000000000000) >> 5 * 8) | ((val & 0xff00000000000000) >> 7 * 8); -#else - if (__BYTE_ORDER == __LITTLE_ENDIAN) { - return (((uint64_t)htonl((int)((val << 32) >> 32))) << 32) | (unsigned int)htonl((int)(val >> 32)); - } else if (__BYTE_ORDER == __BIG_ENDIAN) { - return val; - } -#endif -} - -uint64_t taosNtoh64(uint64_t val) { -#if defined(WINDOWS) || defined(DARWIN) - return taosHton64(val); -#else - if (__BYTE_ORDER == __LITTLE_ENDIAN) { - return (((uint64_t)htonl((int)((val << 32) >> 32))) << 32) | (unsigned int)htonl((int)(val >> 32)); - } else if (__BYTE_ORDER == __BIG_ENDIAN) { - return val; - } #endif }