Contents

require File.expand_path(File.dirname(__FILE__) + '/spec_helper')

require_relative 'test/test1.rb'

describe DRbQS do
  before(:all) do
    @tasks = []
    5.times do |i|
      @tasks << DRbQS::Task.new(Test1.new, :echo, [i])
    end
    @process_id = fork do
      server = DRbQS::Server.new(:port => 13501)

      @tasks.each do |task|
        server.queue.add(task)
      end

      server.set_finish_hook do |serv|
        serv.exit
      end

      server.set_signal_trap
      server.start
      server.wait
    end
    sleep(1)

    @uri = 'druby://:13501'

    @manage = DRbQS::Manage.new(@uri)
  end

  it "should send exit signal" do
    lambda do
      @manage.send_exit_signal
    end.should_not raise_error
    lambda do
      i = 0
      while !Process.waitpid(@process_id, Process::WNOHANG)
        i += 1
        if i > 10
          Process.kill(:KILL, @process_id)
          raise "Server process does not finish."
        end
        sleep(1)
      end
    end.should_not raise_error
  end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
drbqs-0.0.6	spec/manage_spec.rb