diff --git a/src/networking.cpp b/src/networking.cpp index 8ce3387b8..1bfe0550f 100644 --- a/src/networking.cpp +++ b/src/networking.cpp @@ -1269,6 +1269,7 @@ void unlinkClient(client *c) { listDelNode(g_pserver->rgthreadvar[iel].clients_pending_asyncwrite,ln); } } + fFound = g_pserver->asyncworkqueue->removeClientAsyncWrites(c) || fFound; serverAssert(fFound); c->fPendingAsyncWrite = FALSE; }