Home
last modified time | relevance | path

Searched refs:ip (Results 1 – 20 of 20) sorted by relevance

/redis-3.2.3/src/
H A Dlzf_d.c91 … case 32: *op++ = *ip++; case 31: *op++ = *ip++; case 30: *op++ = *ip++; case 29: *op++ = *ip++; in lzf_decompress()
92 … case 28: *op++ = *ip++; case 27: *op++ = *ip++; case 26: *op++ = *ip++; case 25: *op++ = *ip++; in lzf_decompress()
93 … case 24: *op++ = *ip++; case 23: *op++ = *ip++; case 22: *op++ = *ip++; case 21: *op++ = *ip++; in lzf_decompress()
94 … case 20: *op++ = *ip++; case 19: *op++ = *ip++; case 18: *op++ = *ip++; case 17: *op++ = *ip++; in lzf_decompress()
95 … case 16: *op++ = *ip++; case 15: *op++ = *ip++; case 14: *op++ = *ip++; case 13: *op++ = *ip++; in lzf_decompress()
96 … case 12: *op++ = *ip++; case 11: *op++ = *ip++; case 10: *op++ = *ip++; case 9: *op++ = *ip++; in lzf_decompress()
97 … case 8: *op++ = *ip++; case 7: *op++ = *ip++; case 6: *op++ = *ip++; case 5: *op++ = *ip++; in lzf_decompress()
98 … case 4: *op++ = *ip++; case 3: *op++ = *ip++; case 2: *op++ = *ip++; case 1: *op++ = *ip++; in lzf_decompress()
109 if (ip >= in_end) in lzf_decompress()
127 ref -= *ip++; in lzf_decompress()
[all …]
H A Dlzf_c.c139 hval = FRST (ip); in lzf_compress()
156 && ((ref[1] << 8) | ref[0]) == ((ip[1] << 8) | ip[0]) in lzf_compress()
207 ip++; in lzf_compress()
223 ip += len + 1; in lzf_compress()
229 --ip; in lzf_compress()
231 --ip; in lzf_compress()
237 ip++; in lzf_compress()
242 ip++; in lzf_compress()
245 ip -= len + 1; in lzf_compress()
251 ip++; in lzf_compress()
[all …]
H A Danet.c554 if (ip) inet_ntop(AF_INET,(void*)&(s->sin_addr),ip,ip_len); in anetTcpAccept()
558 if (ip) inet_ntop(AF_INET6,(void*)&(s->sin6_addr),ip,ip_len); in anetTcpAccept()
583 if (ip) inet_ntop(AF_INET,(void*)&(s->sin_addr),ip,ip_len); in anetPeerToString()
587 if (ip) inet_ntop(AF_INET6,(void*)&(s->sin6_addr),ip,ip_len); in anetPeerToString()
590 if (ip) strncpy(ip,"/unixsocket",ip_len); in anetPeerToString()
598 if (ip) { in anetPeerToString()
623 anetPeerToString(fd,ip,sizeof(ip),&port); in anetFormatPeer()
633 ip[0] = '?'; in anetSockName()
639 if (ip) inet_ntop(AF_INET,(void*)&(s->sin_addr),ip,ip_len); in anetSockName()
643 if (ip) inet_ntop(AF_INET6,(void*)&(s->sin6_addr),ip,ip_len); in anetSockName()
[all …]
H A Danet.h64 int anetTcpAccept(char *err, int serversock, char *ip, size_t ip_len, int *port);
73 int anetPeerToString(int fd, char *ip, size_t ip_len, int *port);
75 int anetSockName(int fd, char *ip, size_t ip_len, int *port);
76 int anetFormatAddr(char *fmt, size_t fmt_len, char *ip, int port);
H A Dsentinel.c49 char *ip; member
525 if (anetResolve(NULL,hostname,ip,sizeof(ip)) == ANET_ERR) { in createSentinelAddr()
530 sa->ip = sdsnew(ip); in createSentinelAddr()
540 sa->ip = sdsnew(src->ip); in dupSentinelAddr()
547 sdsfree(sa->ip); in releaseSentinelAddr()
553 return a->port == b->port && !strcasecmp(a->ip,b->ip); in sentinelAddrIsEqual()
923 state, from->ip, fromport, to->ip, toport, NULL); in sentinelCallClientReconfScript()
1338 (ip == NULL || (strcmp(ri->addr->ip, ip) == 0 && in getSentinelRedisInstanceByAddrAndRunID()
2030 ip = strchr(l,':'); if (!ip) continue; in sentinelRefreshInstanceInfo()
2039 ip = strstr(l,"ip="); if (!ip) continue; in sentinelRefreshInstanceInfo()
[all …]
H A Dcluster.c671 memset(node->ip,0,sizeof(node->ip)); in createClusterNode()
1224 if (!strcasecmp(node->ip,ip) && node->port == port) break; in clusterHandshakeInProgress()
1283 memcpy(n->ip,norm_ip,sizeof(n->ip)); in clusterStartHandshake()
1306 g->ip, in clusterProcessGossipSection()
1344 memcpy(node->ip,g->ip,NET_IP_STR_LEN); in clusterProcessGossipSection()
1395 if (node->port == port && strcmp(ip,node->ip) == 0) return 0; in nodeUpdateAddressIfNeeded()
1398 memcpy(node->ip,ip,sizeof(ip)); in nodeUpdateAddressIfNeeded()
1651 strcmp(ip,myself->ip)) in clusterProcessPacket()
1653 memcpy(myself->ip,ip,NET_IP_STR_LEN); in clusterProcessPacket()
2275 memcpy(gossip->ip,this->ip,sizeof(this->ip)); in clusterSendPing()
[all …]
H A Dreplication.c54 char ip[NET_IP_STR_LEN]; in replicationGetSlaveName() local
56 ip[0] = '\0'; in replicationGetSlaveName()
59 anetPeerToString(c->fd,ip,sizeof(ip),NULL) != -1) in replicationGetSlaveName()
67 snprintf(buf,sizeof(buf),"%s:<unknown-slave-port>",ip); in replicationGetSlaveName()
726 sds ip = c->argv[j+1]->ptr; in replconfCommand() local
727 if (sdslen(ip) < sizeof(c->slave_ip)) { in replconfCommand()
728 memcpy(c->slave_ip,ip,sdslen(ip)+1); in replconfCommand()
1726 void replicationSetMaster(char *ip, int port) { in replicationSetMaster() argument
1728 server.masterhost = sdsnew(ip); in replicationSetMaster()
1836 if (anetPeerToString(slave->fd,ip,sizeof(ip),NULL) == -1) in roleCommand()
[all …]
H A Dcluster.h102 char ip[NET_IP_STR_LEN]; /* Latest known IP address of this node */ member
173 char ip[NET_IP_STR_LEN]; /* IP address last time it was seen */ member
H A Dredis-trib.rb65 ip = s.join(":") # if s.length > 1 here, it's IPv6, so restore address
68 @info[:host] = ip
684 ips.each do |ip,nodes|
H A Dnetworking.c616 static void acceptCommonHandler(int fd, int flags, char *ip) { in acceptCommonHandler() argument
649 ip != NULL) in acceptCommonHandler()
651 if (strcmp(ip,"127.0.0.1") && strcmp(ip,"::1")) { in acceptCommonHandler()
H A Dserver.c3196 char ip[NET_IP_STR_LEN], *slaveip = slave->slave_ip; in genRedisInfoString() local
3201 if (anetPeerToString(slave->fd,ip,sizeof(ip),&port) == -1) in genRedisInfoString()
3203 slaveip = ip; in genRedisInfoString()
H A Dserver.h1239 void replicationSetMaster(char *ip, int port);
/redis-3.2.3/deps/hiredis/
H A Dhiredis.h175 redisContext *redisConnect(const char *ip, int port);
176 redisContext *redisConnectWithTimeout(const char *ip, int port, const struct timeval tv);
177 redisContext *redisConnectNonBlock(const char *ip, int port);
178 redisContext *redisConnectBindNonBlock(const char *ip, int port, const char *source_addr);
H A Dasync.h104 redisAsyncContext *redisAsyncConnect(const char *ip, int port);
105 redisAsyncContext *redisAsyncConnectBind(const char *ip, int port, const char *source_addr);
H A Dhiredis.c1023 redisContext *redisConnect(const char *ip, int port) { in redisConnect() argument
1031 redisContextConnectTcp(c,ip,port,NULL); in redisConnect()
1035 redisContext *redisConnectWithTimeout(const char *ip, int port, const struct timeval tv) { in redisConnectWithTimeout() argument
1043 redisContextConnectTcp(c,ip,port,&tv); in redisConnectWithTimeout()
1047 redisContext *redisConnectNonBlock(const char *ip, int port) { in redisConnectNonBlock() argument
1055 redisContextConnectTcp(c,ip,port,NULL); in redisConnectNonBlock()
1059 redisContext *redisConnectBindNonBlock(const char *ip, int port, in redisConnectBindNonBlock() argument
1063 redisContextConnectBindTcp(c,ip,port,NULL,source_addr); in redisConnectBindNonBlock()
H A Dasync.c150 redisAsyncContext *redisAsyncConnect(const char *ip, int port) { in redisAsyncConnect() argument
154 c = redisConnectNonBlock(ip,port); in redisAsyncConnect()
168 redisAsyncContext *redisAsyncConnectBind(const char *ip, int port, in redisAsyncConnectBind() argument
170 redisContext *c = redisConnectBindNonBlock(ip,port,source_addr); in redisAsyncConnectBind()
H A DREADME.md34 redisContext *redisConnect(const char *ip, int port);
/redis-3.2.3/deps/lua/src/
H A Dlmathlib.c97 double ip; in math_modf() local
98 double fp = modf(luaL_checknumber(L, 1), &ip); in math_modf()
99 lua_pushnumber(L, ip); in math_modf()
/redis-3.2.3/deps/jemalloc/src/
H A Dprof.c338 void *ip; in prof_unwind_callback() local
342 ip = (void *)_Unwind_GetIP(context); in prof_unwind_callback()
343 if (ip == NULL) in prof_unwind_callback()
345 data->bt->vec[data->bt->len] = ip; in prof_unwind_callback()
/redis-3.2.3/
H A D00-RELEASENOTES85 1. Now slaves support the slave-announce-ip and slave-announce-port options.
120 Ability of slave to announce arbitrary ip/port to master.