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

handle tcp except

This commit is contained in:
yihaoDeng 2022-11-02 20:12:03 +08:00
parent a2abb3a411
commit ff16c4368f
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -718,8 +718,10 @@ static void cliSendCb(uv_write_t* req, int status) {
if (status == 0) { if (status == 0) {
tTrace("%s conn %p data already was written out", CONN_GET_INST_LABEL(pConn), pConn); tTrace("%s conn %p data already was written out", CONN_GET_INST_LABEL(pConn), pConn);
} else { } else {
tError("%s conn %p failed to write:%s", CONN_GET_INST_LABEL(pConn), pConn, uv_err_name(status)); if (!uv_is_closing((uv_handle_t*)&pConn->stream)) {
cliHandleExcept(pConn); tError("%s conn %p failed to write:%s", CONN_GET_INST_LABEL(pConn), pConn, uv_err_name(status));
cliHandleExcept(pConn);
}
return; return;
} }
if (cliHandleNoResp(pConn) == true) { if (cliHandleNoResp(pConn) == true) {

8
source/libs/transport/src/transSvr.c
View File

@ -363,9 +363,11 @@ void uvOnSendCb(uv_write_t* req, int status) {
} }
transUnrefSrvHandle(conn); transUnrefSrvHandle(conn);
} else { } else {
tError("conn %p failed to write data, %s", conn, uv_err_name(status)); if (!uv_is_closing((uv_handle_t*)(conn->pTcp))) {
conn->broken = true; tError("conn %p failed to write data, %s", conn, uv_err_name(status));
transUnrefSrvHandle(conn); conn->broken = true;
transUnrefSrvHandle(conn);
}
} }
} }
static void uvOnPipeWriteCb(uv_write_t* req, int status) { static void uvOnPipeWriteCb(uv_write_t* req, int status) {