add correct thread assert to client::asyncCommand

Former-commit-id: 8970f832348a80db6c183d25c4a5342a258a6ba9
This commit is contained in:
malavan 2021-08-26 13:58:12 +00:00
parent 1b074c3983
commit b92c0e8d5c

View File

@ -4963,6 +4963,7 @@ bool client::asyncCommand(std::function<void *(const redisDbPersistentDataSnapsh
return false; return false;
} }
aeEventLoop *el = serverTL->el; aeEventLoop *el = serverTL->el;
serverAssert(FCorrectThread(this));
blockClient(this, BLOCKED_ASYNC); blockClient(this, BLOCKED_ASYNC);
g_pserver->asyncworkqueue->AddWorkFunction([el, this, preFn, mainFn, postFn, snapshot] { g_pserver->asyncworkqueue->AddWorkFunction([el, this, preFn, mainFn, postFn, snapshot] {
void *preData = preFn(snapshot); void *preData = preFn(snapshot);