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

handle taosd quit

This commit is contained in:
yihaoDeng 2023-08-29 10:25:44 +08:00
parent ff6de8ebe2
commit 023cf096b3
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -290,6 +290,13 @@ static bool uvHandleReq(SSvrConn* pConn) {
void uvOnRecvCb(uv_stream_t* cli, ssize_t nread, const uv_buf_t* buf) { void uvOnRecvCb(uv_stream_t* cli, ssize_t nread, const uv_buf_t* buf) {
SSvrConn* conn = cli->data; SSvrConn* conn = cli->data;
SWorkThrd* pThrd = conn->hostThrd;
if (true == pThrd->quit) {
tInfo("work thread received quit msg, destroy conn");
destroyConn(conn, true);
return;
}
STrans* pTransInst = conn->pTransInst; STrans* pTransInst = conn->pTransInst;
SConnBuffer* pBuf = &conn->readBuf; SConnBuffer* pBuf = &conn->readBuf;