From 0f37ae44e6ad5209f812149b212b8400d3367280 Mon Sep 17 00:00:00 2001 From: John Sully Date: Tue, 21 Sep 2021 21:59:19 +0000 Subject: [PATCH] Make tests deterministic and fix an issue found Former-commit-id: fd00f39f3ca11053a5c99ab52daa1f9a051b7058 --- src/networking.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/networking.cpp b/src/networking.cpp index 077c1c468..7a28697d3 100644 --- a/src/networking.cpp +++ b/src/networking.cpp @@ -2576,6 +2576,8 @@ bool FAsyncCommand(parsed_command &cmd) if (serverTL->in_eval || serverTL->in_exec) return false; auto parsedcmd = lookupCommand(szFromObj(cmd.argv[0])); + if (parsedcmd == nullptr) + return false; static const long long expectedFlags = CMD_ASYNC_OK | CMD_READONLY; return (parsedcmd->flags & expectedFlags) == expectedFlags; } @@ -2710,7 +2712,7 @@ void readQueryFromClient(connection *conn) { if (cserver.cthreads > 1) { parseClientCommandBuffer(c); - if (g_pserver->enable_async_commands && aeLockContention()) + if (g_pserver->enable_async_commands && (aeLockContention() || g_fTestMode)) processInputBuffer(c, false, CMD_CALL_SLOWLOG | CMD_CALL_STATS | CMD_CALL_ASYNC); if (!c->vecqueuedcmd.empty()) serverTL->vecclientsProcess.push_back(c);