50     int port;  member
371 int sentinelSendSlaveOf(sentinelRedisInstance *ri, char *host, int port);
377 sentinelRedisInstance *getSentinelRedisInstanceByAddrAndRunID(dict *instances, char *ip, int port, …
442     server.port = REDIS_SENTINEL_PORT;  in initSentinelConfig()
517 sentinelAddr *createSentinelAddr(char *hostname, int port) {  in createSentinelAddr()  argument
521     if (port < 0 || port > 65535) {  in createSentinelAddr()
531     sa->port = port;  in createSentinelAddr()
541     sa->port = src->port;  in dupSentinelAddr()
553     return a->port == b->port && !strcasecmp(a->ip,b->ip);  in sentinelAddrIsEqual()
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()
918     ll2string(fromport,sizeof(fromport),from->port);  in sentinelCallClientReconfScript()
919     ll2string(toport,sizeof(toport),to->port);  in sentinelCallClientReconfScript()
1145 sentinelRedisInstance *createSentinelRedisInstance(char *name, int flags, char *hostname, int port,…  in createSentinelRedisInstance()  argument
1155     addr = createSentinelAddr(hostname,port);  in createSentinelRedisInstance()
1160         anetFormatAddr(slavename, sizeof(slavename), hostname, port);  in createSentinelRedisInstance()
1267                 sentinelRedisInstance *ri, char *ip, int port)  in sentinelRedisInstanceLookupSlave()  argument
1274     anetFormatAddr(buf,sizeof(buf),ip,port);  in sentinelRedisInstanceLookupSlave()
1326 sentinelRedisInstance *getSentinelRedisInstanceByAddrAndRunID(dict *instances, char *ip, int port, …  in getSentinelRedisInstanceByAddrAndRunID()  argument
1339                             ri->addr->port == port)))  in getSentinelRedisInstanceByAddrAndRunID()
1460 int sentinelResetMasterAndChangeAddress(sentinelRedisInstance *master, char *ip, int port) {  in sentinelResetMasterAndChangeAddress()  argument
1467     newaddr = createSentinelAddr(ip,port);  in sentinelResetMasterAndChangeAddress()
1479                                                  slave->addr->port);  in sentinelResetMasterAndChangeAddress()
1489                                                  master->addr->port);  in sentinelResetMasterAndChangeAddress()
1504                     slaves[j]->port, master->quorum, master);  in sentinelResetMasterAndChangeAddress()
1717             master->name, master_addr->ip, master_addr->port,  in rewriteConfigSentinelOption()
1798                 master->name, slave_addr->ip, slave_addr->port);  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()
2026             char *ip, *port, *end;  in sentinelRefreshInstanceInfo()  local
2032                 port = strchr(ip,','); if (!port) continue;  in sentinelRefreshInstanceInfo()
2033                 *port = '\0'; /* nul term for easy access. */  in sentinelRefreshInstanceInfo()
2034                 port++; /* Now port points to start of port number. */  in sentinelRefreshInstanceInfo()
2035                 end = strchr(port,','); if (!end) continue;  in sentinelRefreshInstanceInfo()
2041                 port = strstr(l,"port="); if (!port) continue;  in sentinelRefreshInstanceInfo()
2042                 port += 5; /* Now port points to start of port number. */  in sentinelRefreshInstanceInfo()
2045                 end = strchr(port,','); if (end) *end = '\0';  in sentinelRefreshInstanceInfo()
2050             if (sentinelRedisInstanceLookupSlave(ri,ip,atoi(port)) == NULL) {  in sentinelRefreshInstanceInfo()
2052                             atoi(port), ri->quorum, ri)) != NULL)  in sentinelRefreshInstanceInfo()
2183                         ri->master->addr->port);  in sentinelRefreshInstanceInfo()
2193         (ri->slave_master_port != ri->master->addr->port ||  in sentinelRefreshInstanceInfo()
2206                     ri->master->addr->port);  in sentinelRefreshInstanceInfo()
2222             ri->slave_master_port == ri->master->promoted_slave->addr->port)  in sentinelRefreshInstanceInfo()
2326     int numtokens, port, removed, master_port;  in sentinelProcessHelloMessage()  local
2337         port = atoi(token[1]);  in sentinelProcessHelloMessage()
2340                         master->sentinels,token[0],port,token[2]);  in sentinelProcessHelloMessage()
2351                     "%@ ip %s port %d for %s", token[0],port,token[2]);  in sentinelProcessHelloMessage()
2359                         master->sentinels, token[0],port,NULL);  in sentinelProcessHelloMessage()
2362                     other->addr->port = 0; /* It means: invalid address. */  in sentinelProcessHelloMessage()
2369                             token[0],port,master->quorum,master);  in sentinelProcessHelloMessage()
2394             if (master_port != master->addr->port ||  in sentinelProcessHelloMessage()
2403                     master->addr->ip, master->addr->port,  in sentinelProcessHelloMessage()
2486                     sentinel.announce_port : server.port;  in sentinelSendHello()
2495         master->name,master_addr->ip,master_addr->port,  in sentinelSendHello()
2652     addReplyBulkLongLong(c,ri->addr->port);  in addReplySentinelRedisInstance()
2933         long port;  in sentinelCommand()  local
2937         if (getLongFromObjectOrReply(c,c->argv[3],&port,NULL) != C_OK ||  in sentinelCommand()
2942             c->argv[2]->ptr,port,NULL);  in sentinelCommand()
2982             addReplyBulkLongLong(c,addr->port);  in sentinelCommand()
3012         long quorum, port;  in sentinelCommand()  local
3018         if (getLongFromObjectOrReply(c,c->argv[4],&port,"Invalid port")  in sentinelCommand()
3036                 c->argv[3]->ptr,port,quorum,NULL);  in sentinelCommand()
3264                 ri->addr->ip, ri->addr->port,  in sentinelInfoCommand()
3559         char port[32];  in sentinelAskMasterStateToOtherSentinels()  local
3581         ll2string(port,sizeof(port),master->addr->port);  in sentinelAskMasterStateToOtherSentinels()
3585                     master->addr->ip, port,  in sentinelAskMasterStateToOtherSentinels()
3739 int sentinelSendSlaveOf(sentinelRedisInstance *ri, char *host, int port) {  in sentinelSendSlaveOf()  argument
3743     ll2string(portstr,sizeof(portstr),port);  in sentinelSendSlaveOf()
4097                     master->promoted_slave->addr->port);  in sentinelFailoverDetectEnd()
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()