* lib/cgi/session.rb (CGI::Session::FileStore::restore): use
lockfile for exclusive locks. a patch from <tommy AT tmtm.org>. [ruby-dev:32296] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@13927 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
4c56aaa162
commit
af2ab37334
@ -1,3 +1,9 @@
|
|||||||
|
Thu Nov 15 12:19:14 2007 Yukihiro Matsumoto <matz@ruby-lang.org>
|
||||||
|
|
||||||
|
* lib/cgi/session.rb (CGI::Session::FileStore::restore): use
|
||||||
|
lockfile for exclusive locks. a patch from <tommy AT tmtm.org>.
|
||||||
|
[ruby-dev:32296]
|
||||||
|
|
||||||
Thu Nov 15 12:14:53 2007 Yukihiro Matsumoto <matz@ruby-lang.org>
|
Thu Nov 15 12:14:53 2007 Yukihiro Matsumoto <matz@ruby-lang.org>
|
||||||
|
|
||||||
* tool/compile_prelude.rb (c_esc): need to escape closing brace.
|
* tool/compile_prelude.rb (c_esc): need to escape closing brace.
|
||||||
|
@ -397,8 +397,9 @@ class CGI
|
|||||||
unless @hash
|
unless @hash
|
||||||
@hash = {}
|
@hash = {}
|
||||||
begin
|
begin
|
||||||
|
lockf = File.open(@path+".lock", "r")
|
||||||
|
lockf.flock File::LOCK_SH
|
||||||
f = File.open(@path, 'r')
|
f = File.open(@path, 'r')
|
||||||
f.flock File::LOCK_SH
|
|
||||||
for line in f
|
for line in f
|
||||||
line.chomp!
|
line.chomp!
|
||||||
k, v = line.split('=',2)
|
k, v = line.split('=',2)
|
||||||
@ -406,6 +407,7 @@ class CGI
|
|||||||
end
|
end
|
||||||
ensure
|
ensure
|
||||||
f.close unless f.nil?
|
f.close unless f.nil?
|
||||||
|
lockf.close if lockf
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
@hash
|
@hash
|
||||||
@ -415,13 +417,17 @@ class CGI
|
|||||||
def update
|
def update
|
||||||
return unless @hash
|
return unless @hash
|
||||||
begin
|
begin
|
||||||
f = File.open(@path, File::CREAT|File::TRUNC|File::RDWR, 0600)
|
lockf = File.open(@path+".lock", File::CREAT|File::RDWR, 0600)
|
||||||
f.flock File::LOCK_EX
|
lockf.flock File::LOCK_EX
|
||||||
|
f = File.open(@path+".new", File::CREAT|File::TRUNC|File::WRONLY, 0600)
|
||||||
for k,v in @hash
|
for k,v in @hash
|
||||||
f.printf "%s=%s\n", CGI::escape(k), CGI::escape(String(v))
|
f.printf "%s=%s\n", CGI::escape(k), CGI::escape(String(v))
|
||||||
end
|
end
|
||||||
|
f.close
|
||||||
|
File.rename @path+".new", @path
|
||||||
ensure
|
ensure
|
||||||
f.close unless f.nil?
|
f.close if f and !f.closed?
|
||||||
|
lockf.close if lockf
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@ -432,6 +438,8 @@ class CGI
|
|||||||
|
|
||||||
# Close and delete the session's FileStore file.
|
# Close and delete the session's FileStore file.
|
||||||
def delete
|
def delete
|
||||||
|
File::unlink @path+".lock" rescue nil
|
||||||
|
File::unlink @path+".new" rescue nil
|
||||||
File::unlink @path
|
File::unlink @path
|
||||||
rescue Errno::ENOENT
|
rescue Errno::ENOENT
|
||||||
end
|
end
|
||||||
|
Loading…
x
Reference in New Issue
Block a user