lib/aerospike/cluster/cluster.rb in aerospike-1.0.12 vs lib/aerospike/cluster/cluster.rb in aerospike-2.0.0
- old
+ new
@@ -210,11 +210,11 @@
private
def launch_tend_thread
@tend_thread = Thread.new do
- abort_on_exception = false
+ Thread.current.abort_on_exception = false
while true
begin
tend
sleep(@tend_interval / 1000.0)
rescue => e
@@ -323,12 +323,12 @@
end
def update_cluster_features
# Cluster supports features that are supported by all nodes
- @features.update do |cluster_features|
- node_featues = self.nodes.map(&:features)
- cluster_features.replace(node_featues.reduce(&:intersection))
+ @features.update do
+ node_features = self.nodes.map(&:features)
+ node_features.reduce(&:intersection) || Set.new
end
end
def notify_cluster_config_changed
listeners = @cluster_config_change_listeners.get