Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
windows_events.cpython-314.pyc181 linesDownload Raw Back to __pycache__
1+
2��i����Rt^RIt]PR8wd	]!R4h^RIt^RIt^RIt^RIHt^RI	t	^RI3t4^RIt^RIt^RI
t
^RIt^RIHt^RIHt^RIHt^RIHt^R	IHt^R5IHt^RIHt^RIHt^R
IHtR(t]P6t]P8tRtRtRtRt !RR]PB4t"!RR]PB4t#!RR]#4t$!RR]#4t%!RR]&4t'!R R!]PP4t)!R"R]PT4t+!R#R4t,!R$R%]PZ4t.])t/!R&R]P`4t1!R'R]P`4t2]2t3]+t4R#))z.Selector and proactor event loops for Windows.N�win32z6win32 only)�partial)�events)�base_subprocess)�futures)�7exceptions)�proactor_events)�selector_events)�tasks)�
windows_utils)�logger�ProactorEventLoop�IocpProactor�_WindowsSelectorEventLoopPolicy�_WindowsProactorEventLoopPolicyi�i�g����MbP?g�������?c�xaa�]tRt^1toRtRR/V3RlltV3RltRtRV3RlltV3Rlt	V3R	lt8R9tVtV;t
#)�_OverlappedFuturez~Subclass of Future which represents an overlapped operation.10 11Cancelling it will immediately cancel the overlapped operation.12�loopNc�r<�\SV`VR7VP'dVPRWnR#��rN�����)�super�__init__�_source_traceback�_ov)�self�ovr�	__class__s&&$��Lib\asyncio\windows_events.pyr�_OverlappedFuture.__init__7s2���
���d��#��!�!�!��&�&�r�*���c��<�\SV`4pVPeOVPP'dRMRpVP	^RVRVPP13R
R24V#)N�pending�	completedzoverlapped=<z, �#x�>)r�14_repr_inforr#�insert�address�r�info�staters&  �rr'�_OverlappedFuture._repr_info=s_����w�!�#���8�8��!%���!1�!1�!1�I�{�E��K�K��\�%���4�8�8�3C�3C�B�2G�q�I�J��r!c�"�VPfR#VPP4RVnR# \dOpRRRTRT/pTP'dTPTR&TPPT4Rp?L]Rp?ii;i)N�messagez&Cancelling an overlapped future failed�	exception�future�source_traceback)r�cancel�OSErrorr�_loop�call_exception_handler)r�exc�contexts&  r�_cancel_overlapped�$_OverlappedFuture._cancel_overlappedDs����8�8���15	7��H�H�O�O�������	7��C��S��$��G�16�%�%�%�.2�.D�.D��*�+��J�J�-�-�g�6�6��	7�s�5�B�AB	�	Bc�D<�VP4\SV`	VR7#�)�msg)r9rr3�rr=rs&&�rr3�_OverlappedFuture.cancelTs ������!��w�~�#�~�&�&r!c�F<�\SV`V4VP4R#�N)r�
set_exceptionr9�rr0rs&&�rrB�_OverlappedFuture.set_exceptionXs���
���i�(����!r!c�4<�\SV`V4RVnR#rA)r�17set_resultr�r�resultrs&&�rrF�_OverlappedFuture.set_result\s���
���6�"���r!�rrA)�__name__�18__module__�__qualname__�__firstlineno__�__doc__rr'r9r3rBrF�__static_attributes__�__classdictcell__�
__classcell__�r�
__classdict__s@@rrr1s4�����19�4���� '�"��r!rc�aa�]tRt^atoRtRR/V3RlltRtV3RltRtRt	R
V3R	llt20V3R21ltV3RltRt
VtV;t#)�_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.rNc�<�\SV`VR7VP'dVPRWnW nW0nRVnR#)rTNr)rrrr�_handle�_wait_handle�_registered)rr�handle�wait_handlerrs&&&&$�rr�_BaseWaitHandleFuture.__init__dsI���
���d��#��!�!�!��&�&�r�*�����'�� ��r!c�f�\P!VP^4\P8H#��)�_winapi�WaitForSingleObjectrX�
WAIT_OBJECT_0�rs&r�_poll�_BaseWaitHandleFuture._pollrs)���+�+�D�L�L�!�<��%�%�&�	'r!c�.<�\SV`4pVPRVPR
24VPe,VP	4'dRMRpVPV4VP22e VPRVP23R
24V#)zhandle=r%�signaled�waitingzwait_handle=)rr'�appendrXrerYr*s&  �rr'� _BaseWaitHandleFuture._repr_infows~����w�!�#�����g�d�l�l�2�.�/�0��<�<�#�"&�*�*�,�,�J�I�E��K�K������(��K�K�,�t�'8�'8��&<�=�>��r!c��RVnR#rArJ)r�futs&&r�_unregister_wait_cb�)_BaseWaitHandleFuture._unregister_wait_cb�s����r!c��VP'gR#RVnVPpRVn\P!V4VPR4R# \dtpTP24\P8wdKRRRTRT/pTP'dTPTR&TPPT4Rp?R#Rp?L�Rp?ii;i�NFr/z$Failed to unregister the wait handler0r1r2)rZrY�_overlapped�UnregisterWaitr4�winerror�ERROR_IO_PENDINGrr5r6rn�rr\r7r8s&   r�_unregister_wait�&_BaseWaitHandleFuture._unregister_wait�s�������� ����'�'�� ���	��&�&�{�3�	
� � ��&���25	��|�|�{�;�;�;��E����d���26�)�)�)�26�2H�2H�G�.�/��27�28�1�1�'�:��<��29	�s�A�C�$8C�*C�Cc�D<�VP4\SV`	VR7#r<)rwrr3r>s&&�rr3�_BaseWaitHandleFuture.cancel�s ��������w�~�#�~�&�&r!c�F<�VP4\SV`	V4R#rA)rwrrBrCs&&�rrB�#_BaseWaitHandleFuture.set_exception�s�������
���i�(r!c�F<�VP4\SV`	V4R#rA)rwrrFrGs&&�rrF� _BaseWaitHandleFuture.set_result�s�������
���6�"r!)rXrrZrYrA)rKrLrMrNrOrrer'rnrwr3rBrFrPrQrRrSs@@rrVrVas<����<� �� �'�30��31'�0'�)�#�#r!rVc�\aa�]tRt^�toRtRR/V3RlltRtV3RltV3RltRt	Vt32V;t#)	�_WaitCancelFuturezgSubclass of Future which represents a wait for the cancellation of a33_WaitHandleFuture using an event.34rNc�8<�\SV`WW4R7RVnR#)rN)rr�_done_callback)rr�eventr\rrs&&&&$�rr�_WaitCancelFuture.__init__�s���
����K��;�"��r!c��\R4h)z'_WaitCancelFuture must not be cancelled)�RuntimeErrorrds&rr3�_WaitCancelFuture.cancel�s���D�E�Er!c�h<�\SV`V4VPeVPV4R#R#rA)rrFr�rGs&&�rrF�_WaitCancelFuture.set_result�s/���
���6�"����*�����%�+r!c�h<�\SV`V4VPeVPV4R#R#rA)rrBr�rCs&&�rrB�_WaitCancelFuture.set_exception�s/���
���i�(����*�����%�+r!)r�)rKrLrMrNrOrr3rFrBrPrQrRrSs@@rr�r��s+�����#�t�#�35F�&�36&�&r!r�c�Laa�]tRt^�toRR/V3RlltV3RltRtRtVtV;t	#)�_WaitHandleFuturerNc�<�\SV`WW5R7W@nRVn\P37!RRRR4VnRVnR#)rTNF)rr�	_proactor�_unregister_proactorrr�CreateEvent�_event�38_event_fut)rrr[r\�proactorrrs&&&&&$�rr�_WaitHandleFuture.__init__�sA���
����[��<�!��$(��!�!�-�-�d�D�%��F�����r!c��<�VPe/\P!VP4RVnRVnVPPVP4RVn\SV`!V4R#rA)	r�ra�CloseHandler�r��_unregisterrrrn)rrmrs&&�rrn�%_WaitHandleFuture._unregister_wait_cb�sY����;�;�"�������,��D�K�"�D�O�	
���"�"�4�8�8�,����
��#�C�(r!c��VP'gR#RVnVPpRVn\P!WP4VPPVPVP4VnR# \39dtpTP\P8wdKRRRTRT/pTP'dTPTR&TPPT4Rp?R#Rp?L�Rp?ii;irq)rZrYrr�UnregisterWaitExr�r4rtrurr5r6r��_wait_cancelrnr�rvs&   rrw�"_WaitHandleFuture._unregister_wait�s�������� ����'�'�� ���	��(�(��k�k�B��.�.�5�5�d�k�k�6:�6N�6N�P�����40	��|�|�{�;�;�;��E����d���41�)�)�)�26�2H�2H�G�.�/��42�43�1�1�'�:��<��44	�s� B�D�8D�*D�D)r�r�r�rZr�rY)45rKrLrMrNrrnrwrPrQrRrSs@@rr�r��s"�����$��)�$P�Pr!r�c�Fa�]tRt^�toRtRtRtRtRtRt	]	t46RtVtR#)	�47PipeServerzPClass representing a pipe server.48 49This is much like a bound, listening socket.50c��Wn\P!4VnRVnRVnVP
R4VnR#�NT)�_address�weakref�WeakSet�_free_instances�_pipe�_accept_pipe_future�_server_pipe_handle)rr)s&&rr�PipeServer.__init__�s9���
�&���0�����51�#'�� ��-�-�d�3��52r!c�J�VPVPR4uqnV#)F)r�r�)r�tmps& r�_get_unconnected_pipe� PipeServer._get_unconnected_pipes#��53�*�*�d�&>�&>�u�&E���Z��54r!c55�j�VP4'dR#\P\P,pV'dV\P,p\P56!VPV\P\P,\P,\P\P\P\P\P4p\P!V4pVP P#V4V#rA)�closedra�PIPE_ACCESS_DUPLEX�FILE_FLAG_OVERLAPPED�FILE_FLAG_FIRST_PIPE_INSTANCE�CreateNamedPiper��PIPE_TYPE_MESSAGE�PIPE_READMODE_MESSAGE�	PIPE_WAIT�PIPE_UNLIMITED_INSTANCESr�BUFSIZE�NMPWAIT_WAIT_FOREVER�NULL�57PipeHandler��add)r�first�flags�h�pipes&&   rr��PipeServer._server_pipe_handles����;�;�=�=���*�*�W�-I�-I�I����W�:�:�:�E��#�#��M�M�5��%�%��(E�(E�E����
��,�,��!�!�=�#8�#8��(�(�'�,�,�

8���'�'��*����� � ��&��r!c��VPRJ#rA)r�rds&rr��PipeServer.closed s���
�
��%�&r!c��VPe"VPP4RVnVPeNVPFpVP	4K	RVnRVnVPP
4R#R#rA)r�r3r�r��closer��clear)rr�s& rr��PipeServer.close#sp���#�#�/��$�$�+�+�-�'+�D�$��=�=�$��,�,���58�59��-��D�J� �D�M�� � �&�&�(�%r!)r�r�r�r�N)
rKrLrMrNrOrr�r�r�r��__del__rPrQ�rTs@rr�r��s*�����4���$'�60)��Gr!r�c��]tRtRtRtRtR#)�_WindowsSelectorEventLoopi2z'Windows version of selector event loop.�N)rKrLrMrNrOrPr�r!rr�r�2s��1r!r�c�haa�]tRtRtoRtR61V3RlltV3RltV3RltRtRt	R62Rlt63R	tVtV;t
#)r
i6z2Windows version of proactor event loop using IOCP.c�B<�Vf\4p\SV`	V4R#rA)rrr)rr�rs&&�rr�ProactorEventLoop.__init__9s�����#�~�H�
����"r!c�z<�VPeQhVPVP4\SV`4R#rA)�_self_reading_future�	call_soon�_loop_self_readingr�_run_forever_setup)rrs&�rr��$ProactorEventLoop._run_forever_setup>s2����(�(�0�0�0����t�.�.�/�
��"�$r!c�<�\SV`4VPekVPPpVPP	4Ve.VP64'gVPPV4RVnR#R#rA)r�_run_forever_cleanupr�rr3r#r�r�)rrrs& �rr��&ProactorEventLoop._run_forever_cleanupCsk���
��$�&��$�$�0��*�*�.�.�B��%�%�,�,�.��~�b�j�j�j����*�*�2�.�(,�D�%�1r!c��"�VPPV4pVGRjx�L65pV!4pVPWERV/R7pWe3#L#5i)N�addr��extra)r��connect_pipe�_make_duplex_pipe_transport)r�protocol_factoryr)�fr��protocol�transs&&&    r�create_pipe_connection�(ProactorEventLoop.create_pipe_connectionRsU����N�N�'�'��0���w��#�%���0�0��8>��7H�1�J�����	�s�!A	�A�$A	c��jaaaaa"�\S4oRVVVVV3RlloSPS4S.#5i)Nc	�<�RpV'dpVP4pSPPV4SP4'dVP	4R#S!4pSPWRS/R7SP
4pVfR#SPPV4pVSn	VPS4R# \dCT'd&TP4R668wdTP	4SPS4R#\d�pT'd>TP4R678wd)SPRRRTRT/4TP	4M+SP 'd\"P$!RTRR	7SPS4Rp?R#Rp?i\&P(d T'dTP	4R#R#i;i)Nr�r�r/zPipe accept failedr0r�zAccept pipe failed on pipe %rT)�exc_infor)rHr��discardr�r�r�r�r��accept_piper��add_done_callback�BrokenPipeError�filenor�r4r6�_debugr�warningr�CancelledError)	r�r�r�r7r)�loop_accept_piper�r�servers	&   �����rr��>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_pipe]s}����D�)
6���8�8�:�D��*�*�2�2�4�8��}�}����68�69���/�1�H��4�4��v�w�.?�5�A��3�3�5���<���N�N�.�.�t�4��*./��*��#�#�$4�5��+#�
1��D�K�K�M�R�/��J�J�L����/�0��
1��D�K�K�M�R�/��/�/�!�#7�#�S���1��70�J�J�L��[�[�[��N�N�#B�#'�$�8����/�0�0���,�,�
!���J�J�L��
!�sZ�C�AC�C� 0C�C�G�6G�G�G�AF$�4*F$�$G�;G�G�GrA)r�r�)rr�r)r�r�sfff@@r�start_serving_pipe�$ProactorEventLoop.start_serving_pipeZs1�����G�$��+	6�+	6�Z	
���'�(��x��s�,3c	71��"�VP4p72\WW#WEWg3RV73RV/V	BpV74GRjx�L75V#L \\3dh\d,TP4TP
4GRjx�L76hi;i5i)�waiterr�N)�
create_future�_WindowsSubprocessTransport�77SystemExit�KeyboardInterrupt�
BaseExceptionr��_wait)rr��args�shell�stdin�stdout�stderr�bufsizer��kwargsr��transps&&&&&&&&&,  r�_make_subprocess_transport�,ProactorEventLoop._make_subprocess_transport�s�����#�#�%��,�T�T�-2�F�7�4:�7�BG�7�06�7��	��L�L��
�
���-�.�	���	��L�L�N��,�,�.� � ��	�s7�$A?�5�3�5�A?�5�A<�$A<�4A7�5A<�<A?)r�rA)rKrLrMrNrOrr�r�r�r�rrPrQrRrSs@@rr
r
6s,����<�#�78%�79
-��1�f�r!c�a�]tRtRtoRt]3RltRtRtRt	R#Rlt80R	t]R814t
]R4tR$RltR$R
ltR$RltR$RltR%RltR$RltRtRtRtRtRtR#RltRtRtRtRtRt Rt!R#Rlt"Rt#R t$R!t%R"t&Vt'R#)&ri�z#Proactor implementation using IOCP.c��RVn.Vn\P!\P\82^V4Vn/Vn\P!4Vn83.Vn\P!4VnR#rA)
r5�_resultsrr�CreateIoCompletionPort�INVALID_HANDLE_VALUEr��_iocp�_cacher�r�rZ�
_unregistered�_stopped_serving)r�concurrencys&&rr�IocpProactor.__init__�s_����84���
� �7�7��,�,�d�A�{�D��85����"�?�?�,������ '��� 1��r!c�8�VPf\R4hR#)NzIocpProactor is closed)rr�rds&r�
_check_closed�IocpProactor._check_closed�s���:�:���7�8�8�r!c��R\VP4,R\VP4,.pVPfVP	R4RVP86P:RRPV4:R2#)zoverlapped#=%sz87result#=%sr��<� r&)�lenr
r	rrjrrK�join)rr+s& r�__repr__�IocpProactor.__repr__�s_�� �3�t�{�{�#3�3��s�4�=�=�1�1�3���:�:���K�K��!�� �N�N�3�3�S�X�X�d�^�D�Dr!c��WnR#rA)r5)rrs&&r�set_loop�IocpProactor.set_loop�s���88r!Nc��VP'gVPV4VPp.VnTRp# Rpi;irA)r	re)r�timeoutr�s&& r�select�IocpProactor.select�s<���}�}�}��J�J�w���m�m����
�	���C��$�C�s	�<�Ac�\�VPP4pVPV4V#rA)r5r�rF)r�valuerms&& r�_result�IocpProactor._result�s%���j�j�&�&�(�����u���89r!c���VP4# \dIpTP\P\P9039d\
TP!hhRp?ii;irA)�	getresultr4rtrr�ERROR_NETNAME_DELETED�ERROR_OPERATION_ABORTED�ConnectionResetErrorr�)r��keyrr7s&&& r�finish_socket_func�IocpProactor.finish_socket_func�sY��	��<�<�>�!���	��|�|�� A� A� +� C� C� E�E�*�C�H�H�5�5���	�s��A%�AA � A%c��VPWV4# \d/pTP\P8Xd91TR3uRp?#hRp?ii;irA)r-r4rtrr�ERROR_PORT_UNREACHABLE)�clsr�r,r�empty_resultr7s&&&&$ r�_finish_recvfrom�IocpProactor._finish_recvfrom�sL��	��)�)�%�b�9�9���	��|�|�{�A�A�A�#�T�)�)���
	�s ��A
