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 ace0c6f commit 37994f5Copy full SHA for 37994f5
lib/mongo/cluster.rb
@@ -151,9 +151,8 @@ def elect_primary!(description)
151
def remove(host)
152
log_debug([ "#{host} being removed from the cluster." ])
153
address = Address.new(host)
154
- removed_servers = @servers_update.synchronize do
155
- @servers.reject!{ |server| server.address == address }
156
- end
+ removed_servers = @servers.select { |s| s.address == address }
+ @servers_update.synchronize { @servers = @servers - removed_servers }
157
removed_servers.each{ |server| server.disconnect! } if removed_servers
158
@addresses_update.synchronize do
159
@addresses.reject!{ |addr| addr == address }
0 commit comments