lib/rbbt/persist.rb in rbbt-util-5.11.8 vs lib/rbbt/persist.rb in rbbt-util-5.11.9

- old
+ new

@@ -412,33 +412,37 @@ res = tee_stream(res, path, type, res.respond_to?(:callback)? res.callback : nil) ConcurrentStream.setup res do begin lockfile.unlock if lockfile.locked? rescue + Log.exception $! Log.warn "Lockfile exception: " << $!.message end end res.abort_callback = Proc.new do begin lockfile.unlock if lockfile.locked? rescue + Log.exception $! Log.warn "Lockfile exception: " << $!.message end end raise KeepLocked.new res when TSV::Dumper res = tee_stream(res.stream, path, type, res.respond_to?(:callback)? res.callback : nil) ConcurrentStream.setup res do begin lockfile.unlock rescue + Log.exception $! Log.warn "Lockfile exception: " << $!.message end end res.abort_callback = Proc.new do begin lockfile.unlock rescue + Log.exception $! Log.warn "Lockfile exception: " << $!.message end end raise KeepLocked.new res end