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

fix compile error

This commit is contained in:
yihaoDeng 2024-09-20 15:24:00 +08:00
parent 6752f7690c
commit be412c3ca7
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -623,8 +623,6 @@ void cliHandleResp(SCliConn* conn) {
cliConnCheckTimoutMsg(conn); cliConnCheckTimoutMsg(conn);
cliConnMayUpdateTimer(conn, READ_TIMEOUT); cliConnMayUpdateTimer(conn, READ_TIMEOUT);
(void)uv_read_start((uv_stream_t*)conn->stream, cliAllocRecvBufferCb, cliRecvCb);
} }
void cliConnTimeout(uv_timer_t* handle) { void cliConnTimeout(uv_timer_t* handle) {
@ -813,7 +811,6 @@ static void addConnToPool(void* pool, SCliConn* conn) {
if (conn->status == ConnInPool) { if (conn->status == ConnInPool) {
return; return;
} }
(void)uv_read_stop(conn->stream);
SCliThrd* thrd = conn->hostThrd; SCliThrd* thrd = conn->hostThrd;
cliResetConnTimer(conn); cliResetConnTimer(conn);
@ -1182,7 +1179,7 @@ static void cliBatchSendCb(uv_write_t* req, int status) {
cliConnMayUpdateTimer(conn, READ_TIMEOUT); cliConnMayUpdateTimer(conn, READ_TIMEOUT);
(void)uv_read_start((uv_stream_t*)conn->stream, cliAllocRecvBufferCb, cliRecvCb); uv_read_start((uv_stream_t*)conn->stream, cliAllocRecvBufferCb, cliRecvCb);
if (!cliMayRecycleConn(conn)) { if (!cliMayRecycleConn(conn)) {
(void)cliBatchSend(conn); (void)cliBatchSend(conn);