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

Fix multithread test failures

Browse Source 
Former-commit-id: 7c39a9b0e193f5c0b327ff21cd49210037142642
This commit is contained in:
John Sully 2020-10-23 15:57:39 +00:00
parent dcd6d809aa
commit c88a19bc5e
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/networking.cpp
View File

@ -1915,10 +1915,8 @@ 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;
if (c->bufpos || listLength(c->reply) || (c->flags & CLIENT_PENDING_WRITE)) { clientInstallWriteHandler(c);
clientInstallWriteHandler(c); handleClientsWithPendingWrites(c->iel, g_pserver->aof_state);
handleClientsWithPendingWrites(c->iel, g_pserver->aof_state);
}
}, false); }, false);
if (!fResult) if (!fResult)