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

enh: remove some error log

This commit is contained in:
Hongze Cheng 2024-09-29 09:00:32 +08:00
parent 839f85d857
commit de4b4387d6
2 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -127,13 +127,9 @@ void rpcClose(void* arg) {
if (arg == NULL) { if (arg == NULL) {
return; return;
} }
if (transRemoveExHandle(transGetInstMgt(), (int64_t)arg) != 0) { TAOS_UNUSED(transRemoveExHandle(transGetInstMgt(), (int64_t)arg));
tError("failed to remove rpc handle"); TAOS_UNUSED(transReleaseExHandle(transGetInstMgt(), (int64_t)arg));
}
if (transReleaseExHandle(transGetInstMgt(), (int64_t)arg) != 0) {
tError("failed to release rpc handle");
}
tInfo("end to close rpc"); tInfo("end to close rpc");
return; return;
} }

11
source/libs/transport/src/transCli.c
View File

@ -3401,16 +3401,11 @@ int32_t transFreeConnById(void* shandle, int64_t transpointId) {
} }
_exception: _exception:
transReleaseExHandle(transGetInstMgt(), (int64_t)shandle); TAOS_UNUSED(transReleaseExHandle(transGetInstMgt(), (int64_t)shandle));
if (code != 0) { if (code != 0) {
if (transpointId != 0) { if (transpointId != 0) {
if (transReleaseExHandle(transGetRefMgt(), transpointId) != 0) { TAOS_UNUSED(transReleaseExHandle(transGetRefMgt(), transpointId));
tError("failed to release refId %" PRId64 "", transpointId); TAOS_UNUSED(transRemoveExHandle(transGetRefMgt(), transpointId));
}
if (transRemoveExHandle(transGetRefMgt(), transpointId) != 0) {
tError("failed to remove refId %" PRId64 "", transpointId);
}
} }
taosMemoryFree(pCli); taosMemoryFree(pCli);
} }