Permalink
Browse files

_actually_ uniq the endpoints. derp.

  • Loading branch information...
1 parent aff0a9c commit 17b5aa548415acd7252ddc3783c117db78ffedd5 @b b committed Sep 7, 2010
Showing with 2 additions and 2 deletions.
  1. +2 −2 lib/cassandra/0.7/cassandra.rb
View
4 lib/cassandra/0.7/cassandra.rb
@@ -39,7 +39,7 @@ def cluster_name
end
def ring
- client.describe_ring(@keyspace).uniq
+ client.describe_ring(@keyspace)
end
def partitioner
@@ -154,7 +154,7 @@ def check_keyspace(ks = @keyspace)
def all_nodes
if @auto_discover_nodes && !@keyspace.eql?("system")
- ips = (new_client.describe_ring(@keyspace).map {|range| range.endpoints}).flatten
+ ips = (new_client.describe_ring(@keyspace).map {|range| range.endpoints}).flatten.uniq
port = @servers.first.split(':').last
ips.map{|ip| "#{ip}:#{port}" }
else

0 comments on commit 17b5aa5

Please sign in to comment.