Lines Matching defs:asyncio

1 """Tests for asyncio/timeouts.py"""
6 import asyncio
7 from asyncio import tasks
11     asyncio.set_event_loop_policy(None)
18             async with asyncio.timeout(0.01) as cm:
19                 await asyncio.sleep(10)
23         loop = asyncio.get_running_loop()
27             async with asyncio.timeout_at(deadline) as cm:
28                 await asyncio.sleep(10)
33         loop = asyncio.get_running_loop()
37             async with asyncio.timeout_at(deadline) as cm1:
40                     async with asyncio.timeout_at(deadline) as cm2:
41                         await asyncio.sleep(10)
42                 except asyncio.CancelledError:
50         loop = asyncio.get_running_loop()
53             async with asyncio.timeout(0.01):
55                     await asyncio.sleep(10)
56                 except asyncio.CancelledError:
62         loop = asyncio.get_running_loop()
64         async with asyncio.timeout(10) as cm:
65             await asyncio.sleep(0.01)
74         loop = asyncio.get_running_loop()
76         async with asyncio.timeout(None) as cm:
77             await asyncio.sleep(0.01)
86         loop = asyncio.get_running_loop()
88         async with asyncio.timeout_at(None) as cm:
89             await asyncio.sleep(0.01)
98         loop = asyncio.get_running_loop()
101             async with asyncio.timeout(0) as cm:
102                 await asyncio.sleep(10)
110         loop = asyncio.get_running_loop()
113             async with asyncio.timeout(0) as cm:
114                 await asyncio.sleep(0)
122         loop = asyncio.get_running_loop()
125             async with asyncio.timeout(-11) as cm:
126                 await asyncio.sleep(0)
135             async with asyncio.timeout(0.01) as cm:
142                 await asyncio.sleep(1)
146             async with asyncio.timeout(0.01):
150         with self.assertRaises(asyncio.CancelledError):
151             async with asyncio.timeout(10) as cm:
152                 asyncio.current_task().cancel()
153                 await asyncio.sleep(10)
159                 async with asyncio.timeout(0.001):
160                     await asyncio.sleep(10)
162         task = asyncio.create_task(outer())
169             async with asyncio.timeout(0.002):
171                     async with asyncio.timeout(0.1):
174                         await asyncio.sleep(1)
179         loop = asyncio.get_running_loop()
184             async with asyncio.timeout(0.1):  # (1)
186                     async with asyncio.timeout(0.01):  # (2)
189                         await asyncio.sleep(1)
191                 await asyncio.sleep(10) # This sleep should be interrupted by (1)
196         loop = asyncio.get_running_loop()
202             async with asyncio.timeout_at(deadline1) as cm:
204                 await asyncio.sleep(50)
206         task = asyncio.create_task(f())
217         with self.assertRaises(asyncio.CancelledError):
222         async with asyncio.timeout(10) as cm:
227             async with asyncio.timeout(0.01) as cm:
228                 await asyncio.sleep(10)
232         async with asyncio.timeout(10) as cm:
233             await asyncio.sleep(0)
238         async with asyncio.timeout(None) as cm:
243             async with asyncio.timeout(0.01):
245                     await asyncio.sleep(1)
248                         async with asyncio.timeout(0.01):
249                             await asyncio.sleep(10)
253             asyncio.current_task().cancel()
254             await asyncio.sleep(1)  # work which will be cancelled
255         except asyncio.CancelledError:
259                 async with asyncio.timeout(0.0):
260                     await asyncio.sleep(1)  # some cleanup
264             asyncio.current_task().cancel()
265             await asyncio.sleep(1)  # work which will be cancelled
266         except asyncio.CancelledError:
269             with self.assertRaises(asyncio.CancelledError):
270                 async with asyncio.timeout(1.0):
271                     asyncio.current_task().cancel()
272                     await asyncio.sleep(2)  # some cleanup
275         with self.assertRaises(asyncio.TimeoutError) as exc:
276             async with asyncio.timeout(0):
277                 await asyncio.sleep(1)
279         assert isinstance(cause, asyncio.CancelledError)