bpo-41804: Enhance test_epoll.test_control_and_wait() (GH-23795)
Use shorter timeout and replace send() with sendall().
(cherry picked from commit 79782fe4f8
)
Co-authored-by: Victor Stinner <vstinner@python.org>
This commit is contained in:
parent
2fba8445a4
commit
e962e3ad22
|
@ -160,44 +160,42 @@ class TestEPoll(unittest.TestCase):
|
|||
self.fail("epoll on closed fd didn't raise EBADF")
|
||||
|
||||
def test_control_and_wait(self):
|
||||
# create the epoll object
|
||||
client, server = self._connected_pair()
|
||||
|
||||
ep = select.epoll(16)
|
||||
ep.register(server.fileno(),
|
||||
select.EPOLLIN | select.EPOLLOUT | select.EPOLLET)
|
||||
ep.register(client.fileno(),
|
||||
select.EPOLLIN | select.EPOLLOUT | select.EPOLLET)
|
||||
|
||||
# EPOLLOUT
|
||||
now = time.monotonic()
|
||||
events = ep.poll(1, 4)
|
||||
then = time.monotonic()
|
||||
self.assertFalse(then - now > 0.1, then - now)
|
||||
|
||||
events.sort()
|
||||
expected = [(client.fileno(), select.EPOLLOUT),
|
||||
(server.fileno(), select.EPOLLOUT)]
|
||||
expected.sort()
|
||||
self.assertEqual(sorted(events), sorted(expected))
|
||||
|
||||
self.assertEqual(events, expected)
|
||||
|
||||
events = ep.poll(timeout=2.1, maxevents=4)
|
||||
# no event
|
||||
events = ep.poll(timeout=0.1, maxevents=4)
|
||||
self.assertFalse(events)
|
||||
|
||||
client.send(b"Hello!")
|
||||
server.send(b"world!!!")
|
||||
# send: EPOLLIN and EPOLLOUT
|
||||
client.sendall(b"Hello!")
|
||||
server.sendall(b"world!!!")
|
||||
|
||||
now = time.monotonic()
|
||||
events = ep.poll(1, 4)
|
||||
events = ep.poll(1.0, 4)
|
||||
then = time.monotonic()
|
||||
self.assertFalse(then - now > 0.01)
|
||||
|
||||
events.sort()
|
||||
expected = [(client.fileno(), select.EPOLLIN | select.EPOLLOUT),
|
||||
(server.fileno(), select.EPOLLIN | select.EPOLLOUT)]
|
||||
expected.sort()
|
||||
|
||||
self.assertEqual(events, expected)
|
||||
self.assertEqual(sorted(events), sorted(expected))
|
||||
|
||||
# unregister, modify
|
||||
ep.unregister(client.fileno())
|
||||
ep.modify(server.fileno(), select.EPOLLOUT)
|
||||
now = time.monotonic()
|
||||
|
|
Loading…
Reference in New Issue