diff options
Diffstat (limited to 'test/test_queue.rb')
| -rw-r--r-- | test/test_queue.rb | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/test/test_queue.rb b/test/test_queue.rb index 6d61aef..cdb9ade 100644 --- a/test/test_queue.rb +++ b/test/test_queue.rb @@ -23,8 +23,8 @@ class TestQueue < Testcase def r.yahns_step begin case read_nonblock(11) - when "delete" - return :delete + when "ignore" + return :ignore end rescue Errno::EAGAIN return :wait_readable @@ -38,13 +38,16 @@ class TestQueue < Testcase @q.spawn_worker_threads(@logger, 1, 1) Thread.pass until r.nread == 0 - w.write("delete") + assert_equal 1, @fdmap.size + w.write("ignore") Thread.pass until r.nread == 0 Thread.pass until @fdmap.size == 0 - # should not raise - @q.queue_add(r, Yahns::Queue::QEV_RD) + assert_raises(Errno::EEXIST) { + @q.queue_add(r, Yahns::Queue::QEV_RD) + } assert_equal 1, @fdmap.size + @q.epoll_ctl(SleepyPenguin::Epoll::CTL_MOD, r, Yahns::Queue::QEV_RD) w.close Thread.pass until @fdmap.size == 0 end |