summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xsrc/redis-trib.rb12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/redis-trib.rb b/src/redis-trib.rb
index cff0f360f..466a81137 100755
--- a/src/redis-trib.rb
+++ b/src/redis-trib.rb
@@ -50,14 +50,16 @@ end
class ClusterNode
def initialize(addr)
s = addr.split(":")
- if s.length != 2
- puts "Invalid node name #{addr}"
- exit 1
+ if s.length < 2
+ puts "Invalid IP or Port (given as #{addr}) - use IP:Port format"
+ exit 1
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
@info = {}
- @info[:host] = s[0]
- @info[:port] = s[1]
+ @info[:host] = ip
+ @info[:port] = port
@info[:slots] = {}
@info[:migrating] = {}
@info[:importing] = {}