Sha256: 93630a7d03dc2cebace9f0de9ff5e4d9f5f680c8138fdfc6c1e84c274c24177e

Contents?: true

Size: 1.29 KB

Versions: 6

Compression:

Stored size: 1.29 KB

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")
        filepath = file.path
        file.close!()
        file = filepath
        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

6 entries across 6 versions & 1 rubygems

Version Path
puppet-0.25.5 spec/integration/util/file_locking.rb
puppet-0.25.4 spec/integration/util/file_locking.rb
puppet-0.25.3 spec/integration/util/file_locking.rb
puppet-0.25.2 spec/integration/util/file_locking.rb
puppet-0.25.1 spec/integration/util/file_locking.rb
puppet-0.25.0 spec/integration/util/file_locking.rb