lib/zk/client/threaded.rb in zk-1.4.1 vs lib/zk/client/threaded.rb in zk-1.4.2
- old
+ new
@@ -178,9 +178,10 @@
old_cnx, @cnx = @cnx, nil
old_cnx.close! if old_cnx # && !old_cnx.closed?
else
logger.debug { "#{self.class}##{__method__} not reopening, no fork detected" }
+ @cnx.reopen(timeout)
end
@mutex.synchronize { @close_requested = false }
connect
state