Sha256: 78a959ea8590aca67a266a3a693c3b692655239fdab6b9c1de4aec33da0fda3c
Contents?: true
Size: 1.35 KB
Versions: 26
Compression:
Stored size: 1.35 KB
Contents
# tests the CZookeeper, obviously only available when running under MRI
require 'spec_helper'
if Module.const_defined?(:CZookeeper)
describe CZookeeper do
def pop_all_events
[].tap do |rv|
begin
rv << @event_queue.pop(non_blocking=true)
rescue ThreadError
end
end
end
def wait_until_connected(timeout=2)
wait_until(timeout) { @czk.state == ZookeeperConstants::ZOO_CONNECTED_STATE }
end
describe do
before do
@event_queue = ZookeeperCommon::QueueWithPipe.new
@czk = CZookeeper.new('localhost:2181', @event_queue)
end
after do
@czk.close rescue Exception
@event_queue.close rescue Exception
end
it %[should be in connected state within a reasonable amount of time] do
wait_until_connected.should be_true
end
describe :after_connected do
before do
wait_until_connected.should be_true
end
it %[should have a connection event after being connected] do
event = wait_until(2) { @event_queue.pop }
event.should be
event[:req_id].should == ZookeeperCommon::ZKRB_GLOBAL_CB_REQ
event[:type].should == ZookeeperConstants::ZOO_SESSION_EVENT
event[:state].should == ZookeeperConstants::ZOO_CONNECTED_STATE
end
end
end
end
end
Version data entries
26 entries across 26 versions & 2 rubygems