diff --git a/src/mnode/src/mnodeSdb.c b/src/mnode/src/mnodeSdb.c index 301dd41cbc5e08917b5adf27643822da574a5abe..efca748e9f05f7e783b8dbd49576c45222f3f739 100644 --- a/src/mnode/src/mnodeSdb.c +++ b/src/mnode/src/mnodeSdb.c @@ -988,7 +988,7 @@ int32_t sdbAllocWriteQueue() { } void sdbFreeWritequeue() { - taosCloseQset(tsSdbWriteQueue); + taosCloseQueue(tsSdbWriteQueue); taosFreeQall(tsSdbWriteQall); taosCloseQset(tsSdbWriteQset); tsSdbWriteQall = NULL; diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index be609c4ee888937db896d00b63c2f218f91c7692..01c753ec5b0b415eb015c92df2c5f45da832aac3 100644 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -747,7 +747,8 @@ static SRpcConn *rpcGetConnObj(SRpcInfo *pRpc, int sid, SRecvInfo *pRecv) { if (pConn) { if (pConn->linkUid != pHead->linkUid) { terrno = TSDB_CODE_RPC_MISMATCHED_LINK_ID; - tError("%s %p %p, linkUid:0x%x is not matched with received:0x%x", pRpc->label, pConn, (void*)pHead->ahandle, pConn->linkUid, pHead->linkUid); + tDebug("%s %p %p, linkUid:0x%x is not matched with received:0x%x", pRpc->label, pConn, (void *)pHead->ahandle, + pConn->linkUid, pHead->linkUid); pConn = NULL; } } diff --git a/src/util/src/tqueue.c b/src/util/src/tqueue.c index e2f061445571a41ad2e9ce9aa60070cf9a41fcee..8c6d6243eb4f677e9a5436b4449e07df011d2b52 100644 --- a/src/util/src/tqueue.c +++ b/src/util/src/tqueue.c @@ -241,7 +241,6 @@ void taosCloseQset(taos_qset param) { if (param == NULL) return; STaosQset *qset = (STaosQset *)param; -#if 0 // remove all the queues from qset pthread_mutex_lock(&qset->mutex); while (qset->head) { @@ -252,7 +251,6 @@ void taosCloseQset(taos_qset param) { queue->next = NULL; } pthread_mutex_unlock(&qset->mutex); -#endif pthread_mutex_destroy(&qset->mutex); tsem_destroy(&qset->sem);