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

update failure on windows

This commit is contained in:
yihaoDeng 2024-09-24 16:37:02 +08:00
parent 2099a45547
commit 72a40fabfc
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1232,6 +1232,10 @@ int32_t cliBatchSend(SCliConn* pConn) {
if (pConn->broken) { if (pConn->broken) {
return 0; return 0;
} }
if (pConn->connnected != 1) {
return 0;
}
int32_t size = transQueueSize(&pConn->reqsToSend); int32_t size = transQueueSize(&pConn->reqsToSend);
int32_t totalLen = 0; int32_t totalLen = 0;
@ -1319,6 +1323,7 @@ int32_t cliBatchSend(SCliConn* pConn) {
int32_t cliSendReq(SCliConn* pConn, SCliReq* pCliMsg) { int32_t cliSendReq(SCliConn* pConn, SCliReq* pCliMsg) {
int32_t code = 0; int32_t code = 0;
(void)transQueuePush(&pConn->reqsToSend, &pCliMsg->q); (void)transQueuePush(&pConn->reqsToSend, &pCliMsg->q);
code = cliBatchSend(pConn); code = cliBatchSend(pConn);
return code; return code;
} }