Lines Matching refs:leader
207 char *leader; /* If this is a master instance, this is the runid of member
1212 ri->leader = NULL; in createSentinelRedisInstance()
1253 sdsfree(ri->leader); in releaseSentinelRedisInstance()
1409 if (ri->leader) { in sentinelResetMaster()
1410 sdsfree(ri->leader); in sentinelResetMaster()
1411 ri->leader = NULL; in sentinelResetMaster()
2814 addReplyBulkCString(c,ri->leader ? ri->leader : "?"); in addReplySentinelRedisInstance()
2932 char *leader = NULL; in sentinelCommand() local
2953 leader = sentinelVoteLeader(ri,(uint64_t)req_epoch, in sentinelCommand()
2962 addReplyBulkCString(c, leader ? leader : "*"); in sentinelCommand()
2964 if (leader) sdsfree(leader); in sentinelCommand()
3534 sdsfree(ri->leader); in sentinelReceiveIsMasterDownReply()
3540 ri->leader = sdsnew(r->element[1]->str); in sentinelReceiveIsMasterDownReply()
3565 sdsfree(ri->leader); in sentinelAskMasterStateToOtherSentinels()
3566 ri->leader = NULL; in sentinelAskMasterStateToOtherSentinels()
3618 sdsfree(master->leader); in sentinelVoteLeader()
3619 master->leader = sdsnew(req_runid); in sentinelVoteLeader()
3623 master->leader, (unsigned long long) master->leader_epoch); in sentinelVoteLeader()
3627 if (strcasecmp(master->leader,sentinel.myid)) in sentinelVoteLeader()
3632 return master->leader ? sdsnew(master->leader) : NULL; in sentinelVoteLeader()
3683 if (ri->leader != NULL && ri->leader_epoch == sentinel.current_epoch) in sentinelGetLeader()
3684 sentinelLeaderIncr(counters,ri->leader); in sentinelGetLeader()
3956 char *leader; in sentinelFailoverWaitStart() local
3960 leader = sentinelGetLeader(ri, ri->failover_epoch); in sentinelFailoverWaitStart()
3961 isleader = leader && strcasecmp(leader,sentinel.myid) == 0; in sentinelFailoverWaitStart()
3962 sdsfree(leader); in sentinelFailoverWaitStart()