diff --git a/src/module.cpp b/src/module.cpp index e957e8fc2..bb0b23621 100644 --- a/src/module.cpp +++ b/src/module.cpp @@ -4291,7 +4291,14 @@ RedisModuleCallReply *RM_Call(RedisModuleCtx *ctx, const char *cmdname, const ch if (!(flags & REDISMODULE_ARGV_NO_REPLICAS)) call_flags |= CMD_CALL_PROPAGATE_REPL; } + + { + aeAcquireLock(); + std::unique_lock ul(c->lock); call(c,call_flags); + aeReleaseLock(); + } + g_pserver->replication_allowed = prev_replication_allowed; serverAssert((c->flags & CLIENT_BLOCKED) == 0);