Contents

require_relative '../test-util'

describe "Pione::TupleSpace::TupleSpaceServer" do
  before do
    DRb.start_service
    @server = TupleSpaceServer.new
    sleep 1
  end

  after do
    DRb.stop_service
  end

  it "should create be alive" do
    @server.should.alive
  end

  it "should count tuple size" do
    Tuple.define_format [:test, :sym]
    @server.write([:test, :a])
    @server.count_tuple([:test, nil]).should == 1
    @server.write([:test, :b])
    @server.count_tuple([:test, nil]).should == 2
    Tuple.delete_format(:test)
  end

  it "should count workers" do
    @server.current_task_worker_size.should == 0
    t1 = Tuple[:agent].new(agent_type: :task_worker, uuid: Util.generate_uuid)
    @server.write(t1)
    @server.current_task_worker_size.should == 1
    t2 = Tuple[:agent].new(agent_type: :task_worker, uuid: Util.generate_uuid)
    @server.write(t2)
    @server.current_task_worker_size.should == 2
    t3 = Tuple[:agent].new(agent_type: :task_worker, uuid: Util.generate_uuid)
    @server.write(t3)
    @server.current_task_worker_size.should == 3
    @server.take(t1)
    @server.current_task_worker_size.should == 2
    @server.take(t2)
    @server.current_task_worker_size.should == 1
    @server.take(t3)
    @server.current_task_worker_size.should == 0
  end

  it "should know worker resource" do
    @server.task_worker_resource.should == 1
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
pione-0.2.2	test/tuple-space/spec_tuple-space-server.rb
pione-0.2.1	test/tuple-space/spec_tuple-space-server.rb
pione-0.2.0	test/tuple-space/spec_tuple-space-server.rb
pione-0.1.4	test/tuple-space/spec_tuple-space-server.rb
pione-0.1.3	test/tuple-space/spec_tuple-space-server.rb
pione-0.1.2	test/tuple-space/spec_tuple-space-server.rb
pione-0.1.1	test/tuple-space/spec_tuple-space-server.rb
pione-0.1.0	test/tuple-space/spec_tuple-space-server.rb