@@ -40,7 +40,6 @@ def mock_socket_module():
40
40
41
41
m_socket .socket = mock .MagicMock ()
42
42
m_socket .socket .return_value = test_utils .mock_nonblocking_socket ()
43
- m_socket .getaddrinfo ._is_coroutine = False
44
43
45
44
return m_socket
46
45
@@ -1286,9 +1285,7 @@ def _test_create_connection_ip_addr(self, m_socket, allow_inet_pton):
1286
1285
sock = m_socket .socket .return_value
1287
1286
1288
1287
self .loop ._add_reader = mock .Mock ()
1289
- self .loop ._add_reader ._is_coroutine = False
1290
1288
self .loop ._add_writer = mock .Mock ()
1291
- self .loop ._add_writer ._is_coroutine = False
1292
1289
1293
1290
coro = self .loop .create_connection (asyncio .Protocol , '1.2.3.4' , 80 )
1294
1291
t , p = self .loop .run_until_complete (coro )
@@ -1330,9 +1327,7 @@ def test_create_connection_ipv6_scope(self, m_socket):
1330
1327
sock .family = socket .AF_INET6
1331
1328
1332
1329
self .loop ._add_reader = mock .Mock ()
1333
- self .loop ._add_reader ._is_coroutine = False
1334
1330
self .loop ._add_writer = mock .Mock ()
1335
- self .loop ._add_writer ._is_coroutine = False
1336
1331
1337
1332
coro = self .loop .create_connection (asyncio .Protocol , 'fe80::1%1' , 80 )
1338
1333
t , p = self .loop .run_until_complete (coro )
@@ -1359,9 +1354,7 @@ def test_create_connection_service_name(self, m_socket):
1359
1354
sock = m_socket .socket .return_value
1360
1355
1361
1356
self .loop ._add_reader = mock .Mock ()
1362
- self .loop ._add_reader ._is_coroutine = False
1363
1357
self .loop ._add_writer = mock .Mock ()
1364
- self .loop ._add_writer ._is_coroutine = False
1365
1358
1366
1359
for service , port in ('http' , 80 ), (b'http' , 80 ):
1367
1360
coro = self .loop .create_connection (asyncio .Protocol ,
@@ -1590,7 +1583,6 @@ class Err(OSError):
1590
1583
1591
1584
m_socket .getaddrinfo .return_value = [
1592
1585
(2 , 1 , 6 , '' , ('127.0.0.1' , 10100 ))]
1593
- m_socket .getaddrinfo ._is_coroutine = False
1594
1586
m_sock = m_socket .socket .return_value = mock .Mock ()
1595
1587
m_sock .bind .side_effect = Err
1596
1588
@@ -1601,7 +1593,6 @@ class Err(OSError):
1601
1593
@patch_socket
1602
1594
def test_create_datagram_endpoint_no_addrinfo (self , m_socket ):
1603
1595
m_socket .getaddrinfo .return_value = []
1604
- m_socket .getaddrinfo ._is_coroutine = False
1605
1596
1606
1597
coro = self .loop .create_datagram_endpoint (
1607
1598
MyDatagramProto , local_addr = ('localhost' , 0 ))
@@ -1835,7 +1826,6 @@ def getaddrinfo(*args, **kw):
1835
1826
m_socket .getaddrinfo = getaddrinfo
1836
1827
m_socket .socket .return_value .bind = bind = mock .Mock ()
1837
1828
self .loop ._add_reader = mock .Mock ()
1838
- self .loop ._add_reader ._is_coroutine = False
1839
1829
1840
1830
reuseport_supported = hasattr (socket , 'SO_REUSEPORT' )
1841
1831
coro = self .loop .create_datagram_endpoint (
0 commit comments