diff options
Diffstat (limited to 'src/sentinel.c')
-rw-r--r-- | src/sentinel.c | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/src/sentinel.c b/src/sentinel.c index b4dead7de..326def135 100644 --- a/src/sentinel.c +++ b/src/sentinel.c @@ -1740,7 +1740,7 @@ const char *sentinelCheckCreateInstanceErrors(int role) { } /* init function for server.sentinel_config */ -void initializeSentinelConfig() { +void initializeSentinelConfig(void) { server.sentinel_config = zmalloc(sizeof(struct sentinelConfig)); server.sentinel_config->monitor_cfg = listCreate(); server.sentinel_config->pre_monitor_cfg = listCreate(); @@ -1751,7 +1751,7 @@ void initializeSentinelConfig() { } /* destroy function for server.sentinel_config */ -void freeSentinelConfig() { +void freeSentinelConfig(void) { /* release these three config queues since we will not use it anymore */ listRelease(server.sentinel_config->pre_monitor_cfg); listRelease(server.sentinel_config->monitor_cfg); @@ -2176,7 +2176,12 @@ void rewriteConfigSentinelOption(struct rewriteConfigState *state) { line = sdscatprintf(sdsempty(), "sentinel known-replica %s %s %d", master->name, announceSentinelAddr(slave_addr), slave_addr->port); - rewriteConfigRewriteLine(state,"sentinel known-replica",line,1); + /* try to replace any known-slave option first if found */ + if (rewriteConfigRewriteLine(state, "sentinel known-slave", sdsdup(line), 0) == 0) { + rewriteConfigRewriteLine(state, "sentinel known-replica", line, 1); + } else { + sdsfree(line); + } /* rewriteConfigMarkAsProcessed is handled after the loop */ } dictReleaseIterator(di2); @@ -3174,7 +3179,7 @@ void sentinelSendPeriodicCommands(sentinelRedisInstance *ri) { /* =========================== SENTINEL command ============================= */ -const char* getLogLevel() { +const char* getLogLevel(void) { switch (server.verbosity) { case LL_DEBUG: return "debug"; case LL_VERBOSE: return "verbose"; @@ -4066,11 +4071,14 @@ NULL } /* Reply format: - * 1.) master name - * 2.) 1.) info from master - * 2.) info from replica - * ... - * 3.) other master name + * 1) master name + * 2) 1) 1) info cached ms + * 2) info from master + * 2) 1) info cached ms + * 2) info from replica1 + * ... + * 3) other master name + * ... * ... */ addReplyArrayLen(c,dictSize(masters_local) * 2); |