diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index e29277fb7f..d0a7971794 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -398,7 +398,7 @@ int32_t dmInitClient(SDnode *pDnode) { rpcInit.notWaitAvaliableConn = 0; (void)taosVersionStrToInt(version, &(rpcInit.compatibilityVer)); - rpcInit.startReadTimer = 0; + rpcInit.startReadTimer = 1; pTrans->clientRpc = rpcOpen(&rpcInit); if (pTrans->clientRpc == NULL) { dError("failed to init dnode rpc client since:%s", tstrerror(terrno)); @@ -441,7 +441,7 @@ int32_t dmInitStatusClient(SDnode *pDnode) { rpcInit.supportBatch = 1; rpcInit.batchSize = 8 * 1024; rpcInit.timeToGetConn = tsTimeToGetAvailableConn; - rpcInit.startReadTimer = 0; + rpcInit.startReadTimer = 1; (void)taosVersionStrToInt(version, &(rpcInit.compatibilityVer)); pTrans->statusRpc = rpcOpen(&rpcInit); @@ -488,7 +488,7 @@ int32_t dmInitSyncClient(SDnode *pDnode) { rpcInit.batchSize = 8 * 1024; rpcInit.timeToGetConn = tsTimeToGetAvailableConn; (void)taosVersionStrToInt(version, &(rpcInit.compatibilityVer)); - rpcInit.startReadTimer = 0; + rpcInit.startReadTimer = 1; pTrans->syncRpc = rpcOpen(&rpcInit); if (pTrans->syncRpc == NULL) { dError("failed to init dnode rpc sync client since %s", tstrerror(terrno)); diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index f02d5206db..e0411e2891 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -641,7 +641,7 @@ bool filterToRmTimoutReq(void* key, void* arg) { if (pReq->msg.info.qId == 0 && !REQUEST_NO_RESP(&pReq->msg) && pReq->ctx) { int64_t elapse = ((taosGetTimestampUs() - pReq->st) / 1000); if (elapse > READ_TIMEOUT) { - return true; + return false; } else { return false; }