�"A�A
�A�A
c��VPV4\P!\4p\	V\92P934'd"VP
VP4W#4M!VPVP4V4VPWAVP4# \dTPR4u#i;i)r!)
�_register_with_iocprr�94Overlappedr��95isinstance�socket�WSARecvr��ReadFiler�r%�	_registerr-�r�conn�nbytesr�rs&&&& r�recv�IocpProactor.recv�s���� � ��&�
�
#�
#�D�
)��	%��$��
�
�.�.��96�97�4�;�;�=�&�8����D�K�K�M�6�2��~�~�b��(?�(?�@�@���	%��<�<��$�$�	%���AB+�. B+�+C98�	C99c��VPV4\P!\4p\	V\100P1014'd"VP
VP4W#4M!VPVP4V4VPWAVP4# \dTP^4u#i;ir_)
r6rrr7r�r8r9�WSARecvIntor��ReadFileIntor�r%r<r-�rr>�bufr�rs&&&& r�	recv_into�IocpProactor.recv_into�s���� � ��&�
�
#�
#�D�
)��	#��$��
�
�.�.����t�{�{�}�c�9�������
�s�3��~�~�b��(?�(?�@�@���	#��<�<��?�"�	#�rBc	�,�VPV4\P!\4pVP	VP4W#4TPYA\TPRR74# \dTPR4u#i;i)r!�r2)r!N)r6rrr7r��WSARecvFromr�r�r%r<rr3r=s&&&& r�recvfrom�IocpProactor.recvfrom�s���� � ��&�
�
#�
#�D�
)��	-��N�N�4�;�;�=�&�8��~�~�b���0E�0E�=@�)B�C�	C���	-��<�<��,�,�	-��� A4�4B�Bc	�,�VPV4\P!\4pVP	VP4W#4TPYA\TP^R74# \dTPR4u#i;i)r`rK�r`N)r6rrr7r��WSARecvFromIntor�r�r%r<rr3rFs&&&& r�
recvfrom_into�IocpProactor.recvfrom_intos���� � ��&�
�
#�
#�D�
)��	+����t�{�{�}�c�9��~�~�b���0E�0E�=>�)@�A�	A���	+��<�<�	�*�*�	+�rOc���VPV4\P!\4pVP	VP4W#V4VP
WQVP4#rA)r6rrr7r��	WSASendTor�r<r-)rr>rGr�r�rs&&&&& r�sendto�IocpProactor.sendtosM��� � ��&�
�
#�
#�D�
)��102���T�[�[�]�C��5��~�~�b��(?�(?�@�@r!c�R�VPV4\P!\4p\	V\103P1044'd"VP
VP4W#4M VPVP4V4VPWAVP4#rA)r6rrr7r�r8r9�WSASendr��	WriteFiler<r-rFs&&&& r�send�IocpProactor.sendsp��� � ��&�
�
#�
#�D�
)���d�F�M�M�*�*��J�J�t�{�{�}�c�1��L�L������,��~�~�b��(?�(?�@�@r!c�aa�VPS4VPSP4o\P!\1054pVP
SP4SP44VV3RlpRpVPVSV4pV!VS4p\P!W`PR7V#)c�.<�VP4\P!RSP44pSP	\106P\PV4SPSP44SSP43#)z@P)r(�struct�packr��107setsockoptr9�108SOL_SOCKETrr�SO_UPDATE_ACCEPT_CONTEXT�109settimeout�110gettimeout�getpeername)r�r,rrGr>�listeners&&& ��r�
finish_accept�*IocpProactor.accept.<locals>.finish_accept+sl����L�L�N��+�+�d�H�O�O�$5�6�C��O�O�F�-�-�'�@�@�#�
G��O�O�H�/�/�1�2���)�)�+�+�+r!c��|"�VGRjx�L111R#L \PdTP4hi;i5irA)rr�r�)r1r>s&&r�accept_coro�(IocpProactor.accept.<locals>.accept_coro4s1���
������,�,�
��112�113���
�s �<����<��'9�<r)r6�_get_accept_socket�familyrrr7r��AcceptExr�r<r114�
ensure_futurer5)rrhrrirlr1�coror>s&f     @r�accept�IocpProactor.accept%s����� � ��*��&�&�x���7��
�
#�
#�D�
)��115���H�O�O�%�t�{�{�}�5�	,�	�����H�m�<���6�4�(��
���D�z�z�2��
r!c�a�SP\P8XdS\P!SP4V4VPP4pVPR4V#VPS4\P!SP4SP4\P"!\$4pVP'SP4V4V3RlpVP)VSV4# \dHpTP\P8wdhSP!4^,^8XdhRp?L�Rp?ii;i)Nc�<�VP4SP\P\P116^4S#r_)r(rbr9rcrr�SO_UPDATE_CONNECT_CONTEXT)r�r,rr>s&&&�r�finish_connect�,IocpProactor.connect.<locals>.finish_connectWs1����L�L�N��O�O�F�-�-�'�A�A�1�
F��Kr!)�typer9�117SOCK_DGRAMrr�118WSAConnectr�r5r�rFr6�	BindLocalror4rt�errno�	WSAEINVAL�getsocknamer7r��	ConnectExr<)rr>r)rm�errxs&f&    r�connect�IocpProactor.connectAs����9�9��)�)�)�
�"�"�4�;�;�=�'�:��*�*�*�*�,�C��N�N�4� ��J�� � ��&�	��!�!�$�+�+�-����=��
#�
#�D�
)��119���T�[�[�]�G�,�	��~�~�b�$��7�7��!�	��z�z�U�_�_�,�����!�!�$��)��*��		�s�/D�E�=E�Ec	�N�VPV4\P!\4pVR,pV^ ,	R,pVP	VP4\P!VP44WgV^^4VPWQVP4#)l��)120r6rrr7r��TransmitFiler��msvcrt�
get_osfhandler<r-)r�sock�file�offset�countr�121offset_low�offset_highs&&&&&   r�sendfile�IocpProactor.sendfile`s���� � ��&�
�
#�
#�D�
)���k�)�122���|�{�2��123������
��,�,�T�[�[�]�;�"��q�!�	%�124�~�~�b��(?�(?�@�@r!c��a�VPS4\P!\4pVP	SP44pV'dVP
S4#V3RlpVPVSV4#)c�(<�VP4S#rA)r()r�r,rr�s&&&�r�finish_accept_pipe�4IocpProactor.accept_pipe.<locals>.finish_accept_pipews����L�L�N��Kr!)r6rrr7r��ConnectNamedPiper�r%r<)rr�r�	connectedr�s&f   rr��IocpProactor.accept_pipelsf���� � ��&�
�
#�
#�D�
)���'�'����
�6�	���<�<��%�%�	��~�~�b�$�(:�;�;r!c��T"�\p\P!V4p\P!T4# \d+pTP\P1258wdhRp?MRp?ii;i\
T^,\4p\P!T4GRjx�L126K�5i)TN)�CONNECT_PIPE_INIT_DELAYrr�ConnectPiper4rt�ERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYr127�sleeprr�)rr)�delayr[r7s&&   rr��IocpProactor.connect_pipe}s����'���
�$�0�0��9����'�'��/�/���
��<�<�;�#>�#>�>��?��
��128���	�#9�:�E��+�+�e�$�$�$�s7�B(�8�B(�A-� A(�#B(�(A-�-3B(� B#�!B(c�&�VPWR4#)z�Wait for a handle.129 130Return a Future object. The result of the future is True if the wait131completed, or False if the wait did not complete (on timeout).132F)�_wait_for_handle)rr[r s&&&r�wait_for_handle�IocpProactor.wait_for_handle�s���$�$�V�e�<�<r!c�8�VPVRR4pW#nV#r�)r�r�)rr��
done_callbackrms&&& rr��IocpProactor._wait_cancel�s#���#�#�E�4��6��+���133r!c�a�VP4Vf\PpM\P!VR,4p\134P!\4p\135P!WPVPV4pV'd\WQW`PR7oM\WQW`VPR7oSP'dSPRV3RlpSV^V3VPVP&S#)N�@�@rc�$<�SP4#rA)re)r�r,rr�s&&&�r�finish_wait_for_handle�=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handle�s����7�7�9�r!r)rra�INFINITE�math�ceilrrr7r��RegisterWaitWithQueuerr)r�r5r�rr
)	rr[r �136_is_cancel�msrr\r�r�s	&&&&    @rr��IocpProactor._wait_for_handle�s���������?��!�!�B����7�S�=�)�B��
#�
#�D�
)��!�7�7��J�J��137�138�B�0���!�"�k�139�140�K�A�!�"�k�'+�z�z�3�A������#�#�B�'�	�$%�b�!�-C�"D����B�J�J���r!c���WP9dOVPPV4\P!VP	4VP141^^4R#R#rQ)rZr�rrr142r�r�r�objs&&rr6� IocpProactor._register_with_iocp�sG���&�&�&���� � ��%��.�.�s�z�z�|�T�Z�Z��A�N�'r!c�t�VP4\WPR7pVP'dVPRVP'gV!RRV4pVPV4WAW#3VPVP&V# \dpTPT4Rp?L>Rp?ii;ir)143rrr5rr#rFr4rBr
r))rrr��callbackr�r$r�s&&&&   rr<�IocpProactor._register�s�������144
�b�z�z�2�������#�#�B�'��z�z�z�145
$� ��t�R�0�����U�#�$%�#�"8����B�J�J������
#�����"�"��
#�s�146B�B7�B2�2B7c�\�VP4VPPV4R#)z�Unregister an overlapped object.147 148Call this method when its future has been cancelled. The event can149already be signalled (pending in the proactor event queue). It is also150safe if the event is never signalled (because it was cancelled).151N)rrrj)rrs&&rr��IocpProactor._unregister�s$��	
�������!�!�"�%r!c�T�\P!V4pVP^4V#r_)r9re)rro�ss&& rrn�IocpProactor._get_accept_socket�s ���M�M�&�!��	���Q���r!c�v�Vf\pMEV^8d\R4h\P!VR,4pV\8�d\R4h\P152!VPV4pVfM�^pVwrErgVPPV4wr�r�Y�P 9dTP#4KoTP%4'dK�T!YVT	4pTP'T4TP(P+T4RpK�VP0F)p	VPPV	P2R4K+	VP0P54R# \d{TPP4'd)TPPRRRRYEYg3,/4T^\P39d\P!T4EK�i;i \,d8p
TP/T
4TP(P+T4Rp
?
ELRp
?
ii;i Rpi;i)Nznegative timeoutr�ztimeout too bigr/z8GetQueuedCompletionStatus() returned an unexpected event�statusz)err=%s transferred=%s key=%#x address=%#x)r��153ValueErrorr�r�rr�GetQueuedCompletionStatusrr
�pop�KeyErrorr5�	get_debugr6rrar�rr3�donerFr	rjr4rBrr)r�)rr r�r��err�transferredr,r)r�rr�r�r$r�s&&            rre�IocpProactor._poll�s����?��B�
�q�[��/�0�0����7�S�=�)�B��X�~� �!2�3�3�� �:�:�4�:�:�r�J�F��~���B�-3�*�C�c�
�'+�{�{���w�'?�$��s� �+�+�+����154��V�V�X�X�	�$�[�r�:�E�155�L�L��'��M�M�(�(��+��A��$�$�B��K�K�O�O�B�J�J��-�%���� � �"��E�

��:�:�'�'�)�)��J�J�5�5�!�%7� �#N�&)��%E�$F�7���q�+�"B�"B�C�C��'�'��,��

