Sha256: c3a27f2f82d2576e71663938caed744e7b88f23bc5e00daec7cfa92ac0e8f7e8
Contents?: true
Size: 1.64 KB
Versions: 96
Compression:
Stored size: 1.64 KB
Contents
require 'thread'
require 'sync'
# Gotten from:
# http://path.berkeley.edu/~vjoel/ruby/solaris-bug.rb
# Extensions to the File class for exception-safe file locking in a
# environment with multiple user threads.
# This is here because closing a file on solaris unlocks any locks that
# other threads might have. So we have to make sure that only the last
# reader thread closes the file.
#
# The hash maps inode number to a count of reader threads
$reader_count = Hash.new(0)
class File
# Get an exclusive (i.e., write) lock on the file, and yield to the block.
# If the lock is not available, wait for it without blocking other ruby
# threads.
def lock_exclusive
if Thread.list.size == 1
flock(LOCK_EX)
else
# ugly hack because waiting for a lock in a Ruby thread blocks the
# process
period = 0.001
until flock(LOCK_EX|LOCK_NB)
sleep period
period *= 2 if period < 1
end
end
yield self
ensure
flush
flock(LOCK_UN)
end
# Get a shared (i.e., read) lock on the file, and yield to the block.
# If the lock is not available, wait for it without blocking other ruby
# threads.
def lock_shared
if Thread.list.size == 1
flock(LOCK_SH)
else
# ugly hack because waiting for a lock in a Ruby thread blocks the
# process
period = 0.001
until flock(LOCK_SH|LOCK_NB)
sleep period
period *= 2 if period < 1
end
end
yield self
ensure
Thread.exclusive {flock(LOCK_UN) if $reader_count[self.stat.ino] == 1}
## for solaris, no need to unlock here--closing does it
## but this has no effect on the bug
end
end
Version data entries
96 entries across 96 versions & 4 rubygems