From f3921035f508cafaa3ae168ec6ccfca3c2b34d16 Mon Sep 17 00:00:00 2001
From: malavan <malavan@eqalpha.com>
Date: Thu, 26 Aug 2021 14:23:13 +0000
Subject: [PATCH] add correct thread assert to client::asyncCommand

Former-commit-id: a892fb4d551fb58d619bc80c333a6b3a9ed34215
---
 src/server.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/server.cpp b/src/server.cpp
index 94709b60f..6aae2a2bc 100644
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -4956,6 +4956,7 @@ bool client::asyncCommand(std::function<void *(const redisDbPersistentDataSnapsh
                             std::function<void(const redisDbPersistentDataSnapshot *, void *)> &&mainFn, 
                             std::function<void(const redisDbPersistentDataSnapshot *, void *)> &&postFn) 
 {
+    serverAssert(FCorrectThread(this));
     const redisDbPersistentDataSnapshot *snapshot = nullptr;
     if (!(this->flags & (CLIENT_MULTI | CLIENT_BLOCKED)))
         snapshot = this->db->createSnapshot(this->mvccCheckpoint, false /* fOptional */);
@@ -4963,7 +4964,6 @@ bool client::asyncCommand(std::function<void *(const redisDbPersistentDataSnapsh
         return false;
     }
     aeEventLoop *el = serverTL->el;
-    serverAssert(FCorrectThread(this));
     blockClient(this, BLOCKED_ASYNC);
     g_pserver->asyncworkqueue->AddWorkFunction([el, this, preFn, mainFn, postFn, snapshot] {
         void *preData = preFn(snapshot);