mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
107 lines
2.4 KiB
Ruby
107 lines
2.4 KiB
Ruby
|
require File.expand_path('../../../spec_helper', __FILE__)
|
||
|
|
||
|
describe "File#flock" do
|
||
|
before :each do
|
||
|
ScratchPad.record []
|
||
|
|
||
|
@name = tmp("flock_test")
|
||
|
touch(@name)
|
||
|
|
||
|
@file = File.open @name, "w+"
|
||
|
end
|
||
|
|
||
|
after :each do
|
||
|
@file.flock File::LOCK_UN
|
||
|
@file.close
|
||
|
|
||
|
rm_r @name
|
||
|
end
|
||
|
|
||
|
it "exclusively locks a file" do
|
||
|
@file.flock(File::LOCK_EX).should == 0
|
||
|
@file.flock(File::LOCK_UN).should == 0
|
||
|
end
|
||
|
|
||
|
it "non-exclusively locks a file" do
|
||
|
@file.flock(File::LOCK_SH).should == 0
|
||
|
@file.flock(File::LOCK_UN).should == 0
|
||
|
end
|
||
|
|
||
|
it "returns false if trying to lock an exclusively locked file" do
|
||
|
@file.flock File::LOCK_EX
|
||
|
|
||
|
ruby_exe(<<-END_OF_CODE, escape: true).should == "false"
|
||
|
File.open('#{@name}', "w") do |f2|
|
||
|
print f2.flock(File::LOCK_EX | File::LOCK_NB).to_s
|
||
|
end
|
||
|
END_OF_CODE
|
||
|
end
|
||
|
|
||
|
it "blocks if trying to lock an exclusively locked file" do
|
||
|
@file.flock File::LOCK_EX
|
||
|
|
||
|
out = ruby_exe(<<-END_OF_CODE, escape: true)
|
||
|
running = false
|
||
|
|
||
|
t = Thread.new do
|
||
|
File.open('#{@name}', "w") do |f2|
|
||
|
puts "before"
|
||
|
running = true
|
||
|
f2.flock(File::LOCK_EX)
|
||
|
puts "after"
|
||
|
end
|
||
|
end
|
||
|
|
||
|
Thread.pass until running
|
||
|
Thread.pass while t.status and t.status != "sleep"
|
||
|
sleep 0.1
|
||
|
|
||
|
t.kill
|
||
|
t.join
|
||
|
END_OF_CODE
|
||
|
|
||
|
out.should == "before\n"
|
||
|
end
|
||
|
|
||
|
it "returns 0 if trying to lock a non-exclusively locked file" do
|
||
|
@file.flock File::LOCK_SH
|
||
|
|
||
|
File.open(@name, "r") do |f2|
|
||
|
f2.flock(File::LOCK_SH | File::LOCK_NB).should == 0
|
||
|
f2.flock(File::LOCK_UN).should == 0
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
|
||
|
platform_is :solaris do
|
||
|
describe "File#flock on Solaris" do
|
||
|
before :each do
|
||
|
@name = tmp("flock_test")
|
||
|
touch(@name)
|
||
|
|
||
|
@read_file = File.open @name, "r"
|
||
|
@write_file = File.open @name, "w"
|
||
|
end
|
||
|
|
||
|
after :each do
|
||
|
@read_file.flock File::LOCK_UN
|
||
|
@read_file.close
|
||
|
@write_file.flock File::LOCK_UN
|
||
|
@write_file.close
|
||
|
rm_r @name
|
||
|
end
|
||
|
|
||
|
it "fails with EBADF acquiring exclusive lock on read-only File" do
|
||
|
lambda do
|
||
|
@read_file.flock File::LOCK_EX
|
||
|
end.should raise_error(Errno::EBADF)
|
||
|
end
|
||
|
|
||
|
it "fails with EBADF acquiring shared lock on read-only File" do
|
||
|
lambda do
|
||
|
@write_file.flock File::LOCK_SH
|
||
|
end.should raise_error(Errno::EBADF)
|
||
|
end
|
||
|
end
|
||
|
end
|