Function loadSentinelConfigFromQueue

src/sentinel.cpp:1847–1904

This function is used for loading the sentinel configuration from * pre_monitor_cfg, monitor_cfg and post_monitor_cfg list */

/* This function is used for loading the sentinel configuration from
 * pre_monitor_cfg, monitor_cfg and post_monitor_cfg list */
void loadSentinelConfigFromQueue(void) {
    const char *err = NULL;
    listIter li;
    listNode *ln;
    int linenum = 0;
    sds line = NULL;

    /* if there is no sentinel_config entry, we can return immediately */
    if (g_pserver->sentinel_config == NULL) return;

    /* loading from pre monitor config queue first to avoid dependency issues */
    listRewind(g_pserver->sentinel_config->pre_monitor_cfg,&li);
    while((ln = listNext(&li))) {
        struct sentinelLoadQueueEntry *entry = (sentinelLoadQueueEntry*)ln->value;
        err = sentinelHandleConfiguration(entry->argv,entry->argc);
        if (err) {
            linenum = entry->linenum;
            line = entry->line;
            goto loaderr;
        }
    }

    /* loading from monitor config queue */
    listRewind(g_pserver->sentinel_config->monitor_cfg,&li);
    while((ln = listNext(&li))) {
        struct sentinelLoadQueueEntry *entry = (sentinelLoadQueueEntry*)ln->value;
        err = sentinelHandleConfiguration(entry->argv,entry->argc);
        if (err) {
            linenum = entry->linenum;
            line = entry->line;
            goto loaderr;
        }
    }

    /* loading from the post monitor config queue */
    listRewind(g_pserver->sentinel_config->post_monitor_cfg,&li);
    while((ln = listNext(&li))) {
        struct sentinelLoadQueueEntry *entry = (sentinelLoadQueueEntry*)ln->value;
        err = sentinelHandleConfiguration(entry->argv,entry->argc);
        if (err) {
            linenum = entry->linenum;
            line = entry->line;
            goto loaderr;
        }
    }

    /* free sentinel_config when config loading is finished */
    freeSentinelConfig();
    return;

loaderr:
    fprintf(stderr, "\n*** FATAL CONFIG FILE ERROR (Redis %s) ***\n",
        KEYDB_REAL_VERSION);
    fprintf(stderr, "Reading the configuration file, at line %d\n", linenum);
    fprintf(stderr, ">>> '%s'\n", line);
    fprintf(stderr, "%s\n", err);
    exit(1);
}