lib/aerospike/cluster/cluster.rb in aerospike-1.0.7 vs lib/aerospike/cluster/cluster.rb in aerospike-1.0.8

@@ -33,11 +33,11 @@
       @connection_timeout = policy.timeout
       @aliases = {}
       @cluster_nodes = []
       @partition_write_map = {}
       @node_index = Atomic.new(0)
-      @closed = Atomic.new(false)
+      @closed = Atomic.new(true)
       @mutex = Mutex.new
 
       # setup auth info for cluster
       if policy.requires_authentication
         @user = policy.user
@@ -268,9 +268,11 @@
           thr.join
         end
       rescue Timeout::Error
         thr.kill if thr.alive?
       end
+
+      @closed.value = false if @cluster_nodes.length > 0
 
     end
 
     def set_partitions(part_map)
       @mutex.synchronize do