feature/qnode

This commit is contained in:
dapan1121 2022-03-25 16:07:07 +08:00
parent f9644f2611
commit aa518a9213
1 changed files with 1 additions and 1 deletions

View File

@ -292,7 +292,7 @@ void uvOnSendCb(uv_write_t* req, int status) {
} }
transQueuePop(&conn->srvMsgs); transQueuePop(&conn->srvMsgs);
tfree(msg); tfree(msg);
msg = (SSrvMsg*)transQueueGet(&conn->srvMsgs, 0); msg = (SSrvMsg*)transQueuePop(&conn->srvMsgs);
if (msg != NULL) { if (msg != NULL) {
uvStartSendRespInternal(msg); uvStartSendRespInternal(msg);
} }