diff options
author | Eric Wong <normalperson@yhbt.net> | 2010-09-25 19:27:09 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2010-09-25 19:27:09 +0000 |
commit | 6296604742ed27ede171dad28f7d2bec2092d122 (patch) | |
tree | 3cfae42371acbf65b80a2357c8c63183edb49df7 | |
parent | e9e91bd9b9c571e9f3374a4b5aa44573f60c3d32 (diff) | |
download | sleepy_penguin-6296604742ed27ede171dad28f7d2bec2092d122.tar.gz |
Just to make sure edge-triggering works on newly created TCP connections.
-rw-r--r-- | test/test_epoll.rb | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/test/test_epoll.rb b/test/test_epoll.rb index 97d244c..a2f739f 100644 --- a/test/test_epoll.rb +++ b/test/test_epoll.rb @@ -13,6 +13,33 @@ class TestEpoll < Test::Unit::TestCase @ep = Epoll.new end + def test_tcp_connect_nonblock_edge + epflags = Epoll::OUT | Epoll::ET + host = '127.0.0.1' + srv = TCPServer.new(host, 0) + port = srv.addr[1] + addr = Socket.pack_sockaddr_in(port, host) + sock = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0) + assert_raises(Errno::EINPROGRESS) { sock.connect_nonblock(addr) } + IO.select(nil, [ sock ], [sock ]) + @ep.add(sock, epflags) + tmp = [] + @ep.wait(1) { |flags, obj| tmp << [ flags, obj ] } + assert_equal [ [Epoll::OUT, sock] ], tmp + end + + def test_tcp_connect_edge + epflags = Epoll::OUT | Epoll::ET + host = '127.0.0.1' + srv = TCPServer.new(host, 0) + port = srv.addr[1] + sock = TCPSocket.new(host, port) + @ep.add(sock, epflags) + tmp = [] + @ep.wait(1) { |flags, obj| tmp << [ flags, obj ] } + assert_equal [ [Epoll::OUT, sock] ], tmp + end + def teardown assert_nothing_raised do @rd.close unless @rd.closed? |