about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2010-09-25 19:27:09 +0000
committerEric Wong <normalperson@yhbt.net>2010-09-25 19:27:09 +0000
commit6296604742ed27ede171dad28f7d2bec2092d122 (patch)
tree3cfae42371acbf65b80a2357c8c63183edb49df7
parente9e91bd9b9c571e9f3374a4b5aa44573f60c3d32 (diff)
downloadsleepy_penguin-6296604742ed27ede171dad28f7d2bec2092d122.tar.gz
Just to make sure edge-triggering works on newly
created TCP connections.
-rw-r--r--test/test_epoll.rb27
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?