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

fix: make CI happy

This commit is contained in:
yihaoDeng 2022-09-10 17:12:22 +08:00
parent 93dd2101c1
commit eac5d2c497
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -376,8 +376,10 @@ void cliHandleResp(SCliConn* conn) {
return; return;
} }
if (cliAppCb(conn, &transMsg, pMsg) != 0) { if (pMsg->type != Release) {
return; if (cliAppCb(conn, &transMsg, pMsg) != 0) {
return;
}
} }
destroyCmsg(pMsg); destroyCmsg(pMsg);
@ -435,8 +437,10 @@ void cliHandleExceptImpl(SCliConn* pConn, int32_t code) {
continue; continue;
} }
} }
if (cliAppCb(pConn, &transMsg, pMsg) != 0) { if (pMsg->type != Release) {
return; if (cliAppCb(pConn, &transMsg, pMsg) != 0) {
return;
}
} }
destroyCmsg(pMsg); destroyCmsg(pMsg);
tTrace("%s conn %p start to destroy, ref:%d", CONN_GET_INST_LABEL(pConn), pConn, T_REF_VAL_GET(pConn)); tTrace("%s conn %p start to destroy, ref:%d", CONN_GET_INST_LABEL(pConn), pConn, T_REF_VAL_GET(pConn));
@ -1457,7 +1461,7 @@ int transReleaseCliHandle(void* handle) {
tGDebug("send release request at thread:%08" PRId64 "", pThrd->pid); tGDebug("send release request at thread:%08" PRId64 "", pThrd->pid);
if (0 != transAsyncSend(pThrd->asyncPool, &cmsg->q)) { if (0 != transAsyncSend(pThrd->asyncPool, &cmsg->q)) {
taosMemoryFree(cmsg); destroyCmsg(cmsg);
return -1; return -1;
} }
return 0; return 0;