@@ -1626,7 +1626,8 @@ def error_received(self, exc):
16261626 transport .sendto (second , addr )
16271627
16281628 loop .run_until_complete (
1629- asyncio .wait_for (protocol .error_received_event , 10 ))
1629+ asyncio .wait_for (protocol .error_received_event ,
1630+ support .SHORT_TIMEOUT ))
16301631 self .assertTrue (protocol .errors )
16311632 self .assertIsInstance (protocol .errors [0 ], OSError )
16321633
@@ -1699,7 +1700,8 @@ def error_received(self, exc):
16991700 # The 'extra' datagram sent from error_received() is delivered
17001701 # back to the same socket; waiting for it proves the write loop
17011702 # kept running instead of wedging or crashing.
1702- loop .run_until_complete (asyncio .wait_for (protocol .done , 10 ))
1703+ loop .run_until_complete (
1704+ asyncio .wait_for (protocol .done , support .SHORT_TIMEOUT ))
17031705
17041706 test_utils .run_until (
17051707 loop , lambda : transport .get_write_buffer_size () == 0 )
@@ -1759,7 +1761,8 @@ def connection_lost(self, exc):
17591761 transport .sendto (b'second' , addr )
17601762 transport .close ()
17611763
1762- loop .run_until_complete (asyncio .wait_for (protocol .lost , 10 ))
1764+ loop .run_until_complete (
1765+ asyncio .wait_for (protocol .lost , support .SHORT_TIMEOUT ))
17631766
17641767 test_utils .run_until (
17651768 loop , lambda : len (receiver .received ) >= 2 )
@@ -1806,7 +1809,8 @@ def connection_lost(self, exc):
18061809 transport .sendto (oversized , addr )
18071810 transport .close ()
18081811
1809- loop .run_until_complete (asyncio .wait_for (protocol .lost , 10 ))
1812+ loop .run_until_complete (
1813+ asyncio .wait_for (protocol .lost , support .SHORT_TIMEOUT ))
18101814 self .assertTrue (protocol .errors )
18111815
18121816 def test_datagram_write_error_close_from_callback (self ):
@@ -1847,7 +1851,8 @@ def connection_lost(self, exc):
18471851 transport .sendto (oversized , addr )
18481852 transport .sendto (oversized , addr )
18491853
1850- loop .run_until_complete (asyncio .wait_for (protocol .lost , 10 ))
1854+ loop .run_until_complete (
1855+ asyncio .wait_for (protocol .lost , support .SHORT_TIMEOUT ))
18511856 self .assertEqual (len (protocol .errors ), 2 )
18521857
18531858 def test_datagram_recvfrom_connection_reset_recovers (self ):
0 commit comments