Lines Matching refs:addr
168 sentinelAddr *addr; /* Master host. */ member
596 ri->name, ri->addr->ip, ri->addr->port, in sentinelEvent()
597 master->name, master->addr->ip, master->addr->port); in sentinelEvent()
601 ri->name, ri->addr->ip, ri->addr->port); in sentinelEvent()
1079 releaseSentinelAddr(match->addr); in sentinelUpdateSentinelAddressInAllMasters()
1080 match->addr = dupSentinelAddr(ri->addr); in sentinelUpdateSentinelAddressInAllMasters()
1147 sentinelAddr *addr; in createSentinelRedisInstance() local
1155 addr = createSentinelAddr(hostname,port); in createSentinelRedisInstance()
1156 if (addr == NULL) return NULL; in createSentinelRedisInstance()
1173 releaseSentinelAddr(addr); in createSentinelRedisInstance()
1187 ri->addr = addr; in createSentinelRedisInstance()
1256 releaseSentinelAddr(ri->addr); in releaseSentinelRedisInstance()
1338 (ip == NULL || (strcmp(ri->addr->ip, ip) == 0 && in getSentinelRedisInstanceByAddrAndRunID()
1339 ri->addr->port == port))) in getSentinelRedisInstanceByAddrAndRunID()
1476 if (sentinelAddrIsEqual(slave->addr,newaddr)) continue; in sentinelResetMasterAndChangeAddress()
1478 slaves[numslaves++] = createSentinelAddr(slave->addr->ip, in sentinelResetMasterAndChangeAddress()
1479 slave->addr->port); in sentinelResetMasterAndChangeAddress()
1486 if (!sentinelAddrIsEqual(newaddr,master->addr)) { in sentinelResetMasterAndChangeAddress()
1488 slaves[numslaves++] = createSentinelAddr(master->addr->ip, in sentinelResetMasterAndChangeAddress()
1489 master->addr->port); in sentinelResetMasterAndChangeAddress()
1494 oldaddr = master->addr; in sentinelResetMasterAndChangeAddress()
1495 master->addr = newaddr; in sentinelResetMasterAndChangeAddress()
1540 return master->promoted_slave->addr; in sentinelGetCurrentMasterAddress()
1542 return master->addr; in sentinelGetCurrentMasterAddress()
1787 slave_addr = ri->addr; in rewriteConfigSentinelOption()
1795 slave_addr = master->addr; in rewriteConfigSentinelOption()
1810 master->name, ri->addr->ip, ri->addr->port, ri->runid); in rewriteConfigSentinelOption()
1905 if (ri->addr->port == 0) return; /* port == 0 means invalid address. */ in sentinelReconnectInstance()
1914 link->cc = redisAsyncConnectBind(ri->addr->ip,ri->addr->port,NET_FIRST_BIND_ADDR); in sentinelReconnectInstance()
1937 link->pc = redisAsyncConnectBind(ri->addr->ip,ri->addr->port,NET_FIRST_BIND_ADDR); in sentinelReconnectInstance()
2168 "start",ri->master->addr,ri->addr); in sentinelRefreshInstanceInfo()
2182 ri->master->addr->ip, in sentinelRefreshInstanceInfo()
2183 ri->master->addr->port); in sentinelRefreshInstanceInfo()
2193 (ri->slave_master_port != ri->master->addr->port || in sentinelRefreshInstanceInfo()
2194 strcasecmp(ri->slave_master_host,ri->master->addr->ip))) in sentinelRefreshInstanceInfo()
2205 ri->master->addr->ip, in sentinelRefreshInstanceInfo()
2206 ri->master->addr->port); in sentinelRefreshInstanceInfo()
2221 ri->master->promoted_slave->addr->ip) == 0 && in sentinelRefreshInstanceInfo()
2222 ri->slave_master_port == ri->master->promoted_slave->addr->port) in sentinelRefreshInstanceInfo()
2362 other->addr->port = 0; /* It means: invalid address. */ in sentinelProcessHelloMessage()
2394 if (master_port != master->addr->port || in sentinelProcessHelloMessage()
2395 strcmp(master->addr->ip, token[5])) in sentinelProcessHelloMessage()
2403 master->addr->ip, master->addr->port, in sentinelProcessHelloMessage()
2406 old_addr = dupSentinelAddr(master->addr); in sentinelProcessHelloMessage()
2410 old_addr,master->addr); in sentinelProcessHelloMessage()
2648 addReplyBulkCString(c,ri->addr->ip); in addReplySentinelRedisInstance()
2652 addReplyBulkLongLong(c,ri->addr->port); in addReplySentinelRedisInstance()
2978 sentinelAddr *addr = sentinelGetCurrentMasterAddress(ri); in sentinelCommand() local
2981 addReplyBulkCString(c,addr->ip); in sentinelCommand()
2982 addReplyBulkLongLong(c,addr->port); in sentinelCommand()
3264 ri->addr->ip, ri->addr->port, in sentinelInfoCommand()
3581 ll2string(port,sizeof(port),master->addr->port); in sentinelAskMasterStateToOtherSentinels()
3585 master->addr->ip, port, in sentinelAskMasterStateToOtherSentinels()
4096 master->promoted_slave->addr->ip, in sentinelFailoverDetectEnd()
4097 master->promoted_slave->addr->port); in sentinelFailoverDetectEnd()
4153 master->promoted_slave->addr->ip, in sentinelFailoverReconfNextSlave()
4154 master->promoted_slave->addr->port); in sentinelFailoverReconfNextSlave()
4176 master->name, master->addr->ip, master->addr->port, in sentinelFailoverSwitchToPromotedSlave()
4177 ref->addr->ip, ref->addr->port); in sentinelFailoverSwitchToPromotedSlave()
4179 sentinelResetMasterAndChangeAddress(master,ref->addr->ip,ref->addr->port); in sentinelFailoverSwitchToPromotedSlave()