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

Make tests deterministic and fix an issue found

Browse Source 
Former-commit-id: fd00f39f3ca11053a5c99ab52daa1f9a051b7058
This commit is contained in:
John Sully 2021-09-21 21:59:19 +00:00
parent 9c48bfbca1
commit 0f37ae44e6
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/networking.cpp
View File

@ -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);