gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update redis-cli.c

Browse Source
This commit is contained in:
Benjamin Sergeant 2020-05-01 20:57:51 -07:00 committed by GitHub
parent 365316aa59
commit 93021da221
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/redis-cli.c
View File

@ -3416,6 +3416,7 @@ static redisReply *clusterManagerMigrateKeysInReply(clusterManagerNode *source,
size_t *argv_len = NULL; size_t *argv_len = NULL;
int c = (replace ? 8 : 7); int c = (replace ? 8 : 7);
if (config.auth) c += 2; if (config.auth) c += 2;
if (config.user) c += 1;
size_t argc = c + reply->elements; size_t argc = c + reply->elements;
size_t i, offset = 6; // Keys Offset size_t i, offset = 6; // Keys Offset
argv = zcalloc(argc * sizeof(char *)); argv = zcalloc(argc * sizeof(char *));
@ -3442,6 +3443,17 @@ static redisReply *clusterManagerMigrateKeysInReply(clusterManagerNode *source,
offset++; offset++;
} }
if (config.auth) { if (config.auth) {
if (config.user) {
argv[offset] = "AUTH2";
argv_len[offset] = 5;
offset++;
argv[offset] = config.user;
argv_len[offset] = strlen(config.user);
offset++;
argv[offset] = config.auth;
argv_len[offset] = strlen(config.auth);
offset++;
} else {
argv[offset] = "AUTH"; argv[offset] = "AUTH";
argv_len[offset] = 4; argv_len[offset] = 4;
offset++; offset++;
@ -3449,6 +3461,7 @@ static redisReply *clusterManagerMigrateKeysInReply(clusterManagerNode *source,
argv_len[offset] = strlen(config.auth); argv_len[offset] = strlen(config.auth);
offset++; offset++;
} }
}
argv[offset] = "KEYS"; argv[offset] = "KEYS";
argv_len[offset] = 4; argv_len[offset] = 4;
offset++; offset++;