fix: fix kill query crash issue

This commit is contained in:
dapan1121 2022-10-14 13:26:10 +08:00
parent 9a024590f5
commit d5cfbebd82
2 changed files with 6 additions and 2 deletions

View File

@ -222,7 +222,9 @@ void taos_kill_query(TAOS *taos) {
int64_t rid = *(int64_t *)taos; int64_t rid = *(int64_t *)taos;
STscObj *pTscObj = acquireTscObj(rid); STscObj *pTscObj = acquireTscObj(rid);
stopAllRequests(pTscObj->pRequests); if (pTscObj) {
stopAllRequests(pTscObj->pRequests);
}
releaseTscObj(rid); releaseTscObj(rid);
} }

View File

@ -998,7 +998,9 @@ void *shellCancelHandler(void *arg) {
shell.stop_query = true; shell.stop_query = true;
} else { } else {
#endif #endif
taos_kill_query(shell.conn); if (shell.conn) {
taos_kill_query(shell.conn);
}
#ifdef WEBSOCKET #ifdef WEBSOCKET
} }
#endif #endif