languages/cpython
languages/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython synced 2024-10-14 19:55:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

bpo-41804: Enhance test_epoll.test_control_and_wait() (GH-23795)

Browse source 
Use shorter timeout and replace send() with sendall().
This commit is contained in:
Victor Stinner 2020-12-16 11:16:25 +01:00 committed by GitHub
parent b32d8b4f9b
commit 79782fe4f8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
Lib/test/test_epoll.py
View file

@ -160,44 +160,42 @@ def test_fromfd(self):
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()