block: rewrite BRPOPLPUSH as RPOPLPUSH to propagate

This commit is contained in:
zhaozhao.zz
2018-08-14 20:58:58 +08:00
committed by antirez
parent fcd5ef1624
commit c03c591330
3 changed files with 5 additions and 1 deletions

View File

@ -596,6 +596,9 @@ void rpoplpushCommand(client *c) {
signalModifiedKey(c->db,touchedkey);
decrRefCount(touchedkey);
server.dirty++;
if (c->lastcmd->proc == brpoplpushCommand) {
rewriteClientCommandVector(c,3,shared.rpoplpush,c->argv[1],c->argv[2]);
}
}
}