Fix issue where Active Replicas were commiting data to the wrong data…

…base under load
Snapchat · Sep 6, 2019 · 50a6a3c · 50a6a3c
1 parent f83a89f
commit 50a6a3c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/replication.cpp b/src/replication.cpp
@@ -3272,9 +3272,14 @@ void replicaReplayCommand(client *c)
     bool fExec = ccmdPrev != serverTL->commandsExecuted;
     cFake->lock.unlock();
     if (fExec)
+    {
         addReply(c, shared.ok);
+        selectDb(c, cFake->db->id);
+    }
     else
+    {
         addReplyError(c, "command did not execute");
+    }
     freeClient(cFake);
     serverTL->current_client = current_clientSave;