fix: fix invalid read-write

This commit is contained in:
yihaoDeng 2023-02-20 19:13:29 +08:00
parent 328cde55d5
commit 2bd38f453c
1 changed files with 1 additions and 1 deletions

View File

@ -1094,7 +1094,7 @@ static void cliSendBatchCb(uv_write_t* req, int status) {
} else {
tDebug("%s conn %p succ to send batch msg, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(conn), conn, p->wLen,
p->batchSize);
if (conn->broken != true) {
if (!uv_is_closing((uv_handle_t*)&conn->stream)) {
if (nxtBatch != NULL) {
conn->pBatch = nxtBatch;
cliSendBatch(conn);