Lines Matching refs:sentinelRedisInstance

163 typedef struct sentinelRedisInstance {  struct
201 struct sentinelRedisInstance *master; /* Master instance if it's slave. */ argument
219 struct sentinelRedisInstance *promoted_slave; /* Promoted slave instance. */ argument
225 } sentinelRedisInstance; typedef
359 sentinelRedisInstance *sentinelGetMasterByName(char *name);
360 char *sentinelGetSubjectiveLeader(sentinelRedisInstance *master);
361 char *sentinelGetObjectiveLeader(sentinelRedisInstance *master);
364 const char *sentinelRedisInstanceTypeStr(sentinelRedisInstance *ri);
365 void sentinelAbortFailover(sentinelRedisInstance *ri);
366 void sentinelEvent(int level, char *type, sentinelRedisInstance *ri, const char *fmt, ...);
367 sentinelRedisInstance *sentinelSelectSlave(sentinelRedisInstance *master);
369 void sentinelStartFailover(sentinelRedisInstance *master);
371 int sentinelSendSlaveOf(sentinelRedisInstance *ri, char *host, int port);
372 char *sentinelVoteLeader(sentinelRedisInstance *master, uint64_t req_epoch, char *req_runid, uint64…
375 int sentinelSendPing(sentinelRedisInstance *ri);
376 int sentinelForceHelloUpdateForMaster(sentinelRedisInstance *master);
377 sentinelRedisInstance *getSentinelRedisInstanceByAddrAndRunID(dict *instances, char *ip, int port, …
384 void releaseSentinelRedisInstance(sentinelRedisInstance *ri);
582 void sentinelEvent(int level, char *type, sentinelRedisInstance *ri, in sentinelEvent()
590 sentinelRedisInstance *master = (ri->flags & SRI_MASTER) ? in sentinelEvent()
630 sentinelRedisInstance *master = (ri->flags & SRI_MASTER) ? in sentinelEvent()
649 sentinelRedisInstance *ri = dictGetVal(de); in sentinelGenerateInitialMonitorEvents()
914 void sentinelCallClientReconfScript(sentinelRedisInstance *master, int role, char *state, sentinelA… in sentinelCallClientReconfScript()
974 instanceLink *releaseInstanceLink(instanceLink *link, sentinelRedisInstance *ri) in releaseInstanceLink()
1018 int sentinelTryConnectionSharing(sentinelRedisInstance *ri) { in sentinelTryConnectionSharing()
1028 sentinelRedisInstance *master = dictGetVal(de), *match; in sentinelTryConnectionSharing()
1054 int sentinelUpdateSentinelAddressInAllMasters(sentinelRedisInstance *ri) { in sentinelUpdateSentinelAddressInAllMasters()
1062 sentinelRedisInstance *master = dictGetVal(de), *match; in sentinelUpdateSentinelAddressInAllMasters()
1145 sentinelRedisInstance *createSentinelRedisInstance(char *name, int flags, char *hostname, int port,… in createSentinelRedisInstance()
1146 sentinelRedisInstance *ri; in createSentinelRedisInstance()
1239 void releaseSentinelRedisInstance(sentinelRedisInstance *ri) { in releaseSentinelRedisInstance()
1266 sentinelRedisInstance *sentinelRedisInstanceLookupSlave( in sentinelRedisInstanceLookupSlave()
1267 sentinelRedisInstance *ri, char *ip, int port) in sentinelRedisInstanceLookupSlave()
1270 sentinelRedisInstance *slave; in sentinelRedisInstanceLookupSlave()
1282 const char *sentinelRedisInstanceTypeStr(sentinelRedisInstance *ri) { in sentinelRedisInstanceTypeStr()
1300 int removeMatchingSentinelFromMaster(sentinelRedisInstance *master, char *runid) { in removeMatchingSentinelFromMaster()
1309 sentinelRedisInstance *ri = dictGetVal(de); in removeMatchingSentinelFromMaster()
1326 sentinelRedisInstance *getSentinelRedisInstanceByAddrAndRunID(dict *instances, char *ip, int port, … in getSentinelRedisInstanceByAddrAndRunID()
1329 sentinelRedisInstance *instance = NULL; in getSentinelRedisInstanceByAddrAndRunID()
1334 sentinelRedisInstance *ri = dictGetVal(de); in getSentinelRedisInstanceByAddrAndRunID()
1350 sentinelRedisInstance *sentinelGetMasterByName(char *name) { in sentinelGetMasterByName()
1351 sentinelRedisInstance *ri; in sentinelGetMasterByName()
1366 sentinelRedisInstance *ri = dictGetVal(de); in sentinelAddFlagsToDictOfRedisInstances()
1380 sentinelRedisInstance *ri = dictGetVal(de); in sentinelDelFlagsToDictOfRedisInstances()
1398 void sentinelResetMaster(sentinelRedisInstance *ri, int flags) { in sentinelResetMaster()
1440 sentinelRedisInstance *ri = dictGetVal(de); in sentinelResetMastersByPattern()
1460 int sentinelResetMasterAndChangeAddress(sentinelRedisInstance *master, char *ip, int port) { in sentinelResetMasterAndChangeAddress()
1474 sentinelRedisInstance *slave = dictGetVal(de); in sentinelResetMasterAndChangeAddress()
1501 sentinelRedisInstance *slave; in sentinelResetMasterAndChangeAddress()
1519 int sentinelRedisInstanceNoDownFor(sentinelRedisInstance *ri, mstime_t ms) { in sentinelRedisInstanceNoDownFor()
1530 sentinelAddr *sentinelGetCurrentMasterAddress(sentinelRedisInstance *master) { in sentinelGetCurrentMasterAddress()
1548 void sentinelPropagateDownAfterPeriod(sentinelRedisInstance *master) { in sentinelPropagateDownAfterPeriod()
1557 sentinelRedisInstance *ri = dictGetVal(de); in sentinelPropagateDownAfterPeriod()
1564 char *sentinelGetInstanceTypeString(sentinelRedisInstance *ri) { in sentinelGetInstanceTypeString()
1573 sentinelRedisInstance *ri; in sentinelHandleConfiguration()
1654 sentinelRedisInstance *slave; in sentinelHandleConfiguration()
1666 sentinelRedisInstance *si; in sentinelHandleConfiguration()
1710 sentinelRedisInstance *master, *ri; in rewriteConfigSentinelOption()
1873 void sentinelSendAuthIfNeeded(sentinelRedisInstance *ri, redisAsyncContext *c) { in sentinelSendAuthIfNeeded()
1889 void sentinelSetClientName(sentinelRedisInstance *ri, redisAsyncContext *c, char *type) { in sentinelSetClientName()
1903 void sentinelReconnectInstance(sentinelRedisInstance *ri) { in sentinelReconnectInstance()
1979 int sentinelMasterLooksSane(sentinelRedisInstance *master) { in sentinelMasterLooksSane()
1988 void sentinelRefreshInstanceInfo(sentinelRedisInstance *ri, const char *info) { in sentinelRefreshInstanceInfo()
2004 sentinelRedisInstance *slave; in sentinelRefreshInstanceInfo()
2241 sentinelRedisInstance *ri = privdata; in sentinelInfoReplyCallback()
2264 sentinelRedisInstance *ri = privdata; in sentinelPingReplyCallback()
2303 sentinelRedisInstance *ri = privdata; in sentinelPublishReplyCallback()
2329 sentinelRedisInstance *si, *master; in sentinelProcessHelloMessage()
2357 sentinelRedisInstance *other = in sentinelProcessHelloMessage()
2427 sentinelRedisInstance *ri = privdata; in sentinelReceiveHelloMessages()
2465 int sentinelSendHello(sentinelRedisInstance *ri) { in sentinelSendHello()
2471 sentinelRedisInstance *master = (ri->flags & SRI_MASTER) ? ri : ri->master; in sentinelSendHello()
2513 sentinelRedisInstance *ri = dictGetVal(de); in sentinelForceHelloUpdateDictOfRedisInstances()
2528 int sentinelForceHelloUpdateForMaster(sentinelRedisInstance *master) { in sentinelForceHelloUpdateForMaster()
2542 int sentinelSendPing(sentinelRedisInstance *ri) { in sentinelSendPing()
2561 void sentinelSendPeriodicCommands(sentinelRedisInstance *ri) { in sentinelSendPeriodicCommands()
2636 void addReplySentinelRedisInstance(client *c, sentinelRedisInstance *ri) { in addReplySentinelRedisInstance()
2834 sentinelRedisInstance *ri = dictGetVal(de); in addReplyDictOfRedisInstances()
2844 sentinelRedisInstance *sentinelGetMasterByNameOrReplyError(client *c, in sentinelGetMasterByNameOrReplyError()
2847 sentinelRedisInstance *ri; in sentinelGetMasterByNameOrReplyError()
2860 int sentinelIsQuorumReachable(sentinelRedisInstance *master, int *usableptr) { in sentinelIsQuorumReachable()
2869 sentinelRedisInstance *ri = dictGetVal(de); in sentinelIsQuorumReachable()
2889 sentinelRedisInstance *ri; in sentinelCommand()
2897 sentinelRedisInstance *ri; in sentinelCommand()
2905 sentinelRedisInstance *ri; in sentinelCommand()
2929 sentinelRedisInstance *ri; in sentinelCommand()
2971 sentinelRedisInstance *ri; in sentinelCommand()
2986 sentinelRedisInstance *ri; in sentinelCommand()
3011 sentinelRedisInstance *ri; in sentinelCommand()
3061 sentinelRedisInstance *ri; in sentinelCommand()
3072 sentinelRedisInstance *ri; in sentinelCommand()
3115 sentinelRedisInstance *ri; in sentinelCommand()
3136 sentinelRedisInstance *ri = dictGetVal(de); in sentinelCommand()
3150 sentinelRedisInstance *sri = dictGetVal(sde); in sentinelCommand()
3255 sentinelRedisInstance *ri = dictGetVal(de); in sentinelInfoCommand()
3286 sentinelRedisInstance *ri = dictGetVal(de); in sentinelRoleCommand()
3295 sentinelRedisInstance *ri; in sentinelSetCommand()
3399 void sentinelCheckSubjectivelyDown(sentinelRedisInstance *ri) { in sentinelCheckSubjectivelyDown()
3471 void sentinelCheckObjectivelyDown(sentinelRedisInstance *master) { in sentinelCheckObjectivelyDown()
3482 sentinelRedisInstance *ri = dictGetVal(de); in sentinelCheckObjectivelyDown()
3509 sentinelRedisInstance *ri = privdata; in sentinelReceiveIsMasterDownReply()
3551 void sentinelAskMasterStateToOtherSentinels(sentinelRedisInstance *master, int flags) { in sentinelAskMasterStateToOtherSentinels()
3557 sentinelRedisInstance *ri = dictGetVal(de); in sentinelAskMasterStateToOtherSentinels()
3608 char *sentinelVoteLeader(sentinelRedisInstance *master, uint64_t req_epoch, char *req_runid, uint64… in sentinelVoteLeader()
3664 char *sentinelGetLeader(sentinelRedisInstance *master, uint64_t epoch) { in sentinelGetLeader()
3682 sentinelRedisInstance *ri = dictGetVal(de); in sentinelGetLeader()
3739 int sentinelSendSlaveOf(sentinelRedisInstance *ri, char *host, int port) { in sentinelSendSlaveOf()
3796 void sentinelStartFailover(sentinelRedisInstance *master) { in sentinelStartFailover()
3820 int sentinelStartFailoverIfNeeded(sentinelRedisInstance *master) { in sentinelStartFailoverIfNeeded()
3883 sentinelRedisInstance **sa = (sentinelRedisInstance **)a, in compareSlavesForPromotion()
3884 **sb = (sentinelRedisInstance **)b; in compareSlavesForPromotion()
3910 sentinelRedisInstance *sentinelSelectSlave(sentinelRedisInstance *master) { in sentinelSelectSlave()
3911 sentinelRedisInstance **instance = in sentinelSelectSlave()
3913 sentinelRedisInstance *selected = NULL; in sentinelSelectSlave()
3925 sentinelRedisInstance *slave = dictGetVal(de); in sentinelSelectSlave()
3946 qsort(instance,instances,sizeof(sentinelRedisInstance*), in sentinelSelectSlave()
3955 void sentinelFailoverWaitStart(sentinelRedisInstance *ri) { in sentinelFailoverWaitStart()
3988 void sentinelFailoverSelectSlave(sentinelRedisInstance *ri) { in sentinelFailoverSelectSlave()
3989 sentinelRedisInstance *slave = sentinelSelectSlave(ri); in sentinelFailoverSelectSlave()
4007 void sentinelFailoverSendSlaveOfNoOne(sentinelRedisInstance *ri) { in sentinelFailoverSendSlaveOfNoOne()
4035 void sentinelFailoverWaitPromotion(sentinelRedisInstance *ri) { in sentinelFailoverWaitPromotion()
4044 void sentinelFailoverDetectEnd(sentinelRedisInstance *master) { in sentinelFailoverDetectEnd()
4059 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverDetectEnd()
4089 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverDetectEnd()
4109 void sentinelFailoverReconfNextSlave(sentinelRedisInstance *master) { in sentinelFailoverReconfNextSlave()
4116 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverReconfNextSlave()
4127 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverReconfNextSlave()
4171 void sentinelFailoverSwitchToPromotedSlave(sentinelRedisInstance *master) { in sentinelFailoverSwitchToPromotedSlave()
4172 sentinelRedisInstance *ref = master->promoted_slave ? in sentinelFailoverSwitchToPromotedSlave()
4182 void sentinelFailoverStateMachine(sentinelRedisInstance *ri) { in sentinelFailoverStateMachine()
4211 void sentinelAbortFailover(sentinelRedisInstance *ri) { in sentinelAbortFailover()
4230 void sentinelHandleRedisInstance(sentinelRedisInstance *ri) { in sentinelHandleRedisInstance()
4269 sentinelRedisInstance *switch_to_promoted = NULL; in sentinelHandleDictOfRedisInstances()
4274 sentinelRedisInstance *ri = dictGetVal(de); in sentinelHandleDictOfRedisInstances()