lib/dmtest/device-mapper/interface.rb - main - githubmirror/device-mapper-test-suite

lib/dmtest/device-mapper/interface.rb

83 строки2 KB

Joe Thornber

Fix race in event_tracker.

12 мар 2014, 17:59

12 мар 2014, 17:59f9c0c8e

require 'dmtest/process'
require 'pathname'

module DM
  class DMInterface
    def create(path)
      ProcessControl.run("dmsetup create #{strip(path)} --notable")
    end

    # FIXME: duplication
    def load(path, table)
      Utils::with_temp_file('dm-table') do |f|
        debug "writing table: #{table.to_embed}"
        f.puts table.to_s
        f.flush
        ProcessControl.run("dmsetup load #{strip(path)} #{f.path}")
      end
    end

    def load_ro(path, table)
      Utils::with_temp_file('dm-table') do |f|
        debug "writing table: #{table.to_embed}"
        f.puts table.to_s
        f.flush
        ProcessControl.run("dmsetup load --readonly #{strip(path)} #{f.path}")
      end
    end

    def suspend(path)
      ProcessControl.run("dmsetup suspend #{strip(path)}")
    end

    def suspend_noflush(path)
      ProcessControl.run("dmsetup suspend --noflush #{strip(path)}")
    end

    def resume(path)
      ProcessControl.run("dmsetup resume #{strip(path)}")
    end

    def remove(path)
      # FIXME: lift this retry?
      Utils.retry_if_fails(5.0) do
        ProcessControl.run("dmsetup remove #{strip(path)}")
      end
    end

    def message(path, sector, *args)
      ProcessControl.run("dmsetup message #{strip(path)} #{sector} #{args.join(' ')}")
    end

    def status(path, *args)
      ProcessControl.run("dmsetup status #{args.join(' ')} #{strip(path)}")
    end

    def table(path)
      ProcessControl.run("dmsetup table #{strip(path)}")
    end

    def info(path)
      ProcessControl.run("dmsetup info #{strip(path)}")
    end

    def wait(path, event_nr)
      output = ProcessControl.run("dmsetup wait -v #{strip(path)} #{event_nr}")
      extract_event_nr(output)
    end

    def extract_event_nr(output)
      m = output.match(/Event number:[ \t]*([0-9]+)/)
      if m.nil?
        raise "Couldn't find event number for dm device"
      end

      m[1].to_i
    end

    private
    def strip(path)
      Pathname(path).basename.to_s
    end
  end
end