1
2
3
4
5
6
7
8
9
10
11
12
13
14
U
Z±døã@sxdZddlZddlmZmZmZmZmZmZm    Z    m
Z
ddl m Z m Z mZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.ddl/m0Z0dd    l1m2Z2dd
l3m4Z4dd l5m6Z6dd l7m8Z8dd l9m:Z:ej;dkrFddlm<Z<m=Z=m>Z>m?Z?m@Z@mAZAn,ej;dkrrej;dkrrddlmBZBmCZCmDZD[dS)zÚ
This namespace represents the core functionality that has to be built-in
and deal with private internal data structures. Things in this namespace
are publicly available in either trio, trio.lowlevel, or trio.testing.
éNé)ÚTrioInternalErrorÚRunFinishedErrorÚ
WouldBlockÚ    CancelledÚBusyResourceErrorÚClosedResourceErrorÚBrokenResourceErrorÚ EndOfChannel)Úenable_ki_protectionÚdisable_ki_protectionÚcurrently_ki_protected)ÚTaskÚ CancelScopeÚrunÚ open_nurseryÚ
checkpointÚ current_taskÚcurrent_effective_deadlineÚcheckpoint_if_cancelledÚTASK_STATUS_IGNOREDÚcurrent_statisticsÚcurrent_trio_tokenÚ
rescheduleÚremove_instrumentÚadd_instrumentÚ current_clockÚcurrent_root_taskÚspawn_system_taskÚ current_timeÚwait_all_tasks_blockedÚ wait_readableÚ wait_writableÚnotify_closingÚNurseryÚstart_guest_run)Úcancel_shielded_checkpointÚAbortÚwait_task_rescheduledÚ#temporarily_detach_coroutine_objectÚ#permanently_detach_coroutine_objectÚ"reattach_detached_coroutine_object)Ú    TrioToken)Ú
ParkingLot)ÚUnboundedQueue)ÚRunVar)Ústart_thread_soon)Ú    MockClockÚwin32)Úmonitor_completion_keyÚ current_iocpÚregister_with_iocpÚwait_overlappedÚwrite_overlappedÚreadinto_overlappedÚlinux)Úcurrent_kqueueÚmonitor_keventÚ wait_kevent)EÚ__doc__ÚsysÚ _exceptionsrrrrrrr    r
Z_kir r r Z_runrrrrrrrrrrrrrrrrrrr r!r"r#r$r%Z_trapsr&r'r(r)r*r+Z _entry_queuer,Z _parking_lotr-Z_unbounded_queuer.Ú_localr/Z _thread_cacher0Z _mock_clockr1Úplatformr3r4r5r6r7r8r:r;r<©rBrBúJd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_core/__init__.pyÚ<module>s ( h            "