/usr/share/doc/liblockfile-ruby/examples/a.rb is in liblockfile-ruby 1.4.3-2.1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 | #!/usr/bin/env ruby
$:.unshift '../lib'
#
# puts this script in an nfs located directory and run from a couple of nodes at
# once. the list should appear ordered from either host - note that times may
# not be ordered depending on the system clocks
#
#
# builtin
#
require 'socket'
require 'pstore'
#
# do what we can to invalidate any nfs caching
#
def timestamp time = Time.now
#{{{
usec = "#{ time.usec }"
usec << ('0' * (6 - usec.size)) if usec.size < 6
time.strftime('%Y-%m-%d %H:%M:%S.') << usec
#}}}
end
def hostname
#{{{
@__hostname__ ||= Socket::gethostname
#}}}
end
def tmpnam dir = Dir.tmpdir, seed = File.basename($0)
#{{{
pid = Process.pid
path = "%s_%s_%s_%s_%d" %
[hostname, seed, pid, timestamp.gsub(/\s+/o,'_'), rand(101010)]
File.join(dir, path)
#}}}
end
def uncache file
#{{{
refresh = nil
begin
is_a_file = File === file
path = (is_a_file ? file.path : file.to_s)
stat = (is_a_file ? file.stat : File.stat(file.to_s))
refresh = tmpnam(File.dirname(path))
File.link path, refresh rescue File.symlink path, refresh
File.chmod stat.mode, path
File.utime stat.atime, stat.mtime, path
ensure
begin
File.unlink refresh if refresh
rescue Errno::ENOENT
end
end
#}}}
end
#
# raa - http://raa.ruby-lang.org/project/lockfile/
#
require 'lockfile'
pstore = PStore.new 'test.db'
timeout = 60
max_age = 8
refresh = 2
debug = false
lockfile = Lockfile.new 'test.lock',
:timeout => timeout,
:max_age => max_age,
:refresh => refresh,
:debug => debug
#
# flock throws ENOLCK on nfs file systems in newer linux kernels
# plus we want to show that lockfile alone can do the locking
#
class File
def flock(*args,&block);true;end
end
#
# if locking does not work this loop will blow up (Marshal load error) or appear
# un-ordered. actually it will eventually blow up due to nfs caching - but that
# is not the fault of the lockfile class! for the most part it is a simply demo
# of locking. the file will never become corrupt, it just will be unreadable at
# times due to kernel caching.
#
loop do
lockfile.lock do
uncache pstore.path
pstore.transaction do
#
# get/update list
#
pstore[:list] = [] unless pstore.root? :list
list = pstore[:list]
tuple = [list.size, hostname, Time.now.to_f]
list << tuple
#
# show last 16 elements
#
puts '---'
list[-([list.size, 16].min)..-1].each{|tuple| p tuple}
puts '---'
#
# keep it a reasonable size
#
list.shift while list.size > 1024
#
# write back updates
#
pstore[:list] = list
end
end
sleep 1
end
|