gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

run when necessary

Browse Source 
Former-commit-id: d724e7226c690fdce0e6ee6cbf8afdb9481f51c5
This commit is contained in:
John Sully 2020-10-16 07:00:03 +00:00
parent b5074e9b1e
commit b0d9d3bc09
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/networking.cpp
View File

@ -1915,8 +1915,10 @@ void ProcessPendingAsyncWrites()
if (c->fPendingAsyncWriteHandler.compare_exchange_strong(expected, true)) { if (c->fPendingAsyncWriteHandler.compare_exchange_strong(expected, true)) {
bool fResult = c->postFunction([](client *c) { bool fResult = c->postFunction([](client *c) {
c->fPendingAsyncWriteHandler = false; c->fPendingAsyncWriteHandler = false;
clientInstallWriteHandler(c); if (c->bufpos || listLength(c->reply) || (c->flags & CLIENT_PENDING_WRITE)) {
handleClientsWithPendingWrites(c->iel, g_pserver->aof_state); clientInstallWriteHandler(c);
handleClientsWithPendingWrites(c->iel, g_pserver->aof_state);
}
}, false); }, false);
if (!fResult) if (!fResult)