remove redundant check for evalCommand (#8565)
This commit is contained in:
parent
1ccfd6a1f7
commit
53774e69fa
@ -5824,18 +5824,14 @@ clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, in
|
|||||||
* cluster is down. */
|
* cluster is down. */
|
||||||
if (error_code) *error_code = CLUSTER_REDIR_DOWN_STATE;
|
if (error_code) *error_code = CLUSTER_REDIR_DOWN_STATE;
|
||||||
return NULL;
|
return NULL;
|
||||||
} else if ((cmd->flags & CMD_WRITE) && !(cmd->proc == evalCommand)
|
} else if (cmd->flags & CMD_WRITE) {
|
||||||
&& !(cmd->proc == evalShaCommand))
|
/* The cluster is configured to allow read only commands */
|
||||||
{
|
|
||||||
/* The cluster is configured to allow read only commands
|
|
||||||
* but this command is neither readonly, nor EVAL or
|
|
||||||
* EVALSHA. */
|
|
||||||
if (error_code) *error_code = CLUSTER_REDIR_DOWN_RO_STATE;
|
if (error_code) *error_code = CLUSTER_REDIR_DOWN_RO_STATE;
|
||||||
return NULL;
|
return NULL;
|
||||||
} else {
|
} else {
|
||||||
/* Fall through and allow the command to be executed:
|
/* Fall through and allow the command to be executed:
|
||||||
* this happens when server.cluster_allow_reads_when_down is
|
* this happens when server.cluster_allow_reads_when_down is
|
||||||
* true and the command is a readonly command or EVAL / EVALSHA. */
|
* true and the command is not a write command */
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -5876,7 +5872,7 @@ clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, in
|
|||||||
int is_write_command = (c->cmd->flags & CMD_WRITE) ||
|
int is_write_command = (c->cmd->flags & CMD_WRITE) ||
|
||||||
(c->cmd->proc == execCommand && (c->mstate.cmd_flags & CMD_WRITE));
|
(c->cmd->proc == execCommand && (c->mstate.cmd_flags & CMD_WRITE));
|
||||||
if (c->flags & CLIENT_READONLY &&
|
if (c->flags & CLIENT_READONLY &&
|
||||||
(!is_write_command || cmd->proc == evalCommand || cmd->proc == evalShaCommand) &&
|
!is_write_command &&
|
||||||
nodeIsSlave(myself) &&
|
nodeIsSlave(myself) &&
|
||||||
myself->slaveof == n)
|
myself->slaveof == n)
|
||||||
{
|
{
|
||||||
|
Loading…
x
Reference in New Issue
Block a user