Function sentinelConfigSetCommand

app/redis-6.2.6/src/sentinel.c:3156–3204

SENTINEL CONFIG SET */

/* SENTINEL CONFIG SET <option> */
void sentinelConfigSetCommand(client *c) {
    robj *o = c->argv[3];
    robj *val = c->argv[4];
    long long numval;
    int drop_conns = 0;

    if (!strcasecmp(o->ptr, "resolve-hostnames")) {
        if ((numval = yesnotoi(val->ptr)) == -1) goto badfmt;
        sentinel.resolve_hostnames = numval;
    } else if (!strcasecmp(o->ptr, "announce-hostnames")) {
        if ((numval = yesnotoi(val->ptr)) == -1) goto badfmt;
        sentinel.announce_hostnames = numval;
    } else if (!strcasecmp(o->ptr, "announce-ip")) {
        if (sentinel.announce_ip) sdsfree(sentinel.announce_ip);
        sentinel.announce_ip = sdsnew(val->ptr);
    } else if (!strcasecmp(o->ptr, "announce-port")) {
        if (getLongLongFromObject(val, &numval) == C_ERR ||
            numval < 0 || numval > 65535)
            goto badfmt;
        sentinel.announce_port = numval;
    } else if (!strcasecmp(o->ptr, "sentinel-user")) {
        sdsfree(sentinel.sentinel_auth_user);
        sentinel.sentinel_auth_user = sdslen(val->ptr) == 0 ?
            NULL : sdsdup(val->ptr);
        drop_conns = 1;
    } else if (!strcasecmp(o->ptr, "sentinel-pass")) {
        sdsfree(sentinel.sentinel_auth_pass);
        sentinel.sentinel_auth_pass = sdslen(val->ptr) == 0 ?
            NULL : sdsdup(val->ptr);
        drop_conns = 1;
    } else {
        addReplyErrorFormat(c, "Invalid argument '%s' to SENTINEL CONFIG SET",
                            (char *) o->ptr);
        return;
    }

    sentinelFlushConfig();
    addReply(c, shared.ok);

    /* Drop Sentinel connections to initiate a reconnect if needed. */
    if (drop_conns)
        sentinelDropConnections();

    return;

badfmt:
    addReplyErrorFormat(c, "Invalid value '%s' to SENTINEL CONFIG SET '%s'",
                        (char *) val->ptr, (char *) o->ptr);
}

/* SENTINEL CONFIG GET <option> */
void sentinelConfigGetCommand(client *c) {