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