xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix precheck

This commit is contained in:
yihaoDeng 2024-12-15 13:35:16 +08:00
parent 6d1de67389
commit 1e84358cb9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/transport/src/thttp.c
View File

@ -457,7 +457,7 @@ static FORCE_INLINE void clientRecvCb(uv_stream_t* handle, ssize_t nread, const
} }
} }
taosWUnLockLatch(&p->latch); taosWUnLockLatch(&p->latch);
taosReleaseRef(httpRecvRefMgt, cli->recvBufRid); TAOS_UNUSED(taosReleaseRef(httpRecvRefMgt, cli->recvBufRid));
} else { } else {
tWarn("http-report failed to acquire recv buf since %s", tstrerror(terrno)); tWarn("http-report failed to acquire recv buf since %s", tstrerror(terrno));
} }
@ -984,8 +984,8 @@ static void taosFreeHttpRecvHandle(int64_t rid) {
if (rid <= 0) { if (rid <= 0) {
return; return;
} }
taosReleaseRef(httpRecvRefMgt, rid); TAOS_UNUSED(taosReleaseRef(httpRecvRefMgt, rid));
taosRemoveRef(httpRecvRefMgt, rid); TAOS_UNUSED(taosRemoveRef(httpRecvRefMgt, rid));
} }
static int32_t taosGetHttpRecvById(int64_t rid, char** pRecv, int32_t* len) { static int32_t taosGetHttpRecvById(int64_t rid, char** pRecv, int32_t* len) {
int32_t code = 0; int32_t code = 0;
@ -1003,7 +1003,7 @@ static int32_t taosGetHttpRecvById(int64_t rid, char** pRecv, int32_t* len) {
code = TSDB_CODE_INVALID_PARA; code = TSDB_CODE_INVALID_PARA;
} }
taosWUnLockLatch(&p->latch); taosWUnLockLatch(&p->latch);
taosReleaseRef(httpRecvRefMgt, rid); TAOS_UNUSED(taosReleaseRef(httpRecvRefMgt, rid));
return code; return code;
} }