Skip to content

Commit 39f4654

Browse files
committed
Revert "fix connection backlog offset - updated tests - added tests for 0 and 1"
This reverts commit 2c603b9.
1 parent 2c603b9 commit 39f4654

File tree

2 files changed

+3
-15
lines changed

2 files changed

+3
-15
lines changed

Lib/asyncio/selector_events.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ def _accept_connection(
173173
# listening socket has triggered an EVENT_READ. There may be multiple
174174
# connections waiting for an .accept() so it is called in a loop.
175175
# See https://bugs.python.org/issue27906 for more details.
176-
for _ in range(backlog + 1):
176+
for _ in range(backlog):
177177
try:
178178
conn, addr = sock.accept()
179179
if self._debug:

Lib/test/test_asyncio/test_selector_events.py

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -347,18 +347,6 @@ def test_process_events_write_cancelled(self):
347347
selectors.EVENT_WRITE)])
348348
self.loop._remove_writer.assert_called_with(1)
349349

350-
def test_accept_connection_zero_one(self):
351-
for backlog in [0, 1]:
352-
sock = mock.Mock()
353-
sock.accept.return_value = (mock.Mock(), mock.Mock())
354-
with self.subTest(backlog):
355-
mock_obj = mock.patch.object
356-
with mock_obj(self.loop, '_accept_connection2') as accept2_mock:
357-
self.loop._accept_connection(
358-
mock.Mock(), sock, backlog=backlog)
359-
self.loop.run_until_complete(asyncio.sleep(0))
360-
self.assertEqual(sock.accept.call_count, backlog + 1)
361-
362350
def test_accept_connection_multiple(self):
363351
sock = mock.Mock()
364352
sock.accept.return_value = (mock.Mock(), mock.Mock())
@@ -374,7 +362,7 @@ def test_accept_connection_multiple(self):
374362
self.loop._accept_connection(
375363
mock.Mock(), sock, backlog=backlog)
376364
self.loop.run_until_complete(asyncio.sleep(0))
377-
self.assertEqual(sock.accept.call_count, backlog + 1)
365+
self.assertEqual(sock.accept.call_count, backlog)
378366

379367
def test_accept_connection_skip_connectionabortederror(self):
380368
sock = mock.Mock()
@@ -400,7 +388,7 @@ def mock_sock_accept():
400388
# as in test_accept_connection_multiple avoid task pending
401389
# warnings by using asyncio.sleep(0)
402390
self.loop.run_until_complete(asyncio.sleep(0))
403-
self.assertEqual(sock.accept.call_count, backlog + 1)
391+
self.assertEqual(sock.accept.call_count, backlog)
404392

405393
class SelectorTransportTests(test_utils.TestCase):
406394

0 commit comments

Comments
 (0)