Lines Matching refs:sentinel
244 } sentinel; variable
461 sentinel.current_epoch = 0; in initSentinel()
462 sentinel.masters = dictCreate(&instancesDictType,NULL); in initSentinel()
463 sentinel.tilt = 0; in initSentinel()
464 sentinel.tilt_start_time = 0; in initSentinel()
465 sentinel.previous_time = mstime(); in initSentinel()
466 sentinel.running_scripts = 0; in initSentinel()
467 sentinel.scripts_queue = listCreate(); in initSentinel()
468 sentinel.announce_ip = NULL; in initSentinel()
469 sentinel.announce_port = 0; in initSentinel()
470 sentinel.simfailure_flags = SENTINEL_SIMFAILURE_NONE; in initSentinel()
471 memset(sentinel.myid,0,sizeof(sentinel.myid)); in initSentinel()
494 if (sentinel.myid[j] != 0) break; in sentinelIsRunning()
498 getRandomHexChars(sentinel.myid,CONFIG_RUN_ID_SIZE); in sentinelIsRunning()
503 serverLog(LL_WARNING,"Sentinel ID is %s", sentinel.myid); in sentinelIsRunning()
647 di = dictGetIterator(sentinel.masters); in sentinelGenerateInitialMonitorEvents()
691 listAddNodeTail(sentinel.scripts_queue,sj); in sentinelScheduleScriptExecution()
694 if (listLength(sentinel.scripts_queue) > SENTINEL_SCRIPT_MAX_QUEUE) { in sentinelScheduleScriptExecution()
698 listRewind(sentinel.scripts_queue,&li); in sentinelScheduleScriptExecution()
704 listDelNode(sentinel.scripts_queue,ln); in sentinelScheduleScriptExecution()
708 serverAssert(listLength(sentinel.scripts_queue) <= in sentinelScheduleScriptExecution()
719 listRewind(sentinel.scripts_queue,&li); in sentinelGetScriptListNodeByPid()
738 listRewind(sentinel.scripts_queue,&li); in sentinelRunPendingScripts()
739 while (sentinel.running_scripts < SENTINEL_SCRIPT_MAX_RUNNING && in sentinelRunPendingScripts()
770 sentinel.running_scripts++; in sentinelRunPendingScripts()
833 listDelNode(sentinel.scripts_queue,ln); in sentinelCollectTerminatedScripts()
835 sentinel.running_scripts--; in sentinelCollectTerminatedScripts()
847 listRewind(sentinel.scripts_queue,&li); in sentinelKillTimedoutScripts()
866 addReplyMultiBulkLen(c,listLength(sentinel.scripts_queue)); in sentinelPendingScriptsCommand()
867 listRewind(sentinel.scripts_queue,&li); in sentinelPendingScriptsCommand()
1026 di = dictGetIterator(sentinel.masters); in sentinelTryConnectionSharing()
1060 di = dictGetIterator(sentinel.masters); in sentinelUpdateSentinelAddressInAllMasters()
1168 if (flags & SRI_MASTER) table = sentinel.masters; in createSentinelRedisInstance()
1354 ri = dictFetchValue(sentinel.masters,sdsname); in sentinelGetMasterByName()
1438 di = dictGetIterator(sentinel.masters); in sentinelResetMastersByPattern()
1632 if (current_epoch > sentinel.current_epoch) in sentinelHandleConfiguration()
1633 sentinel.current_epoch = current_epoch; in sentinelHandleConfiguration()
1637 memcpy(sentinel.myid,argv[1],CONFIG_RUN_ID_SIZE); in sentinelHandleConfiguration()
1646 if (ri->config_epoch > sentinel.current_epoch) in sentinelHandleConfiguration()
1647 sentinel.current_epoch = ri->config_epoch; in sentinelHandleConfiguration()
1683 sentinel.announce_ip = sdsnew(argv[1]); in sentinelHandleConfiguration()
1686 sentinel.announce_port = atoi(argv[1]); in sentinelHandleConfiguration()
1704 line = sdscatprintf(sdsempty(), "sentinel myid %s", sentinel.myid); in rewriteConfigSentinelOption()
1708 di = dictGetIterator(sentinel.masters); in rewriteConfigSentinelOption()
1818 "sentinel current-epoch %llu", (unsigned long long) sentinel.current_epoch); in rewriteConfigSentinelOption()
1822 if (sentinel.announce_ip) { in rewriteConfigSentinelOption()
1824 line = sdscatrepr(line, sentinel.announce_ip, sdslen(sentinel.announce_ip)); in rewriteConfigSentinelOption()
1829 if (sentinel.announce_port) { in rewriteConfigSentinelOption()
1831 sentinel.announce_port); in rewriteConfigSentinelOption()
1892 snprintf(name,sizeof(name),"sentinel-%.8s-%s",sentinel.myid,type); in sentinelSetClientName()
2134 if (sentinel.tilt) return; in sentinelRefreshInstanceInfo()
2162 if (sentinel.simfailure_flags & in sentinelRefreshInstanceInfo()
2384 if (current_epoch > sentinel.current_epoch) { in sentinelProcessHelloMessage()
2385 sentinel.current_epoch = current_epoch; in sentinelProcessHelloMessage()
2388 (unsigned long long) sentinel.current_epoch); in sentinelProcessHelloMessage()
2449 if (strstr(r->element[2]->str,sentinel.myid) != NULL) return; in sentinelReceiveHelloMessages()
2478 if (sentinel.announce_ip) { in sentinelSendHello()
2479 announce_ip = sentinel.announce_ip; in sentinelSendHello()
2485 announce_port = sentinel.announce_port ? in sentinelSendHello()
2486 sentinel.announce_port : server.port; in sentinelSendHello()
2492 announce_ip, announce_port, sentinel.myid, in sentinelSendHello()
2493 (unsigned long long) sentinel.current_epoch, in sentinelSendHello()
2849 ri = dictFetchValue(sentinel.masters,name->ptr); in sentinelGetMasterByNameOrReplyError()
2886 addReplyDictOfRedisInstances(c,sentinel.masters); in sentinelCommand()
2941 ri = getSentinelRedisInstanceByAddrAndRunID(sentinel.masters, in sentinelCommand()
2946 if (!sentinel.tilt && ri && (ri->flags & SRI_S_DOWN) && in sentinelCommand()
3067 dictDelete(sentinel.masters,c->argv[2]->ptr); in sentinelCommand()
3110 dict *masters_local = sentinel.masters; in sentinelCommand()
3161 if (masters_local != sentinel.masters) dictRelease(masters_local); in sentinelCommand()
3166 sentinel.simfailure_flags = SENTINEL_SIMFAILURE_NONE; in sentinelCommand()
3169 sentinel.simfailure_flags |= in sentinelCommand()
3175 sentinel.simfailure_flags |= in sentinelCommand()
3247 dictSize(sentinel.masters), in sentinelInfoCommand()
3248 sentinel.tilt, in sentinelInfoCommand()
3249 sentinel.running_scripts, in sentinelInfoCommand()
3250 listLength(sentinel.scripts_queue), in sentinelInfoCommand()
3251 sentinel.simfailure_flags); in sentinelInfoCommand()
3253 di = dictGetIterator(sentinel.masters); in sentinelInfoCommand()
3282 addReplyMultiBulkLen(c,dictSize(sentinel.masters)); in sentinelRoleCommand()
3284 di = dictGetIterator(sentinel.masters); in sentinelRoleCommand()
3586 sentinel.current_epoch, in sentinelAskMasterStateToOtherSentinels()
3588 sentinel.myid : "*"); in sentinelAskMasterStateToOtherSentinels()
3609 if (req_epoch > sentinel.current_epoch) { in sentinelVoteLeader()
3610 sentinel.current_epoch = req_epoch; in sentinelVoteLeader()
3613 (unsigned long long) sentinel.current_epoch); in sentinelVoteLeader()
3616 if (master->leader_epoch < req_epoch && sentinel.current_epoch <= req_epoch) in sentinelVoteLeader()
3620 master->leader_epoch = sentinel.current_epoch; in sentinelVoteLeader()
3627 if (strcasecmp(master->leader,sentinel.myid)) in sentinelVoteLeader()
3683 if (ri->leader != NULL && ri->leader_epoch == sentinel.current_epoch) in sentinelGetLeader()
3708 myvote = sentinelVoteLeader(master,epoch,sentinel.myid,&leader_epoch); in sentinelGetLeader()
3801 master->failover_epoch = ++sentinel.current_epoch; in sentinelStartFailover()
3803 (unsigned long long) sentinel.current_epoch); in sentinelStartFailover()
3961 isleader = leader && strcasecmp(leader,sentinel.myid) == 0; in sentinelFailoverWaitStart()
3981 if (sentinel.simfailure_flags & SENTINEL_SIMFAILURE_CRASH_AFTER_ELECTION) in sentinelFailoverWaitStart()
4240 if (sentinel.tilt) { in sentinelHandleRedisInstance()
4241 if (mstime()-sentinel.tilt_start_time < SENTINEL_TILT_PERIOD) return; in sentinelHandleRedisInstance()
4242 sentinel.tilt = 0; in sentinelHandleRedisInstance()
4311 mstime_t delta = now - sentinel.previous_time; in sentinelCheckTiltCondition()
4314 sentinel.tilt = 1; in sentinelCheckTiltCondition()
4315 sentinel.tilt_start_time = mstime(); in sentinelCheckTiltCondition()
4318 sentinel.previous_time = mstime(); in sentinelCheckTiltCondition()
4323 sentinelHandleDictOfRedisInstances(sentinel.masters); in sentinelTimer()