Class: Pitchfork::Flock
- Inherits:
-
Object
- Object
- Pitchfork::Flock
- Defined in:
- lib/pitchfork/flock.rb
Constant Summary collapse
- Error =
Class.new(StandardError)
Instance Method Summary collapse
- #at_fork ⇒ Object
-
#initialize(name) ⇒ Flock
constructor
A new instance of Flock.
- #to_io ⇒ Object
- #try_lock ⇒ Object
- #unlink ⇒ Object
- #unlock ⇒ Object
Constructor Details
#initialize(name) ⇒ Flock
Returns a new instance of Flock.
7 8 9 10 11 12 13 |
# File 'lib/pitchfork/flock.rb', line 7 def initialize(name) @name = name @file = Tempfile.create([name, '.lock']) @file.write("#{Process.pid}\n") @file.flush @owned = false end |
Instance Method Details
#at_fork ⇒ Object
15 16 17 18 19 20 |
# File 'lib/pitchfork/flock.rb', line 15 def at_fork @owned = false @file.close @file = File.open(@file.path, "w") nil end |
#to_io ⇒ Object
22 23 24 |
# File 'lib/pitchfork/flock.rb', line 22 def to_io @file end |
#try_lock ⇒ Object
32 33 34 35 36 37 38 39 40 |
# File 'lib/pitchfork/flock.rb', line 32 def try_lock raise Error, "Pitchfork::Flock(#{@name}) trying to lock an already owned lock" if @owned if @file.flock(File::LOCK_EX | File::LOCK_NB) @owned = true else false end end |
#unlink ⇒ Object
26 27 28 29 30 |
# File 'lib/pitchfork/flock.rb', line 26 def unlink File.unlink(@file.path) rescue Errno::ENOENT false end |
#unlock ⇒ Object
42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/pitchfork/flock.rb', line 42 def unlock raise Error, "Pitchfork::Flock(#{@name}) trying to unlock a non-owned lock" unless @owned begin if @file.flock(File::LOCK_UN) @owned = false true else false end end end |