Lines Matching refs:slave

1270     sentinelRedisInstance *slave;  in sentinelRedisInstanceLookupSlave()  local
1276 slave = dictFetchValue(ri->slaves,key); in sentinelRedisInstanceLookupSlave()
1278 return slave; in sentinelRedisInstanceLookupSlave()
1474 sentinelRedisInstance *slave = dictGetVal(de); in sentinelResetMasterAndChangeAddress() local
1476 if (sentinelAddrIsEqual(slave->addr,newaddr)) continue; in sentinelResetMasterAndChangeAddress()
1478 slaves[numslaves++] = createSentinelAddr(slave->addr->ip, in sentinelResetMasterAndChangeAddress()
1479 slave->addr->port); in sentinelResetMasterAndChangeAddress()
1501 sentinelRedisInstance *slave; in sentinelResetMasterAndChangeAddress() local
1503 slave = createSentinelRedisInstance(NULL,SRI_SLAVE,slaves[j]->ip, in sentinelResetMasterAndChangeAddress()
1506 if (slave) sentinelEvent(LL_NOTICE,"+slave",slave,"%@"); in sentinelResetMasterAndChangeAddress()
1654 sentinelRedisInstance *slave; in sentinelHandleConfiguration() local
1659 if ((slave = createSentinelRedisInstance(NULL,SRI_SLAVE,argv[2], in sentinelHandleConfiguration()
2004 sentinelRedisInstance *slave; in sentinelRefreshInstanceInfo() local
2051 if ((slave = createSentinelRedisInstance(NULL,SRI_SLAVE,ip, in sentinelRefreshInstanceInfo()
2054 sentinelEvent(LL_NOTICE,"+slave",slave,"%@"); in sentinelRefreshInstanceInfo()
3925 sentinelRedisInstance *slave = dictGetVal(de); in sentinelSelectSlave() local
3928 if (slave->flags & (SRI_S_DOWN|SRI_O_DOWN)) continue; in sentinelSelectSlave()
3929 if (slave->link->disconnected) continue; in sentinelSelectSlave()
3930 if (mstime() - slave->link->last_avail_time > SENTINEL_PING_PERIOD*5) continue; in sentinelSelectSlave()
3931 if (slave->slave_priority == 0) continue; in sentinelSelectSlave()
3940 if (mstime() - slave->info_refresh > info_validity_time) continue; in sentinelSelectSlave()
3941 if (slave->master_link_down_time > max_master_down_time) continue; in sentinelSelectSlave()
3942 instance[instances++] = slave; in sentinelSelectSlave()
3989 sentinelRedisInstance *slave = sentinelSelectSlave(ri); in sentinelFailoverSelectSlave() local
3993 if (slave == NULL) { in sentinelFailoverSelectSlave()
3997 sentinelEvent(LL_WARNING,"+selected-slave",slave,"%@"); in sentinelFailoverSelectSlave()
3998 slave->flags |= SRI_PROMOTED; in sentinelFailoverSelectSlave()
3999 ri->promoted_slave = slave; in sentinelFailoverSelectSlave()
4003 slave, "%@"); in sentinelFailoverSelectSlave()
4059 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverDetectEnd() local
4061 if (slave->flags & (SRI_PROMOTED|SRI_RECONF_DONE)) continue; in sentinelFailoverDetectEnd()
4062 if (slave->flags & SRI_S_DOWN) continue; in sentinelFailoverDetectEnd()
4089 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverDetectEnd() local
4092 if (slave->flags & (SRI_RECONF_DONE|SRI_RECONF_SENT)) continue; in sentinelFailoverDetectEnd()
4093 if (slave->link->disconnected) continue; in sentinelFailoverDetectEnd()
4095 retval = sentinelSendSlaveOf(slave, in sentinelFailoverDetectEnd()
4099 sentinelEvent(LL_NOTICE,"+slave-reconf-sent-be",slave,"%@"); in sentinelFailoverDetectEnd()
4100 slave->flags |= SRI_RECONF_SENT; in sentinelFailoverDetectEnd()
4116 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverReconfNextSlave() local
4118 if (slave->flags & (SRI_RECONF_SENT|SRI_RECONF_INPROG)) in sentinelFailoverReconfNextSlave()
4127 sentinelRedisInstance *slave = dictGetVal(de); in sentinelFailoverReconfNextSlave() local
4131 if (slave->flags & (SRI_PROMOTED|SRI_RECONF_DONE)) continue; in sentinelFailoverReconfNextSlave()
4137 if ((slave->flags & SRI_RECONF_SENT) && in sentinelFailoverReconfNextSlave()
4138 (mstime() - slave->slave_reconf_sent_time) > in sentinelFailoverReconfNextSlave()
4141 sentinelEvent(LL_NOTICE,"-slave-reconf-sent-timeout",slave,"%@"); in sentinelFailoverReconfNextSlave()
4142 slave->flags &= ~SRI_RECONF_SENT; in sentinelFailoverReconfNextSlave()
4143 slave->flags |= SRI_RECONF_DONE; in sentinelFailoverReconfNextSlave()
4148 if (slave->flags & (SRI_RECONF_SENT|SRI_RECONF_INPROG)) continue; in sentinelFailoverReconfNextSlave()
4149 if (slave->link->disconnected) continue; in sentinelFailoverReconfNextSlave()
4152 retval = sentinelSendSlaveOf(slave, in sentinelFailoverReconfNextSlave()
4156 slave->flags |= SRI_RECONF_SENT; in sentinelFailoverReconfNextSlave()
4157 slave->slave_reconf_sent_time = mstime(); in sentinelFailoverReconfNextSlave()
4158 sentinelEvent(LL_NOTICE,"+slave-reconf-sent",slave,"%@"); in sentinelFailoverReconfNextSlave()