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

Fix issue with AE unlocking in beforeSleep

Browse Source
This commit is contained in:
John Sully 2022-03-29 12:17:13 -04:00
parent 8eaede1c61
commit 7fb077ff2f
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server.cpp
View File

@ -2926,12 +2926,14 @@ void beforeSleep(struct aeEventLoop *eventLoop) {
std::unique_lock<fastlock> ul(g_lockasyncfree); std::unique_lock<fastlock> ul(g_lockasyncfree);
if (listLength(g_pserver->clients_to_close)) { if (listLength(g_pserver->clients_to_close)) {
ul.unlock();
locker.disarm(); locker.disarm();
handleClientsWithPendingWrites(iel, aof_state); handleClientsWithPendingWrites(iel, aof_state);
locker.arm(); locker.arm();
fSentReplies = true; fSentReplies = true;
} else {
ul.unlock();
} }
ul.unlock();
if (!serverTL->gcEpoch.isReset()) if (!serverTL->gcEpoch.isReset())
g_pserver->garbageCollector.endEpoch(serverTL->gcEpoch, true /*fNoFree*/); g_pserver->garbageCollector.endEpoch(serverTL->gcEpoch, true /*fNoFree*/);