Lines Matching refs:_core
7 from ... import _core
20 await _core.checkpoint()
21 except _core.Cancelled:
23 task_name = _core.current_task().name
25 assert _core.current_effective_deadline() == -inf
26 with pytest.raises(_core.Cancelled):
27 await _core.checkpoint()
30 assert "async_main" in _core.current_task().name
32 assert _core.current_effective_deadline() == inf
33 await _core.checkpoint()
45 await _core.wait_all_tasks_blocked()
80 _core.run(async_main)
93 await _core.cancel_shielded_checkpoint()
100 await _core.wait_all_tasks_blocked()
131 _core.run(async_main)
144 await _core.cancel_shielded_checkpoint()
170 _core.run(async_main)
187 runner = _core._run.GLOBAL_RUN_CONTEXT.runner
198 except _core.RunFinishedError: # pragma: no cover
203 token = _core.current_trio_token()
218 _core.run(async_main)
247 return _core.Abort.SUCCEEDED
251 async with _core.open_nursery() as nursery:
252 nursery.start_soon(_core.wait_task_rescheduled, abort_fn)
253 await _core.wait_all_tasks_blocked()
254 nursery.cancel_scope.deadline = _core.current_time()
270 await _core.cancel_shielded_checkpoint()
300 with pytest.raises(_core.Cancelled):
301 await _core.checkpoint()
310 await _core.wait_all_tasks_blocked()
317 _core.run(async_main)