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