Contents

#!/usr/bin/env ruby

Dir.chdir(File.dirname(__FILE__)) { (s = lambda { |f| File.exist?(f) ? require(f) : Dir.chdir("..") { s.call(f) } }).call("spec/spec_helper.rb") }

require 'puppet/util/file_locking'

describe Puppet::Util::FileLocking do
    it "should be able to keep file corruption from happening when there are multiple writers" do
        file = Tempfile.new("puppetspec")
        file.close!()
        file = file.path
        data = {:a => :b, :c => "A string", :d => "another string", :e => %w{an array of strings}}
        File.open(file, "w") { |f| f.puts YAML.dump(data) }

        threads = []
        sync = Sync.new
        9.times { |a|
            threads << Thread.new {
                9.times { |b|
                    sync.synchronize(Sync::SH) {
                        Puppet::Util::FileLocking.readlock(file) { |f|
                            YAML.load(f.read).should == data
                        }
                    }
                    sleep 0.01
                    sync.synchronize(Sync::EX) {
                        Puppet::Util::FileLocking.writelock(file) { |f|
                            f.puts YAML.dump(data)
                        }
                    }
                }
            }
        }
        threads.each { |th| th.join }
    end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
puppet-0.24.9	spec/integration/util/file_locking.rb
puppet-0.24.7	spec/integration/util/file_locking.rb
puppet-0.24.8	spec/integration/util/file_locking.rb