diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c index 26904ebbfb..9e61e8aaca 100644 --- a/source/libs/stream/src/streamState.c +++ b/source/libs/stream/src/streamState.c @@ -140,7 +140,7 @@ SStreamState* streamStateOpen(char* path, void* pTask, bool specPath, int32_t sz pState->pTdbState->pBackendCfWrapper = taosAcquireRef(streamBackendCfWrapperId, id); // already exist stream task for qInfo("already exist stream state for %s", pState->pTdbState->idstr); - taosAcquireRef(streamBackendId, pState->streamBackendRid); + // taosAcquireRef(streamBackendId, pState->streamBackendRid); } taosThreadMutexUnlock(&pMeta->backendMutex); diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index c6c412022a..e16c490fee 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -196,8 +196,6 @@ static bool uvHandleReq(SSvrConn* pConn) { tError("%s conn %p recv invalid packet, failed to decompress", transLabel(pTransInst), pConn); return false; } - tDebug("head version: %d 2", pHead->version); - pHead->code = htonl(pHead->code); pHead->msgLen = htonl(pHead->msgLen); diff --git a/source/util/src/tref.c b/source/util/src/tref.c index e70e12b37b..1bd3099b2d 100644 --- a/source/util/src/tref.c +++ b/source/util/src/tref.c @@ -181,7 +181,8 @@ int64_t taosAddRef(int32_t rsetId, void *p) { if (pSet->nodeList[hash]) pSet->nodeList[hash]->prev = pNode; pSet->nodeList[hash] = pNode; - uTrace("rsetId:%d p:%p rid:%" PRId64 " is added, count:%d", rsetId, p, rid, pSet->count); + uTrace("rsetId:%d p:%p rid:%" PRId64 " is added, count:%d, remain count:%d", rsetId, p, rid, pSet->count, + pNode->count); taosUnlockList(pSet->lockedBy + hash); @@ -235,7 +236,7 @@ void *taosAcquireRef(int32_t rsetId, int64_t rid) { if (pNode->removed == 0) { pNode->count++; p = pNode->p; - uTrace("rsetId:%d p:%p rid:%" PRId64 " is acquired", rsetId, pNode->p, rid); + uTrace("rsetId:%d p:%p rid:%" PRId64 " is acquired, remain count:%d", rsetId, pNode->p, rid, pNode->count); } else { terrno = TSDB_CODE_REF_NOT_EXIST; uTrace("rsetId:%d p:%p rid:%" PRId64 " is already removed, failed to acquire", rsetId, pNode->p, rid);