mirror of
https://github.com/fluencelabs/redis
synced 2025-03-19 17:10:50 +00:00
Merge pull request #2096 from mattsta/cluster-ipv6
Enable Cluster IPv6 Support
This commit is contained in:
commit
5a526c22cc
@ -178,7 +178,7 @@ int clusterLoadConfig(char *filename) {
|
|||||||
clusterAddNode(n);
|
clusterAddNode(n);
|
||||||
}
|
}
|
||||||
/* Address and port */
|
/* Address and port */
|
||||||
if ((p = strchr(argv[1],':')) == NULL) goto fmterr;
|
if ((p = strrchr(argv[1],':')) == NULL) goto fmterr;
|
||||||
*p = '\0';
|
*p = '\0';
|
||||||
memcpy(n->ip,argv[1],strlen(argv[1])+1);
|
memcpy(n->ip,argv[1],strlen(argv[1])+1);
|
||||||
n->port = atoi(p+1);
|
n->port = atoi(p+1);
|
||||||
|
@ -50,14 +50,16 @@ end
|
|||||||
class ClusterNode
|
class ClusterNode
|
||||||
def initialize(addr)
|
def initialize(addr)
|
||||||
s = addr.split(":")
|
s = addr.split(":")
|
||||||
if s.length != 2
|
if s.length < 2
|
||||||
puts "Invalid node name #{addr}"
|
puts "Invalid IP or Port (given as #{addr}) - use IP:Port format"
|
||||||
exit 1
|
exit 1
|
||||||
end
|
end
|
||||||
|
port = s.pop # removes port from split array
|
||||||
|
ip = s.join(":") # if s.length > 1 here, it's IPv6, so restore address
|
||||||
@r = nil
|
@r = nil
|
||||||
@info = {}
|
@info = {}
|
||||||
@info[:host] = s[0]
|
@info[:host] = ip
|
||||||
@info[:port] = s[1]
|
@info[:port] = port
|
||||||
@info[:slots] = {}
|
@info[:slots] = {}
|
||||||
@info[:migrating] = {}
|
@info[:migrating] = {}
|
||||||
@info[:importing] = {}
|
@info[:importing] = {}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user