We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d16b4c commit a86bfebCopy full SHA for a86bfeb
lib/mongo/cluster.rb
@@ -149,9 +149,8 @@ def elect_primary!(description)
149
def remove(host)
150
log_debug([ "#{host} being removed from the cluster." ])
151
address = Address.new(host)
152
- removed_servers = @servers_update.synchronize do
153
- @servers.reject!{ |server| server.address == address }
154
- end
+ removed_servers = @servers.select { |s| s.address == address }
+ @servers_update.synchronize { @servers = @servers - removed_servers }
155
removed_servers.each{ |server| server.disconnect! } if removed_servers
156
@addresses_update.synchronize do
157
@addresses.reject!{ |addr| addr == address }
0 commit comments