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

fix invalid read

This commit is contained in:
yihaoDeng 2024-09-20 15:37:15 +08:00
parent be412c3ca7
commit 919de857d2
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -105,6 +105,7 @@ typedef struct SCliConn {
uv_buf_t* buf; uv_buf_t* buf;
int32_t bufSize; int32_t bufSize;
int32_t readerStart;
queue wq; // uv_write_t queue queue wq; // uv_write_t queue
} SCliConn; } SCliConn;
@ -1178,8 +1179,12 @@ static void cliBatchSendCb(uv_write_t* req, int status) {
} }
cliConnMayUpdateTimer(conn, READ_TIMEOUT); cliConnMayUpdateTimer(conn, READ_TIMEOUT);
// if (!uv_is_readable(conn->stream)) {
uv_read_start((uv_stream_t*)conn->stream, cliAllocRecvBufferCb, cliRecvCb); if (conn->readerStart == 0) {
uv_read_start((uv_stream_t*)conn->stream, cliAllocRecvBufferCb, cliRecvCb);
conn->readerStart = 1;
}
//}
if (!cliMayRecycleConn(conn)) { if (!cliMayRecycleConn(conn)) {
(void)cliBatchSend(conn); (void)cliBatchSend(conn);