fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-30 22:31:03 +00:00
Code Issues Projects Releases Wiki Activity

Sentinel: allow to vote for myself.

Browse Source
This commit is contained in:
antirez 2013-11-12 11:32:40 +01:00
parent b6b65b29c0
commit ab4b2ec88f
1 changed files with 3 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/sentinel.c
View File

@ -1043,24 +1043,6 @@ sentinelRedisInstance *sentinelGetMasterByName(char *name) {
return ri; return ri;
} }
/* Senitnel lookup by runid */
sentinelRedisInstance *sentinelGetSentinelByRunid(sentinelRedisInstance *master, char *runid) {
sentinelRedisInstance *retval = NULL;
dictIterator *di;
dictEntry *de;
di = dictGetIterator(master->sentinels);
while((de = dictNext(di)) != NULL) {
sentinelRedisInstance *ri = dictGetVal(de);
if (!strcmp(ri->runid,runid)) {
retval = ri;
break;
}
}
dictReleaseIterator(di);
return retval;
}
/* Add the specified flags to all the instances in the specified dictionary. */ /* Add the specified flags to all the instances in the specified dictionary. */
void sentinelAddFlagsToDictOfRedisInstances(dict *instances, int flags) { void sentinelAddFlagsToDictOfRedisInstances(dict *instances, int flags) {
dictIterator *di; dictIterator *di;
@ -2417,17 +2399,15 @@ int compareRunID(const void *a, const void *b) {
* If a vote is not available returns NULL, otherwise return the Sentinel * If a vote is not available returns NULL, otherwise return the Sentinel
* runid and populate the leader_epoch with the epoch of the last vote. */ * runid and populate the leader_epoch with the epoch of the last vote. */
char *sentinelVoteLeader(sentinelRedisInstance *master, uint64_t req_epoch, char *req_runid, uint64_t *leader_epoch) { char *sentinelVoteLeader(sentinelRedisInstance *master, uint64_t req_epoch, char *req_runid, uint64_t *leader_epoch) {
sentinelRedisInstance *si = sentinelGetSentinelByRunid(master,req_runid);
if (req_epoch > sentinel.current_epoch) if (req_epoch > sentinel.current_epoch)
sentinel.current_epoch = req_epoch; sentinel.current_epoch = req_epoch;
if (si && master->leader_epoch < req_epoch && if (master->leader_epoch < req_epoch && sentinel.current_epoch <= req_epoch) {
sentinel.current_epoch <= req_epoch)
{
sdsfree(master->leader); sdsfree(master->leader);
master->leader = sdsnew(req_runid); master->leader = sdsnew(req_runid);
master->leader_epoch = sentinel.current_epoch; master->leader_epoch = sentinel.current_epoch;
printf("Selected leader %s for epoch %llu\n", master->leader,
(unsigned long long) master->leader_epoch);
} }
*leader_epoch = master->leader_epoch; *leader_epoch = master->leader_epoch;