��,�,��O�O�A�&��M�M�(�(��+�+��,���A�sI�E'�	G/�",H4�'*G,�AG,�+G,�/H1�:,H,�&H4�,H1�1H4�4H8c�<�VPPV4R#rA)rr�r�s&&r�
_stop_serving�IocpProactor._stop_serving3s��	
���!�!�#�&r!c��VPfR#\VPP44FGwrr4VP	4'dK\V\4'dK6VP4KI	Rp\P!4pW�,p	VP'd|V	\P!48:dO\P!RV\P!4V,1564\P!4V,p	VP!V4K�.Vn\$P&!VP4RVnR# \dfpTPeLRRRTRT/pTP'dTPTR&TPPT4Rp?EK�Rp?EK�Rp?ii;i)Nr/zCancelling a future failedr0r1r2g�?z,%r is running after closing for %.1f seconds)r�listr
�values�	cancelledr8r�r3r4r5rr6�time�	monotonicr�debugrer	rar�)157rrmrr�r�r7r8�158msg_update�159start_time�next_msgs160&         rr��IocpProactor.close9sb���:�:���'+�4�;�;�+=�+=�+?�&@�"�C�S��}�}�����C�!2�3�3��C��J�J�L�'A�0�161��^�^�%�162��*���k�k�k��4�>�>�+�+����K�!�4�>�>�#3�j�#@�B��>�>�+�j�8��
�J�J�z�"���
����D�J�J�'���163��;�	C��z�z�-�%�'C�'��$�c�#��164�0�0�0�:=�:O�:O�G�$6�7��165�166�9�9�'�B�B�.��	C�s�+E�G�&'G�*G�Gc�&�VP4R#rA)r�rds&rr��IocpProactor.__del__hs���167�168�r!)r
rr5rZr	rrrAr_rQ)(rKrLrMrNrOr�rrrrr!r%�staticmethodr-�classmethodr3r@rHrMrSrWr\rsr�r�r�r�r�r�r�r6r<r�rnrer�r�r�rPrQr�s@rrr�s�����-�#+�2�9�E��	��169�����	��	�A�A�	C�	A�A�A��88�>170A�<�"0�&=�� �DO��@&��1717#�r'�-�^�r!c�&a�]tRtRtoRtRtVtR#)r�ilc
�a�\P!V3RVRVRVRVRV/VBSnV3RlpSPPP\
SPP44p	V	PV4R#)r�r�rrrc�^<�SPP4pSPV4R#rA)�_proc�poll�_process_exited)r��172returncoders& �rr��4_WindowsSubprocessTransport._start.<locals>.callbackss!��������*�J�� � ��,r!N)	r�Popenr�r5r�r��intrXr�)173rr�r�r�rrrrr�r�s174f&&&&&&,  r�_start�"_WindowsSubprocessTransport._startns����"�(�(��'��'�%*�'�39�'�BH�'��'�%�'��175�	-�
�J�J� � �0�0��T�Z�Z�5G�5G�1H�I��	���H�%r!)r�N)rKrLrMrNr�rPrQr�s@rr�r�ls����176&�177&r!r�c��]tRtRt]tRtR#)ri~r�N)rKrLrMrN�SelectorEventLoop�
_loop_factoryrPr�r!rrr~���%�Mr!c��]tRtRt]tRtR#)ri�r�N)rKrLrMrNr
r�rPr�r!rrr�r�r!)r�r
r�_DefaultEventLoopPolicyrr�	EventLoop)5rO�sys�platform�ImportErrorrrrar~�	functoolsrr�r�r9r`r�r��rrrrrr	r178r�logr�__all__r�r��ERROR_CONNECTION_REFUSED�ERROR_CONNECTION_ABORTEDr�r��FuturerrVr�r��objectr��BaseSelectorEventLoopr��BaseProactorEventLoopr
r�BaseSubprocessTransportr�r��_BaseDefaultEventLoopPolicyrrr�r�r�r!r�<module>r�sa��4�179��<�<�7��180�l�181#�#������
�
�
���������������|�|���������� ����-����-�`G#�G�N�N�G#�T&�-�&�01P�-�1P�h8��8�v2�� E� E�2�h��=�=�h�VH�H�V&�/�"I�"I�&�.��&�f�&H�&H�&�&�f�&H�&H�&�:���	r!
codekingpro/portable-devtools · Team Ai