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.
8 9 10 11 12 13 14 |
# File 'lib/pitchfork/flock.rb', line 8 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
16 17 18 19 20 21 |
# File 'lib/pitchfork/flock.rb', line 16 def at_fork @owned = false @file.close @file = File.open(@file.path, "w") nil end |
#to_io ⇒ Object
23 24 25 |
# File 'lib/pitchfork/flock.rb', line 23 def to_io @file end |
#try_lock ⇒ Object
33 34 35 36 37 38 39 40 41 |
# File 'lib/pitchfork/flock.rb', line 33 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
27 28 29 30 31 |
# File 'lib/pitchfork/flock.rb', line 27 def unlink File.unlink(@file.path) rescue Errno::ENOENT false end |
#unlock ⇒ Object
43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/pitchfork/flock.rb', line 43 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 |