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

Fix ci errors.

This commit is contained in:
xiao-77 2024-11-29 10:37:05 +08:00
parent 7e20b31d04
commit bf6361ac93
3 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -652,6 +652,7 @@ void cliHandleResp(SCliConn* conn) {
} }
if ((code = transDecompressMsg((char**)&pHead, &msgLen)) < 0) { if ((code = transDecompressMsg((char**)&pHead, &msgLen)) < 0) {
taosMemoryFree(pHead);
tDebug("%s conn %p recv invalid packet, failed to decompress", CONN_GET_INST_LABEL(conn), conn); tDebug("%s conn %p recv invalid packet, failed to decompress", CONN_GET_INST_LABEL(conn), conn);
// TODO: notify cb // TODO: notify cb
return; return;
@ -664,8 +665,10 @@ void cliHandleResp(SCliConn* conn) {
if (cliHandleState_mayHandleReleaseResp(conn, pHead)) { if (cliHandleState_mayHandleReleaseResp(conn, pHead)) {
if (cliMayRecycleConn(conn)) { if (cliMayRecycleConn(conn)) {
taosMemoryFree(pHead);
return; return;
} }
taosMemoryFree(pHead);
return; return;
} }
code = cliGetReqBySeq(conn, seq, pHead->msgType, &pReq); code = cliGetReqBySeq(conn, seq, pHead->msgType, &pReq);
@ -674,6 +677,7 @@ void cliHandleResp(SCliConn* conn) {
if (code == 0) { if (code == 0) {
code = cliBuildRespFromCont(NULL, &resp, pHead); code = cliBuildRespFromCont(NULL, &resp, pHead);
code = cliNotifyCb(conn, NULL, &resp); code = cliNotifyCb(conn, NULL, &resp);
taosMemoryFree(pHead);
return; return;
} }
if (code != 0) { if (code != 0) {
@ -701,7 +705,7 @@ void cliHandleResp(SCliConn* conn) {
tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, seq:%" PRId64 ", sid:%" PRId64 ", code:%s", tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, seq:%" PRId64 ", sid:%" PRId64 ", code:%s",
CONN_GET_INST_LABEL(conn), conn, TMSG_INFO(resp.msgType), conn->dst, conn->src, pHead->msgLen, seq, qId, CONN_GET_INST_LABEL(conn), conn, TMSG_INFO(resp.msgType), conn->dst, conn->src, pHead->msgLen, seq, qId,
tstrerror(pHead->code)); tstrerror(pHead->code));
taosMemoryFree(pHead);
code = cliNotifyCb(conn, pReq, &resp); code = cliNotifyCb(conn, pReq, &resp);
if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) { if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) {
tGWarn("%s msg need retry", CONN_GET_INST_LABEL(conn)); tGWarn("%s msg need retry", CONN_GET_INST_LABEL(conn));

2
tests/script/tsim/valgrind/checkError1.sim
View File

@ -120,7 +120,7 @@ if $rows != 3 then
endi endi
sql show variables; sql show variables;
if $rows != 9 then if $rows != 94 then
return -1 return -1
endi endi

3
tests/system-test/0-others/test_hot_refresh_configurations.py
View File

@ -224,7 +224,8 @@ class TDTestCase:
for i in range(len(values)): for i in range(len(values)):
v = values[i] v = values[i]
dnode = random.choice(p_list) dnode = random.choice(p_list)
tdSql.execute(f'alter {dnode} "{name} {v}";') tdSql.execute(f'alter all dnodes "{name} {v}";')
sleep(0.5)
value = self.svr_get_param_value(name) value = self.svr_get_param_value(name)
tdLog.debug(f"value: {value}") tdLog.debug(f"value: {value}")
if check_values: if check_values: