Cluster: invalidate current transaction on redirections.

This commit is contained in:
antirez 2014-03-03 17:11:51 +01:00
parent 35e8bc305d
commit c5edd91716

View File

@ -2027,6 +2027,7 @@ int processCommand(redisClient *c) {
addReplyError(c,"Multi keys request invalid in cluster"); addReplyError(c,"Multi keys request invalid in cluster");
return REDIS_OK; return REDIS_OK;
} else if (n != server.cluster->myself) { } else if (n != server.cluster->myself) {
flagTransaction(c);
addReplySds(c,sdscatprintf(sdsempty(), addReplySds(c,sdscatprintf(sdsempty(),
"-%s %d %s:%d\r\n", ask ? "ASK" : "MOVED", "-%s %d %s:%d\r\n", ask ? "ASK" : "MOVED",
hashslot,n->ip,n->port)); hashslot,n->ip,n->port));