caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-22 16:18:28 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Cluster: ASKING command fixed, state was not retained.

Browse Source
This commit is contained in:
antirez 2013-02-20 17:07:52 +01:00
parent b8d8b9ec41
commit 9ec1b709f5
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/networking.c
View File

@ -816,12 +816,16 @@ void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) {
/* resetClient prepare the client to process the next command */ /* resetClient prepare the client to process the next command */
void resetClient(redisClient *c) { void resetClient(redisClient *c) {
redisCommandProc *prevcmd = c->cmd ? c->cmd->proc : NULL;
freeClientArgv(c); freeClientArgv(c);
c->reqtype = 0; c->reqtype = 0;
c->multibulklen = 0; c->multibulklen = 0;
c->bulklen = -1; c->bulklen = -1;
/* We clear the ASKING flag as well if we are not inside a MULTI. */ /* We clear the ASKING flag as well if we are not inside a MULTI, and
if (!(c->flags & REDIS_MULTI)) c->flags &= (~REDIS_ASKING); * if what we just executed is not the ASKING command itself. */
if (!(c->flags & REDIS_MULTI) && prevcmd != askingCommand)
c->flags &= (~REDIS_ASKING);
} }
int processInlineBuffer(redisClient *c) { int processInlineBuffer(redisClient *c) {