Fix issue where Active Replicas were commiting data to the wrong database under load
Former-commit-id: 50a6a3ca389aef3d8f970faef5336f7053cf4cc5
This commit is contained in:
parent
2491f2a23d
commit
8fa118873c
@ -3272,9 +3272,14 @@ void replicaReplayCommand(client *c)
|
|||||||
bool fExec = ccmdPrev != serverTL->commandsExecuted;
|
bool fExec = ccmdPrev != serverTL->commandsExecuted;
|
||||||
cFake->lock.unlock();
|
cFake->lock.unlock();
|
||||||
if (fExec)
|
if (fExec)
|
||||||
|
{
|
||||||
addReply(c, shared.ok);
|
addReply(c, shared.ok);
|
||||||
|
selectDb(c, cFake->db->id);
|
||||||
|
}
|
||||||
else
|
else
|
||||||
|
{
|
||||||
addReplyError(c, "command did not execute");
|
addReplyError(c, "command did not execute");
|
||||||
|
}
|
||||||
freeClient(cFake);
|
freeClient(cFake);
|
||||||
serverTL->current_client = current_clientSave;
|
serverTL->current_client = current_clientSave;
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user