add-determinism 0.7.3

RPM buildroot helper to strip nondeterministic bits in files
Documentation

��gk7csB�OOFoOOFoOOFoOOFoOOFoOOFoOOFoOOFoOOF	o	OOF
o
OOFoOOFoOOF
o
OOFoOOFoOOFoOOFoOOFEoOOFEoOOFEoOOFEoOOFEoOOFEoOO	FEoOO
FEoOOFEoOOFEoOO
FEoOOFEoOOF E!o!Oo"Oo#Oo$X%XO1o&Oo'Oo(Oo)Oo*O%Ogo+O&Ogo,Oo-X%XO1%^Oo.JOo.Oo/OO XM`1o1O!O"XMd1o3O#O$XMh1o5dX^OoI�c9c)'�N�)�	constants)�
coroutines)�events)�
exceptions)�futures)�	protocols)�sslproto)�	staggered)�tasks)�timeouts)�
transports)�trsock)�logger)�
BaseEventLoop�Server�dg�?�AF_INET6i�Qcs��QMkWWQOO1WM1%^WQM1!WQ1!)N�__self__)Z	_callback�
isinstance�getattrr
�Task�reprr�str)�handleZcb�  �,/usr/lib64/python3.14/asyncio/base_events.py�_format_handlerGs@��	�	�	�B��'�"�j�$�/����<�<��B�K�K� � ��6�{��csl�QWM6X^dQWM6X^dWQ1!)Nz<pipe>z<stdout>)�
subprocess�PIPE�STDOUTr)Zfd� r�_format_piper"Ps+��	�Z�_�_���	�z� � �	 ���B�x�rcs��WWO1%aWO1bQMWMWM
O1dW^WO1bc9c)N�SO_REUSEPORTz)reuse_port not supported by socket modulerzTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)�hasattr�socket�
ValueError�
setsockopt�
SOL_SOCKETr#�OSError��sockr!r�_set_reuseportr,Ysc���6�>�*�*��D�E�E�	J��O�O�F�-�-�v�/B�/B�A�F���	J��I�J�
J�	J�s�/A�A(c	s��WWO1%adQOWMWM-7aQ`dQWM6X^WMkJ&QWM
6X^WMkJdQ`OkJHW
QW1%^	QO6X^OkJ*W
QW1%^	QO6X^OkJWQ1kQWM6X^<WM+kW%^QMWM 1JQ+kW
QW1%^QM#O1kOQ7^dQCJkWM$T�1W%^QWM 6X^
T�QOTTV00p!T�QOT00p!	dWW0^dc9cW&^Hrc9c)N�	inet_ptonrr�ZidnaZ%)r$r%�IPPROTO_TCPZIPPROTO_UDP�SOCK_STREAM�
SOCK_DGRAMr�bytesr�int�	TypeErrorr&�	AF_UNSPEC�AF_INET�	_HAS_IPv6�appendrZdecoder-r))	�host�port�family�type�protoZflowinfoZscopeidZafs�af�	         r�_ipaddr_infor@ds����6�;�'�'���Q��*�*�F�,>�,>�?�?��L���v�!�!�!��"�"��	
��"�"�	"��"�"����|���	�D�%�	 �	 �T�S�[���	�D�#�	�	�4�2�:���	��t�9�D���!�!�!��~�~����9��J�J�v���'���h���$�����{�{�6�"��
�d�{����	����R�&��y�R�6�?�?�2����T��,K�K�K����T�L�8�8����;�:�&�	��	��2�	��	�s*�F*�<G�G�*F=�<F=�
G�
Gcs��WM1kQC$kQOkTB7^+T$$T$MQ1H&	WQM	11k+kQO6�^%QMQOOQO*
1QOOQO*
.QMOWMMWMQ2111Q!)Nrrc3s. �QCkQ`HQs�H	d3c�N�)�.0Zarr�	<genexpr>Z(_interleave_addrinfos.<locals>.<genexpr>�s ����
�a�
�	
��
�s��	)
�collectionsZOrderedDictr8�listZvaluesZextend�	itertools�chain�
from_iterableZzip_longest)Z	addrinfosZfirst_address_family_countZaddrinfos_by_family�addrr;Zaddrinfos_listsZ	reordered�       r�_interleave_addrinfosrL�s���&�1�1�3�����a����,�*,��'��#�*�*�4�0�	�
�.�5�5�7�8�O��I�!�A�%������+�,K�-G�!�-K�L�M��A��>� :�Q� >�>�?�
�����?�?�0�0��!�!�?�3�
����rcs��QM1%a,QM1kWQWW01%^dW
MQ1M1drA)�	cancelled�	exceptionr�
SystemExit�KeyboardInterruptrZ	_get_loop�stop)�fut�excrr�_run_until_complete_cbrT�sG���=�=�?�?��m�m�o���c�J�(9�:�;�;�
����c����!r�TCP_NODELAYcs<�QMWMWM-7^nQMWM
6X^OQMWM6X^0QMWMWMO1dddd�Nr)
r;r%r6rr<r0r=r/r'rUr*r!r�_set_nodelayrW�sj���K�K�F�N�N�F�O�O�<�<��	�	�V�/�/�/��
�
�f�0�0�0��O�O�F�.�.��0B�0B�A�F�1�0�
=rcs�drArBr*r!rrWrW�s��rcsh�W_+WQWM1%^WO1bdd)Nz"Socket cannot be of type SSLSocket)�sslrZ	SSLSocketr4r*r!r�_check_ssl_socketrY�s*��
��:�d�C�M�M�:�:��<�=�=�;�rcsT[�XoOoOojOoOoOoOoOoOo	Oo
O	oO
oOo
Qod)
�_SendfileFallbackProtocoli�cs��WQWM1%aWO1bTiQM1QiQM1QiQMQi
QM1QMQ1QM%^*QMMM1QidOQid)Nz.transport should be _FlowControlMixin instance)rrZ_FlowControlMixinr4�
_transportZget_protocol�_protoZ
is_reading�_should_resume_readingZ_protocol_paused�_should_resume_writing�
pause_reading�set_protocol�_loop�
create_future�_write_ready_fut)�self�transprr�__init__Z"_SendfileFallbackProtocol.__init__�s����&�*�">�">�?�?��L�M�M� ���)�)�+���&,�&7�&7�&9��#�&,�&=�&=��#��������D�!��&�&�$(�O�O�$9�$9�$G�$G�$I�D�!�$(�D�!rc�s� �QMM1%^WO1bQMkQ`dQDOes�I
dI3c)NzConnection closed by peer)r[�
is_closing�ConnectionErrorrc)rdrRrr�drainZ_SendfileFallbackProtocol.drain�s>����?�?�%�%�'�'�!�"=�>�>��#�#���;���	�	�s�AA
�A�A
c��WO1b)Nz?Invalid state: connection should have been established already.��RuntimeError�rd�	transportrr�connection_madeZ)_SendfileFallbackProtocol.connection_made�s���N�O�	Orcs��QM_CQ`%QMMWO11JQMMQ1QMM	Q1d)NzConnection is closed by peer)rc�
set_exceptionrhr\�connection_lost)rdrSrrrqZ)_SendfileFallbackProtocol.connection_lost�s[��� � �,��{��%�%�3�3�#�$B�C�E��%�%�3�3�C�8����#�#�C�(rcsr�QM_dQMMM1QidrA)rcr[rarb�rdr!r�
pause_writingZ'_SendfileFallbackProtocol.pause_writing�s,��� � �,�� $��� 5� 5� C� C� E��rcsd�QM`dQMMO1OQid�NF)rc�
set_resultrrr!r�resume_writingZ(_SendfileFallbackProtocol.resume_writing�s-��� � �(�����(�(��/� $��rcrj�Nz'Invalid state: reading should be pausedrk)rdZdatarr�
data_receivedZ'_SendfileFallbackProtocol.data_received����D�E�Ercrjrwrkrrr!r�eof_receivedZ&_SendfileFallbackProtocol.eof_receivedryrc�sR �QMMQM1QM%^QMM	1QM
_QM
M
1QM%^QMM1dd3crA)	r[r`r\r]�resume_readingrc�cancelr^rvrrr!r�restoreZ!_SendfileFallbackProtocol.restoresr������$�$�T�[�[�1��&�&��O�O�*�*�,�� � �,�
�!�!�(�(�*��&�&��K�K�&�&�(�'�s�B%B')r\r]r^r[rcN)�__name__�
__module__�__qualname__�__firstlineno__rfrirorqrsrvrxrzr}�__static_attributes__�__classdictcell__�Z
__classdict__�@rrZrZ�s6����)��O�	)�F�
%�F�F�
)rrZcs�[�XoOoOojOOgoOoOoOoOoOo	O	o
O
oXO1o
OoO
oOoOoOoOoOoQod)riNcs��TiT iWM1Qi+QiT0iTPiT@iT`i	Tpi
OQiOQidrt)
ra�_sockets�weakref�WeakSet�_clients�_waiters�_protocol_factory�_backlog�_ssl_context�_ssl_handshake_timeout�_ssl_shutdown_timeout�_serving�_serving_forever_fut)rd�loop�sockets�protocol_factoryZssl_context�backlog�ssl_handshake_timeout�ssl_shutdown_timeout�        rrfZServer.__init__sO���
��
� ���)��
���
�!1���
�'��&;�#�%9�"���
�$(��!rcsR�OQMMOQM8O/!)N�<z	 sockets=�>)�	__class__r~r�rrr!r�__repr__ZServer.__repr__%s'���4�>�>�*�*�+�9�T�\�\�4D�A�F�Frcs:�QMMQ1drA)r��addrmrr�_attachZServer._attach(s���
�
���)�$rcs��QMMQ1WQM1O6X^QM`QM	1ddd�Nr)r��discard�lenr��_wakeuprmrr�_detachZServer._detach,s?���
�
���i�(��t�}�}���"�t�}�}�'<��L�L�N�(=�"rcs��QMkOQiQC+kQM1%^HQMO1H-	drA)r��doneru)rdZwaiters�waiter�   rr�ZServer._wakeup1s5���-�-����
��F��;�;�=�=��!�!�$�'�rc
s4�QM%^dOQiQMCokQMQM1QMMQMTMTMQMQM1Hq	d�NT)
r�r�Zlistenr�ra�_start_servingr�r�r�r�)rdr+rrr�ZServer._start_serving8sl���=�=����
��M�M�D��K�K��
�
�&��J�J�%�%��&�&��.?�.?��m�m�T�%@�%@��*�*�
,�"rc��QM!rA)rarrr!r�get_loopZServer.get_loopCs���z�z�rcr�rA)r�rrr!r�
is_servingZServer.is_servingFs���}�}�rcsV�QM`dWOQM11!)NrBc3sL �QCkWMQ1s�H	d3crA)r
ZTransportSocket)rCZsrrrDZ!Server.sockets.<locals>.<genexpr>Ms���F�
�1�V�+�+�A�.�.�
�s�"$)r��tuplerrr!rr�ZServer.socketsIs$���=�=� ���F��
�
�F�F�Frcsv�QMkQ`dOQiQCkQMMQ1H 	OQiQM_@QMM1%a!QMM
1OQiWQM1O6X^QM1dd)NFr)
r�raZ
_stop_servingr�r�r�r|r�r�r�)rdr�r+r�r�closeZServer.closeOs����-�-���?����
��D��J�J�$�$�T�*����
��%�%�1��-�-�2�2�4�4��%�%�,�,�.�(,�D�%��t�}�}���"��L�L�N�#rc�f�QMM1CkQM1H	drA)r��copyr�rmrr�
close_clientsZServer.close_clientsb�#�����+�+�-�I��O�O��.rcr�rA)r�r�Zabortrmrr�
abort_clientsZServer.abort_clientsfr�rc�sl �QM1WMO1DOes�I
dI3cr�)r�r
�sleeprrr!r�
start_servingZServer.start_servingjs$��������k�k�!�n���s�*4�2�4c�s� �QM_WOQ8O/1bQM`WOQ8O/1bQM1QMM1QiQMDOes�I
OQidI
WM^1QM1QM1DOes�I
bb9cc9cOQic9c3c)Nzserver z, is already being awaited on serve_forever()z
 is closed)
r�rlr�r�rarbrZCancelledErrorr��wait_closedrrr!r�
serve_foreverZServer.serve_foreverps�����$�$�0���$��!M�N�P�
P��=�=� �����
�;�<�<�����$(�J�J�$<�$<�$>��!�		-��+�+�+�+�)-�D�%�
,���(�(�	�
��
�
���&�&�(�(�(�����	��)-�D�%�s`�A*C �-B�<B
�=B�C �
B�C�!#C�C�C�
C�C
�
C�C�	C�C c�s� �QM`dQMM1kQMMQ1QDOes�I
dI3crA)r�rarbr8)rdr�rrr�ZServer.wait_closed�s?���*�=�=� �����)�)�+���
�
���V�$����s�A	A�A�A)r�r�rar�r�r�r�r�r�r�r�rA)r~rr�r�rfr�r�r�r�r�r�r�Zpropertyr�r�r�r�r�r�r�r�r�r�r�rrrsh����>B�)� G�%��
(�	,����G��G�
�&���-�*rrcs�[�XoOoOojOoOoOoOOOO,OgoO	oO
o	OwOOOO,O
ggo
OwOOOOOOOOOOOOOO,OggoOxOgoOyOgo
OyOgoOwOgoOoOoOoOoOoOoO oOwO!goO"oO#oO$oO%oO&oO'oO(oO)oO*o X!MD0O+go#O,o$O-o%OO,O.go&OO,O/go'OO,O0go(O1o)O2o*O3o+OO,O4go,O5o-O6o.O7o/O8O9O:O9O;O9O<O9,O=go0OzO>go1O{O?O,O@ggo2OAo3OBo4OCo5OwODgo6OyOEOO8O9O;O9O<O9OFOOGOOOOOOOOHOOIOOJO,OKggo7O|OLgo8O{O?O,OMggo9ONo:OOo;OOOOOOOO,OPgo<OyO8O9O;O9O<O9OQOOROOFO,OSggo=O8O9O:X>M~O;O9O<O9,OTgo@OUoAOyO8X>M�O<X>M�OFOOVOWOEOOXOOQOOYOOOOOOZO,O[ggoDOEOOOOO,O\goEO]oFO^oGO_oHO`XIM�OaXIM�ObXIM�OcOOdOOeO9OfOOgOOhO,	OigoKO`XIM�OaXIM�ObXIM�OcOOdOOeO9OfOOgOOhO,	OjgoLOkoMOloNOmoOOnoPOooQOpoROqoSOroTOsoUOtoVOuoWOvoXQoYd)}ri�cs��OQiOQiOQiWM1Qi+QiOQiOQiOQi	WMO1MQi
OQiQMW M"11OQiOQiOQiOQiOQiOQiW0M21QiOQiOQid)NrF�	monotonicg�������?)�_timer_cancelled_count�_closed�	_stoppingrEZdeque�_ready�
_scheduled�_default_executor�
_internal_fds�
_thread_id�timeZget_clock_infoZ
resolution�_clock_resolution�_exception_handler�	set_debugrZ_is_debug_mode�_old_agen_hooks�slow_callback_duration�_current_handle�
_task_factory�"_coroutine_origin_tracking_enabled�&_coroutine_origin_tracking_saved_depthr�r��
_asyncgens�_asyncgens_shutdown_called�_executor_shutdown_calledrrr!rrfZBaseEventLoop.__init__�s���&'��#�������!�'�'�)������!%���������!%�!4�!4�[�!A�!L�!L���"&������z�0�0�2�3�#���'*��#�#���!���27��/�6:��3�"�/�/�+���*/��'�).��&rc	s��OQMMOQM1OQM1OQM	1O/	!)Nr�z	 running=z closed=z debug=r�)r�r~�
is_running�	is_closed�	get_debugrrr!rr�ZBaseEventLoop.__repr__�sP������'�'�(�	�$�/�/�2C�1D�E��n�n�&�'�w�t�~�~�/?�.@��
C�	
rcs0�WMQO5!)N�r�)rZFuturerrr!rrbZBaseEventLoop.create_future�s���~�~�4�(�(r�nameN�contextcs"�QM1QM`8WMTT#O5kQM%^
QMOQ!Q`QMT1kJQMTQO5kQMQ1Q!)N)r�r�r������)r�)�
_check_closedr�r
r�_source_tracebackZset_name)rdZcoror�r��task�     r�create_taskZBaseEventLoop.create_task�s���
	
�������%��:�:�d�D�J�D��%�%��*�*�2�.������)�)�$�5���)�)�$�g�)�F���M�M�$���rcsL�Q_WQ1%aWO1bTid)Nz'task factory must be a callable or None)�callabler4r�)rdZfactoryrr�set_task_factoryZBaseEventLoop.set_task_factory�s&����x��'8�'8��E�F�F�$�rcr�rA)r�rrr!r�get_task_factoryZBaseEventLoop.get_task_factory�s���!�!�!r�extra�serverc��WbrA�ZNotImplementedError)rdr+�protocolr�r�r��      r�_make_socket_transportZ$BaseEventLoop._make_socket_transport��
��"�!r�server_sideF�server_hostnamer�r��call_connection_madeTcr�rAr�)rdZrawsockr��
sslcontextr�r�r�r�r�r�r�r��            r�_make_ssl_transportZ!BaseEventLoop._make_ssl_transport�s
��"�!rcr�rAr�)rdr+r��addressr�r�r�r�_make_datagram_transportZ&BaseEventLoop._make_datagram_transportr�rcr�rAr��rd�piper�r�r�r�r�_make_read_pipe_transportZ'BaseEventLoop._make_read_pipe_transportr�rcr�rAr�r�r�r�_make_write_pipe_transportZ(BaseEventLoop._make_write_pipe_transport
r�rc	�s �Wb3crAr�)
rdr��args�shell�stdin�stdout�stderr�bufsizer��kwargs�
          r�_make_subprocess_transportZ(BaseEventLoop._make_subprocess_transports
���"�!�s�	cr�rAr�rrr!r�_write_to_selfZBaseEventLoop._write_to_selfs
��"�!rcr�rAr�)rd�
event_listrr�_process_eventsZBaseEventLoop._process_events!s��!�!rc�<�QM%^WO1bd)NzEvent loop is closed)r�rlrrr!rr�ZBaseEventLoop._check_closed%s���<�<��5�6�6�rcr�)Nz!Executor shutdown has been called)r�rlrrr!r�_check_default_executorZ%BaseEventLoop._check_default_executor)s���)�)��B�C�C�*rcs��QMMQ1QM1%a+QMQMQM11ddrA)r�r�r��call_soon_threadsafer��aclose�rd�agenrr�_asyncgen_finalizer_hookZ&BaseEventLoop._asyncgen_finalizer_hook-sB��������%��~�~����%�%�d�&6�&6����
�F� rcs��QM%^"WMOQ8O/WQO5QMMQ1d)Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() call�Zsource)r��warnings�warn�ResourceWarningr�r�rrr�_asyncgen_firstiter_hookZ&BaseEventLoop._asyncgen_firstiter_hook2sA���*�*��M�M�)�$��21�2���
.�
	
�����D�!rc	�s� �OQiWQM1%adWQM1kQMM	1W
MQRp+pCl"M1KH	pkOO,2DOes�I
kWT11C7rmEWQW1%aHQMOOQ8/OQOQ,1H9	dppkcIP3c)NTZreturn_exceptions�messagez;an error occurred during closing of asynchronous generator rNZasyncgen)r�r�r�rF�clearr
�gatherr�Zzipr�	Exception�call_exception_handler)rdZ
closing_agensZagZresults�resultrr�r�shutdown_asyncgensZ BaseEventLoop.shutdown_asyncgens;s����*.��'��4�?�?�#�#�
��T�_�_�-�
����������$1�
2�M�b�i�i�k�M�
2�$�"�$�$�� ��7�L�F��&�)�,�,��+�+��"9�9=�� B�����	-��8��3�$�s$�A&C�(C�
C�
C�'C�6&Cc�s< �OQiQM`dQM1kWMQM
Q0O5kQM
1WMQ19YppY1DOes�I
QDOes�I
OOO1DOes�I
QM1dI/I'I)DOes�I
%acI/9cW^@WMOQO/WOO5QMMOO5dc9c3c)	NT)Ztargetr�z:The executor did not finishing joining its threads within z	 seconds.�)Z
stacklevelF�Zwait)r�r�rb�	threadingZThread�_do_shutdownZstartr�timeout�joinZTimeoutErrorrrZRuntimeWarning�shutdown)rdr�futureZthread�    r�shutdown_default_executorZ'BaseEventLoop.shutdown_default_executorTs����*.��&��!�!�)���#�#�%���!�!��):�):�&��K������		��'�'��0�0�0����1�0�
�K�K�M�1��1�0�0�0���	8��M�M�0�07�y�	�C�(�Q�
8�
�"�"�+�+��+�7�		8�s��AD�"C�>B.�?C�B4�B0�	B4�
C�B2�C�D�.C�0B4�2C�4C	�:B=�;C	�C�AD�D�D�Dcsz�QMMOO5QM1%a"QMWM
QO1ddW^ZkQM1%a;QM1%a!QMQMQ1Ok=dOk=dOk=dOk=cc9c)NTr)	r�rr�r�rZ_set_result_unless_cancelledrrMrp)rdrZexr�rrZBaseEventLoop._do_shutdownls���	D��"�"�+�+��+�6��>�>�#�#��)�)�'�*N�*N�*0�$�8�$���	D��>�>�#�#�F�,<�,<�,>�,>��)�)�&�*>�*>��C�C�-?�#��	D�s�AA�
B:� AB5�5B:cs��QM1%^WO1bWM1_WO1bd)Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r�rlrZ_get_running_looprrr!r�_check_runningZBaseEventLoop._check_runningvsA���?�?����C�D�D��#�#�%�1��I�K�
K�2rcsf�QM1QM1QMQM1WM
1QiWM1Qi	WMQMQMO5WMQ1d)N)Z	firstiterZ	finalizer)r�r�_set_coroutine_origin_tracking�_debug�sysZget_asyncgen_hooksr�r�	get_identr��set_asyncgen_hooksrrr�_set_running_looprrr!r�_run_forever_setupZ BaseEventLoop._run_forever_setup}s��	
���������+�+�D�K�K�8�"�5�5�7���#�-�-�/�������3�3��3�3�	
�
	� � ��&rcs��OQiOQiWMO1QM	O1QM
_%WMQM
2OQiddrt)r�r�rrrr�rrrrr!r�_run_forever_cleanupZ"BaseEventLoop._run_forever_cleanup�s[��������� � ��&��+�+�E�2����+��"�"�D�$8�$8�9�#'�D� �,rcs��QM1QM1QM%aH$QM1dQM1c9crA)r �	_run_oncer�r!rrr!r�run_foreverZBaseEventLoop.run_forever�sE��	(��#�#�%����� ��>�>�>���%�%�'��D�%�%�'�s�0A�A�Acs\�QM1QM1WMQ1%(kWM
TO5kQ%^OQiQMW1QM1QMW1QM1%aWO1bQM1!Q%^:QM1%^%QM1%aQM1b9cQMW1c9c)Nr�Fz+Event loop stopped before Future completed.)r�rrZisfuturer
Z
ensure_futureZ_log_destroy_pendingZadd_done_callbackrTr#r�rMrNZremove_done_callbackrlr
)rdrZnew_taskr�r�run_until_completeZ BaseEventLoop.run_until_complete�s���	
���������'�'��/�/���$�$�V�7���+0�F�'�� � �!7�8�
	@�����
�'�'�(>�?��{�{�}�}��L�M�M��}�}����	��F�K�K�M�M�&�2B�2B�2D�2D�� � �"����'�'�(>�?�s�7C
�
AD�D�D+cs�OQidr�)r�rrr!rrQZBaseEventLoop.stop�s����rcs��QM1%^WO1bQM%^dQM%^WM
OQ1OQiQMM1QMM1OQi	QMkQ_OQi
QMOO5dd)Nz!Cannot close a running event loopzClose %rTFr)r�rlr�rr�debugr�r	r�r�r�r�rd�executorrrr�ZBaseEventLoop.close�s����?�?����B�C�C��<�<���;�;��L�L��T�*����������������)-��&��)�)����%)�D�"����5��)� rcr�rA)r�rrr!rr�ZBaseEventLoop.is_closed�s���|�|�rcs��QM1%a:QOQ8/WQO5QM1%aQM1ddd)Nzunclosed event loop r)r�rr�r�)rdZ_warnrr�__del__ZBaseEventLoop.__del__�sC���~�~����(���1�?�4�P��?�?�$�$��
�
��%� rcs�QMOG!rA)r�rrr!rr�ZBaseEventLoop.is_running�s�����t�+�,rcs,�WM1!rA)r�r�rrr!rr�ZBaseEventLoop.time�s���~�~��rcs��Q`WO1bQMQM1Q*Q+QL3OQ,2kQM%^
QMOQ!)Nzdelay must not be Noner�r�)r4�call_atr�r�)rdZdelay�callbackr�r��timerr�r�
call_laterZBaseEventLoop.call_laters]�� �=��4�5�5����T�Y�Y�[�5�0�(�.�T�.�%,�.���"�"��'�'��+��rcsd�Q`WO1bQM1QM%^"QM1QM	QO1W
MTT@Q1kQM%^
QMOWMQMQ1OQi
Q!)Nzwhen cannot be Noner)r�T)r4r�r�
_check_thread�_check_callbackrZTimerHandler��heapqZheappushr�)rdZwhenr*r�r�r+r�rr)ZBaseEventLoop.call_at s���
�<��1�2�2������;�;���� �� � ��9�5��"�"�4�4�w�G���"�"��'�'��+�
���t����.�����rcs��QM1QM%^"QM1QMQO1QM	TQ1kQM
%^
QM
OQ!)N�	call_soonr�)r�rr-r.�
_call_soonr��rdr*r�r�rr�rr0ZBaseEventLoop.call_soon2s_��	
�����;�;���� �� � ��;�7������9���#�#��(�(��,��
rcs��WMQ1%aWMQ1%^WOQO/1bW	Q1%aWOQOQ8/1bd)Nzcoroutines cannot be used with z()z"a callable object was expected by z(), got )rZiscoroutineZ_iscoroutinefunctionr4r�)rdr*Zmethodr�rr.ZBaseEventLoop._check_callbackEsp���"�"�8�,�,��/�/��9�9��1�&���<�>�
>���!�!��4�V�H�=��l�$�%�
%�"rcs��WMTT1kQM%^
QMOQMM	Q1Q!)Nr�)rZHandler�r�r8)rdr*r�r�rr�rr1ZBaseEventLoop._call_soonOs@�����x�t�=���#�#��(�(��,������6�"��
rcs~�QM`dWM1kTM6w^WO1bd)NzMNon-thread-safe operation invoked on an event loop other than the current one)r�rrrl)rdZ	thread_idrrr-ZBaseEventLoop._check_threadVs@���?�?�"���'�'�)�	����'��'�(�
(�(rcs��QM1QM%^QMQO1QMTQ1kQM%^
QMOQM1Q!)Nr�r�)r�rr.r1r�r�r2r�rr�Z"BaseEventLoop.call_soon_threadsafegs^�������;�;�� � ��+A�B������9���#�#��(�(��,������
rcsJ�QM1QM%^QMQO1Q`EQMkQM	1Q`&W
MMOO5kTiWMQMQ+QL32QO5!)N�run_in_executorZasyncio)Zthread_name_prefixr�)
r�rr.r�r��
concurrentr�ThreadPoolExecutorZwrap_futureZsubmit)rdr'Zfuncr�rrr3ZBaseEventLoop.run_in_executorrs��������;�;�� � ��'8�9����-�-�H��(�(�*���%�-�-�@�@�'0�A���*2�&��"�"��O�O�D�(�4�(�t�5�	5rcsx�WQWMM1%aW	O1bTid)Nz,executor must be ThreadPoolExecutor instance)rr4rr5r4r�r&rr�set_default_executorZ"BaseEventLoop.set_default_executor�s-���(�J�$6�$6�$I�$I�J�J��J�K�K�!)�rcsX�QOQ8/+kQ%^QMOQ8/1Q%^QMOQ8/1Q%^QMOQ8/1Q%^QMOQ8/1OMQ1kWMOQ1QM	1kW
MTT4TV1k	QM	1Q*
k
OQO	Q
O
*O
OQ	8/kT�M6�^WMQ1Q	!WMQ1Q	!)
NZ:zfamily=ztype=zproto=zflags=�, zGet address info %szGetting address info z took g@�@z.3fzms: )	r8rrr%r�r%�getaddrinfor��info)rdr9r:r;r<r=�flags�msg�t0�addrinfo�dt�           r�_getaddrinfo_debugZ BaseEventLoop._getaddrinfo_debug�s����q���!�"����J�J���
�+�,���J�J��t�h�'�(���J�J���y�)�*���J�J���y�)�*��i�i��n�����*�C�0�
�Y�Y�[���%�%�d�&��M��
�Y�Y�[�2�
��%�c�U�&��c��#��d�8�,�O��
�,�,�,��K�K�����
�L�L����rr;rr<r=r:c
�s� �QM%^
QMkJWMkQM	OTqT#TEQ1DOes�I
!I3crA)rr@r%r8r3)rdr9r:r;r<r=r:Zgetaddr_funcr�rr8ZBaseEventLoop.getaddrinfo�sN����;�;��2�2�L�!�-�-�L��)�)��,�d�D��H�H�	H�H�s�AA�	A�
Ac�s` �QMOWMT1DOes�I
!I3crA)r3r%�getnameinfo)rdZsockaddrr:r�rrAZBaseEventLoop.getnameinfo�s/����)�)��&�$�$�h�7�7�	7�7�s�%.�,�.�fallbackc�sf �QM%^QM1O6w^WO1bWQ1QM	TT41QMTT41DOes�I
!IWM^kQ%abOk=JOk=cc9cQMTT41DOes�I
!3c)Nrzthe socket must be non-blocking)	rZ
gettimeoutr&rY�_check_sendfile_params�_sock_sendfile_nativer�SendfileNotAvailableError�_sock_sendfile_fallback)rdr+�file�offset�countrBrSrKr�
sock_sendfileZBaseEventLoop.sock_sendfile�s�����;�;�4�?�?�,��1��>�?�?��$���#�#�D��>�	��3�3�D�4:�C�C�
C�C���3�3�	�����	���1�1�$�28�A�A�A�	A�sN�AB1�A-�&A+�'A-�*B1�+A-�-B�B�	B1�B�B1�+B.�,B1c�sH �WMOQ8OQ8O/1b3c)Nz-syscall sendfile is not available for socket z
 and file z combination�rrE�rdr+rGrHrIr�rrDZ#BaseEventLoop._sock_sendfile_native�s3����2�2�;�D�8�D��x�|�
-�.�	.�s� "c�sr �Q%^QMQ1Q%^WQWM1JWMkW	Q1kOkQ%^WTG*
Q1kQO6:^J]WQ1OQkQM
OQMQ1DOes�I
k	Q	%aJ"QMTOQ	1DOes�I
Ty*
kHzQQO6�^&WQO1%^QMT7*1!!!I\I:QO6�^&WQO1%^QMT7*1ccc9c3c)Nr�seek)
rM�minrZ!SENDFILE_FALLBACK_READBUFFER_SIZE�	bytearray�
memoryviewr3�readintoZsock_sendallr$)
rdr+rGrHrI�	blocksize�buf�
total_sent�view�readr�rrFZ%BaseEventLoop._sock_sendfile_fallback�s$�����I�I�f���
��y�B�B�C�#�E�E�	��	�"���
�	/��� #�E�$6�	� B�I� �A�~��!�#��z�	�2��!�1�1�$��
�
�t�L�L�����'�'��5�D�k�:�:�:��"�
���A�~�'�$��"7�"7��	�	�&�-�.�#8�~�M�;���A�~�'�$��"7�"7��	�	�&�-�.�#8�~�sC�AD7�AD�%D�&#D�	D�
D�-D7�D�D�.D4�4D7cs��OWQOO17^WO1bQMWM6XaWO1bQ_OWQW1%aWOMQ11bQO6:^WOMQ11bWQW1%aWOMQ11bQO6^WOMQ11bd)NZb�modez$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})rz0offset must be a non-negative integer (got {!r}))	rr&r<r%r0rr3r4�formatrLr�rrCZ$BaseEventLoop._check_sendfile_params�s����g�d�F�C�0�0��C�D�D��y�y�F�.�.�.��J�K�K����e�S�)�)��A�H�H��O�Q�Q���z� �A�H�H��O�Q�Q��&�#�&�&��B�I�I����
��A�:��B�I�I����
�rc�s� �+kQMQ1QrmVmxk	Ok
WMTVQO5k
Q
MO1Q_NQC!rkm�T�6w^HQ
MQ1J)	Q%^QM1bW	OQ8O/1bQMT�1DOes�I
Q
O9m!W^Rk
OQ8OWQ
1M
1/kW	Q
MQ1k
QMQ
1Ok
=
H�Ok
=
cc9cIhW^*k
QMQ
1Q
_Q
M1bOk
=
cQ
_Q
M1b9cO9mc9c3c)N�r;r<r=F�*error while attempting to bind on address �: z&no matching local address with family=z found)r8r%�setblocking�bindr)r�lower�errno�pop�sock_connectr�)rdrZ	addr_infoZlocal_addr_infosZ
my_exceptionsr;Ztype_r=�_r�r+ZlfamilyZladdrrSr;s               r�
_connect_sockZBaseEventLoop._connect_sock�s}����
����-�(�+4�(��u����#	.��=�=��%�H�D����U�#��+�/?�+�G�Q��1��(� �	2��	�	�%�(��
0@�%�+�/�/�1�1�%�(O��y�PV�&W�X�X��#�#�D�2�2�2��*.�-�J���1#�2�'�',�i�r�#�c�(�.�.�2B�1C�E��&�c�i�i��5��%�,�,�S�1�1��
2��
3���	�� � ��%����
�
����	����
�
����)-�-�J��sk�E,�=D�B8�/?D�.D�/D�4E,�8
D�AD�	D�D�D�
E!�#%E�E!�!E$�$E)�)E,rXr+�
local_addr�happy_eyeballs_delay�
interleave�
all_errorsc	�s�[[[[ �Q
_Q%aWO1bQ
`Q%^Q%aWO1bQk
Q_Q%aWO1bQ_Q%aWO1bQ_WQ1Q
_Q`OkQ`QB_�Q_WO1bPMT#0QWMTgPO5DOes�I
kQ%aWO1bQ	_?PMT�WMQQPO5DOes�I
jP%aWO1bJOjQ%^W
QQ1k+jQ
`&QCkPMPQP1DOes�I
kJ3	J0WMQQQ0O	gQ1Q
PO
5DOes�I
OkQ`�PRRp+pCkQCkQKH	H	pkkjQ%^WOP1bWP1O6X^PObWPO1jWQ0O
gP11%^PObWOMOMOP1111bJ;Q`WO1bQM WM6w^WOQ8/1bPM#T�TJQQO5DOes�I
rkkPM$%^+QM'O1kW(M*OT�QQQ1QQ0!BI
BI�BI�W
^BH�c9cBIdppkkcOjc9cIr3c)Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a host�1ssl_handshake_timeout is only meaningful with ssl�0ssl_shutdown_timeout is only meaningful with sslr�8host/port and sock can not be specified at the same time�r;r<r=r:r��!getaddrinfo() returned empty listc3s8: �QCkQ0QQQ0Oggs�H	d3c)cs*:�PMPQP1!rA)rc)r=r�laddr_infosrds ���rZ<lambda>Z;BaseEventLoop.create_connection.<locals>.<genexpr>.<lambda>zs���$�2D�2D�&��+�3rNrB)rCr=rrmrds  ���rrD�2BaseEventLoop.create_connection.<locals>.<genexpr>ws&�����).�H�)1���).�s�r�rzcreate_connection failedc3s>: �QCkWQ1P6Hs�H	d3crA�r)rCrS�models  �rrDrn�s����G�J�S�s�3�x�5�0�J�s�zMultiple exceptions: {}r7c3s6 �QCkWQ1s�H	d3crAro)rCrSrrrDrn�s���%E�*�3�c�#�h�h�*���z5host and port was not specified and no sock specified�"A Stream Socket was expected, got )r�r�r%z%r connected to %s:%r: (%r, %r))r&rY�_ensure_resolvedr%r0r)rLrcr	Zstaggered_raceZExceptionGroupr�rZallrXrr<�_create_connection_transportr�get_extra_inforr%)rdr�r9r:rXr;r=r:r+rdr�r�r�rerfrg�infosr=ZsubrSrnr�rrmrps`                     @@@r�create_connectionZBaseEventLoop.create_connectionsp����(�&�s��J�K�K��"�s�� �"A�B�B�"�O� �,�S��C�E�
E� �+�C��B�D�
D����d�#��+�
�0B��J���t�/��� �N�P�P��/�/���V��'�'�u��0�N�N�E���A�B�B��%�$(�$9�$9���+�+�5��d�%:�%,�,��#�!�"E�F�F�#�#���-�e�Z�@���J�#�+� %�H�!�%)�%7�%7�&��+�&?� ?���	!&�(�6�6��).�
�)��������|�-7�G�Z�c�3�C�c�3�c�Z�G�
�&�!�,�-G��T�T��:��!�+�(��m�+�!$�J�q�M� 2���G�J�G�G�G�",�Q�-�/�&�&?�&F�&F� �I�I�%E�*�%E�E�'G�H�H��(�|� �K�M�M��y�y�F�.�.�.�!�8���A�C�C�%)�$E�$E��C�"7�!5�%F�%7�7��	�8��;�;��+�+�H�5�D��L�L�:��T�9�h�
@��(�"�"�mN�,�" ?��#�!� �!����H�� "&�J�� 7�s��B1K.�7K�8AK.�8K�96K.�0K
�K�K
�-K.�8K�9K.�K�K.�!BK%�%AK.�9K,�:AK.�K.�K
�

K�K.�K�K.�K.�%K)�)K.c�s8 �QMO1Q1kQM1k	Q%^0WQW1%^OJQk
QM	TT�TTQQO5kJQMTQ	1kQ	DOes�I
T�0!IQM
1b9c3c)NF)r�r�r�r�)r\rbr�boolr�r�r�)rdr+r�rXr�r�r�r�r�r�r�rnr�rrtZ*BaseEventLoop._create_connection_transport�s����	
�����#�%���#�#�%���!+�C��!6�!6��C�J��0�0��
�'�&;�%9�	1�;�I��3�3�D�F�K�I�	��L�L�
�"�"�
��	��O�O���s0�A2B�5B�:B�;B�?B�B�B�Bc�s �QM1%^WO1bWQOWMM
1kQWMM
G^WOQ8/1bQWMMG^QMTT41DOes�I
!Q%aWOQ8/1bQMTT41DOes�I
!I4WM^kQ%abOk=ISOk=cc9cI/3c)NzTransport is closingZ_sendfile_compatiblez(sendfile is not supported for transport zHfallback is disabled and native sendfile is not supported for transport )rgrlrrZ
_SendfileModeZUNSUPPORTEDZ
TRY_NATIVE�_sendfile_nativerrE�_sendfile_fallback)rdrnrGrHrIrBrWrSr�r�sendfileZBaseEventLoop.sendfile�s���0���!�!��5�6�6��y�"8� �.�.�:�:�<���9�*�*�6�6�6��:�9�-�H�J�
J��9�*�*�5�5�5�
�!�2�2�9�39�B�B�B���+�+4�-�9�:�
:��,�,�Y�-3�<�<�	<�B���7�7�
��� ��
��<�sN�BD	�C�'C�(C�+,D	�D�D	�C�D�2C?�:D	�?D�D	c�s6 �WMO1b3c)Nz!sendfile syscall is not supportedrK)rdrerGrHrIr�rryZBaseEventLoop._sendfile_native�s����2�2�/�1�	1�rqc�sX �Q%^QMQ1Q%^WQO1JOkWQ1kOkWQ1kQ%^XWTG*
Q1kQO6:^DQQO6�^$W	QO1%^QMT7*1QM1DOes�I
!W
Q1OQk	QMOQMQ	1DOes�I
k
Q
%aDQQO6�^$W	QO1%^QMT7*1QM1DOes�I
!QM1DOes�I
QMQ	OQ
1Tz*
kBHI�I�I<I%QO6�^$W	QO1%^QMT7*1QM1DOes�I
c9c3c)Ni@rrM)rMrNrOrZr$r}rPr3rQriZwrite)rdrerGrHrIrRrSrTr=rUrVr?rrzZ BaseEventLoop._sendfile_fallback�sn�����I�I�f��).�C��u�%�E�	��	�"���
�)�&�1��	"��� #�E�$6�	� B�I� �A�~�)��A�~�'�$��"7�"7��	�	�&�-�.��-�-�/�!�!�"�#��z�	�2��!�1�1�$��
�
�t�L�L���%�
�A�~�'�$��"7�"7��	�	�&�-�.��-�-�/�!�!�
�k�k�m�#�#����T�%�4�[�)��"�
�
"�M�
"�
$���A�~�'�$��"7�"7��	�	�&�-�.��-�-�/�!�!�s��AF*�	E"�&=F*�#E�$F*�).E"�E�E"�$=F*�!E�"F*�'E"�:E �;E"�F*�E"�F*� E"�">F'� F#�!F'�'F*c�s� �W`WO1bWQWM1%aW	OQ8/1bWQOO1%aW	OQ8O/1bQM
1kWMTT8TEQQOO5	k	QM1QMQ	1QMQ	MQ1k
QMQM1kQDOes�I
Q	M"!IW^2QM1Q
M!1QM!1bc9c3c)Nz"Python ssl module is not availablez@sslcontext is expected to be an instance of ssl.SSLContext, got Z_start_tls_compatibleFz
transport z  is not supported by start_tls())r�r�r�)rXrlrZ
SSLContextr4rrbrZSSLProtocolr_r`r0ror{�
BaseExceptionr�r|Z_app_transport)rdrnr�r�r�r�r�r�r�Zssl_protocolZ
conmade_cbZ	resume_cbr�r�	start_tlsZBaseEventLoop.start_tlss<����;��C�D�D��*�c�n�n�5�5���!�n�&�'�
'��y�"9�5�A�A���Y�M�)I�J�L�
L��#�#�%���+�+��J��"7�!5�!&�(��	���!����|�,��^�^�L�$@�$@�)�L�
��N�N�9�#;�#;�<�	�	��L�L��*�*�*�
���	��O�O�����������		�s0�C'E�*D�/D�0D�4E�D�<D>�>E�
reuse_port�allow_broadcastc
�s~	 �Q	_�Q	MWM6X^WOQ	8/1bQ%a*Q%a#Q%aQ%aQ%aQ%aQ%^EW	T#TEQQQO5k
OMOQ
M
111kWOQO/1bQ	MO1OkBJ�Q%a Q%aQO6X^WO	1bTE0O
00k
BJ�WWO1%^�QWM6X^�T#0C(kQ`HWQW1%^HWO1b	Q%^YQOO
7^PWMWMQ1M 1%^WM"Q1TE0T#000k
BJ,kOQ0OQ00C�rkkQ`HWQW,1%^W/Q1O6XaWO1bQM1T�WM2TVQO5DOes�I
kQ%aW'O1bQC"rkkkkkQQ0kQQ7^OO+QQ$QQQQ$H$	H�	QM
1RRp+pC(rkkQ%^QO`HQ%^QO`H$QQ0KH*	k
kkQ
%aWO1b+kQ
C�rrmErkkOk	OkWMQWM2QO5k	Q%^W5Q	1Q%^/Q	M7WM8WM:O1Q	MO1Q%^Q	M=Q1Q%^#Q%aQM?Q	Q1DOes�I
QkJ	QObQ1kQME1kQMGQ	QQQ1kQMH%^:Q%^W(MJOT#QQ1JW(MLOQQQ1QDOes�I
QQ0!W$^BI}W&^"kW(M*OT/1Ok=BI�Ok=cc9cBI8ppkkcI�W&^1kQ	_Q	MA1QMBQ1Ok=BH�Ok=cQ	_Q	MA1b9cI�QMA1b9c3c)Nz$A datagram socket was expected, got )rd�remote_addrr;r=r:r~rr7c3sD �QCrmQ%aHQOQ/s�H	d3c)Z=NrB)rCZkZvr�rrDZ9BaseEventLoop.create_datagram_endpoint.<locals>.<genexpr>Zs ���$N�L�D�A�A�Z��s�!�A�3�Z�L�s� � zKsocket modifier keyword arguments can not be used when sock is specified. (Z)Frzunexpected address family�NN�AF_UNIXzstring is expected)rZz2Unable to check or remove stale UNIX socket %r: %rrrz2-tuple is expectedrkrlzcan not get address informationrYz@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))'r<r%r0r&ZdictrZitemsr\r$r�rrr4�statZS_ISSOCK�osZst_modeZremoveZFileNotFoundErrorr)r�errorr�r�rsr1r,r'r(ZSO_BROADCASTr]rar�r8rbr�rr9r%) rdr�rdr�r;r=r:r~rr+ZoptsZproblemsZr_addrZaddr_pairs_inforJ�errZ
addr_infosZidxrvZfamrbZpror��keyZ	addr_pairrZ
local_addressZremote_addressrSr�r�rns                                 r�create_datagram_endpointZ&BaseEventLoop.create_datagram_endpointHs�������y�y�F�.�.�.� �:�4�(�C�E�E��k��e�u��/��z�#)�e�'1�,;�=�� �9�9�$N�D�J�J�L�$N�N�� �0�08�z��<�=�=�
���U�#��F��+��Q�;�$�%@�A�A�%+�O�\�#B�"D�����+�+��&�.�.�0H�'�5�D��'�
�4��0E�0E�'�(<�=�=�6��*�Q�-�{�"B�	6��=�=�����)<�)D�)D�E�E��I�I�j�1�&,�O�%/�$=�$?�#B�� �
�#$�j�/�A�{�3C�!D�I�C���'� *�4�� 7� 7�C��I��N�"+�,A�"B�B�&*�&;�&;� �f�6G�6G�"'�4�'<�'A�!A�� %�")�*M�"N�N�7<�3�C��C��G�#&��*�C�"�*�4�37��,�
�3��3:�J�s�O�C�0�	8=�"E�&<F�;K�;K�;M�#E�;M���i�'�I�a�L�%�(�Y�q�\�%�S�)�$�;M� �#E�
'�$�%F�G�G��J�6E�2��&�0�-�������!�=�=�%�F�,=�,=�U�L�D�!�&�t�,�&����"�-�-�v�/B�/B�A�G��$�$�U�+�!��	�	�-�0�"�.�"&�"3�"3�D�.�"I�I�I�!/���96E�<!��m�#�#�%���#�#�%���1�1��(�F�F�,�	��;�;�����0�&�Y��J����(�(�)�X�?�	��L�L�
�(�"�"��}-���"�6����&5�%/�6�6��6�� !A��#E�8J���+��'��
�
���%�%�c�*�*����'��
�
����*
��	��O�O���s��DR=�R=�0R=�AP
�R=�;AR=�Q�AR=�&Q�=Q�Q�(R=�=B;Q�8Q�9Q�?A?R=�?R'�R%�R'�	R=�
Q�R=�	Q�#Q�:R=�Q�R=�R=�Q�
R"�%R	�R=�	R"�"R=�%R'�'R:�:R=c	�s� �QOrmxWTxT#Q+QOL32k	Q	_Q	+!QMTxT#TEO5DOes�I
!I3c)N:NrN:rNN)r;r<r=r:)r@r8)
rdr�r;r<r=r:r�r9r:r9r�rrsZBaseEventLoop._ensure_resolved�sc����R�[�
���D��e�J�g�b�k�J�����6�M��)�)�$�V�05�*�D�D�
D�D�s�6?�=�?c�s� �QMT0QWMT@O5DOes�I
kQ%aWOQ8O/1bQ!I3c)N)r;r<r:r�zgetaddrinfo(z) returned empty list)rsr%r0r))rdr9r:r;r:rvr�r�_create_server_getaddrinfoZ(BaseEventLoop._create_server_getaddrinfo�sX����+�+�T�L��17�1C�1C�27�,�D�D����L���0E�F�G�G���D�s�(A
�A�A
r�r�
reuse_address�
keep_aliver�c
�s�	 �WQW1%^WO1bQ_Q`WO1bQ
_Q`WO1bQ_W	Q1Q`QB_sQ_WO1bQ	`-W
MO6H9%^WMO6gk	+kQO6X^O+kJDWQW1%a)WQWMM1%aQ+kJQkQRp+pCkQMT#QQO5KH	kkWMQ2DOes�I
kW!W"M$M'Q11kO	kQBC)kQrkkkkkW(M(QQQ1kQM3Q1Q	%^/QM5W(M6W(M8O1Q
%^W;Q1Q%^/QM5W(M6W(M<O1W>%^XQW(M@6X^DWCW(O
1%^/QM5W(MDW(MFO1QMIQ1BH,	Q%a"WKOQRp+pCkQOKH
	pk8/1bOkQ%aQCkQMU1H	J>Q`WO1bQMVW(MX6w^WOQ8/1bQ+kQCkQM[O	1H	W]TQT�QQ
1kQ%^.QM_1WM`O1DOes�I
QM,%^W.MbOQ1Q!ppkcBIwW(M*^1QM,%^W.M0O
QQQOO5BH�c9cWJ^�kOQ8OWQ1MM18/kQMNWNMP6X^NQMS1QMU1QM,%^W.M0Q1Ok=BH'WKQMNQ1ObOk=cc9cppkcQ%aQCkQMU1H	cc9cBI`3c)Nz*ssl argument must be an SSLContext or NonerhrirjZposixZcygwinr.)r;r:Fz:create_server() failed to create socket.socket(%r, %r, %r)T��exc_info�IPPROTO_IPV6rZr[z%could not bind on any address out of iz)Neither host/port nor sock were specifiedrrrz
%r is serving)2rrxr4r&rYr�r�rZplatformrrEZabcZIterabler�r
r
ZsetrGrHrIr%r�rr�warningr8r'r(ZSO_REUSEADDRr,ZSO_KEEPALIVEr7rr$r�ZIPV6_V6ONLYr]r)r^r_Z
EADDRNOTAVAILr`r�r<r0r\rr�r�r9)rdr�r9r:r;r:r+r�rXr�r~r�r�r�r�r�ZhostsZfsrvZ	completedZresr>Zsocktyper=Z	canonnameZsar�r;r9r�s                              r�
create_serverZBaseEventLoop.create_server�s.���:�c�4� � ��H�I�I� �,����C�E�
E� �+����B�D�
D����d�#���t�/��� �N�P�P��$� "���7� 2� O�s�|�|�x�7O�
��G��r�z�����T�3�'�'� ��{���'?�'?�@�@������$�%�#�d��1�1�$�V�8=�2�?�#�
�%� �,�,��+�+�E��	���5�5�e�<�=�E��I�5
%� �C�9<�6�B��%��B�!�%�}�}�R��5�A���N�N�4�(�$����"�-�-�v�/B�/B�D�J�!�&�t�,�!����"�-�-�v�/B�/B�D�J�
"�	��&�/�/�1�#�F�N�;�;�����(;�(;�(.�(:�(:�(,�.�
@��	�	�"�
�=!�X�!�:?�%@�%�$�d�1�g�%�%@�#C�D�D�!�	� � '���
�
��!(���|� �!L�M�M��y�y�F�.�.�.� �#E�d�X�!N�O�O��f�G��D����U�#����'7��&;�,�.����!�!�#��+�+�a�.� � ��;�;��K�K���0��
��e%�,��"�<�<�!��;�;�"�N�N�,G�+-�x���O�!�
!��6#�@�#%�c�#�h�n�n�&6� 8���9�9��(;�(;�;�#�K�K�M� �J�J�L�#�{�{� &���s� 3�$�%�c�i�i��5�4�?��@��&A��!� '���
�
��!(�!��(
!�s��A;S�A*S�,N�	S�!N�".S�R� N�8C2R�+O#�<R�R
� R�,B8S�$S�%4S�AO �R�O � R�#
R�-BR�3R�:R�R�R�#S�Sc
�s� �QMWM6w^WOQ8/1bQ_Q%aWO1bQ_Q%aWO1bQ_W	Q1QMT!QOOQQO5DOes�I
rmgQM%^)QMO1kWMOT&Q1Tg0!IC3c)	Nrrrhrir.T)r�r�r�r%z%r handled: (%r, %r))
r<r%r0r&rYrtrrurr%)rdr�r+rXr�r�rnr�r�r�connect_accepted_socketZ%BaseEventLoop.connect_accepted_socketqs����
�9�9��*�*�*��A�$��J�K�K� �,�S��C�E�
E� �+�C��B�D�
D����d�#�$(�$E�$E��C���"7�!5�%F�%7�7��	��;�;��+�+�H�5�D��L�L�/��(�K��"�"�7�s�BC�C�ACc�� �Q1kQM1kQMT#Q1kQDOes�I
QM%^&WM
OQM
1TS1TS0!I>QM1b9c3c)Nz Read pipe %r connected: (%r, %r))rbr�r�rrr%�fileno�rdr�r�r�r�rnr�r�connect_read_pipeZBaseEventLoop.connect_read_pipe�s}���#�%���#�#�%���2�2�4�6�J�	�	��L�L�
�;�;��L�L�;�����	�
=��"�"�
��	��O�O����+�*B	�A3�A1�A3�:B	�1A3�3B�B	c�r�)Nz!Write pipe %r connected: (%r, %r))rbr�r�rrr%r�r�r�r�connect_write_pipeZ BaseEventLoop.connect_write_pipe�s}���#�%���#�#�%���3�3�D�F�K�	�	��L�L�
�;�;��L�L�<�����	�
=��"�"�
��	��O�O���r�cs~�Q+kQ_QMOWQ1/1Q_2QWM6X^QMOWQ1/1J@Q_QMOWQ1/1Q_QMOWQ1/1WM
OM
Q11d)Nzstdin=zstdout=stderr=zstdout=zstderr=Z )r8r"rr rr%r)rdr;r�r�r�r9r�r�_log_subprocessZBaseEventLoop._log_subprocess�s����u�����K�K�&��e�!4� 5�6�7���&�J�,=�,=�"=��K�K�.��f�)=�(>�?�@��!����g�l�6�&:�%;�<�=��!����g�l�6�&:�%;�<�=����S�X�X�d�^�$rr�r�r��universal_newlinesr�r��encoding�errors�textc		�s �WQWW01%aWO1bQ%^WO1bQ%aWO1bQO6w^WO1bQ%^WO1bQ	_WO1bQ
_WO1bQ1k
OkQM%^O	Q*kQMT�TE1QMT�O
T4TX0,Q@2DOes�I
kQM%^Q_WMOT�1T�0!I23c)Nzcmd must be a string� universal_newlines must be Falsezshell must be Truer�bufsize must be 0�text must be False�encoding must be None�errors must be Nonezrun shell command %rT�%s: %r)	rr2rr&rr�r�rr9)rdr�Zcmdr�r�r�r�r�r�r�r�r�r�r��	debug_logrns                r�subprocess_shellZBaseEventLoop.subprocess_shell�s
����#��s�|�,�,��3�4�4���?�@�@���1�2�2��a�<��0�1�1���1�2�2����4�5�5����2�3�3�#�%���	��;�;�/��4�I�� � ��6�B��9�9��4���K�CI�K�K�	��;�;�9�0��K�K��)�7��"�"�	K�s�CD�D	�3Dc		�s� �Q%^WO1bQ%^WO1bQO6w^WO1bQ%^WO1bQ	_WO1bQ
_WO1bQ0Q*kQ1kOkQM%^OQ8/kQMQT4Q1QMT�O	T4QQ0,Q
@2DOes�I
kQM%^Q_WM
O
QQ1QQ0!I43c)Nr�zshell must be Falserr�r�r�r�zexecute program Fr�)r&rr�r�rr9)rdr�Zprogramr�r�r�r�r�r�r�r�r�r�r�Z
popen_argsr�r�rns                  r�subprocess_execZBaseEventLoop.subprocess_exec�s�����?�@�@���2�3�3��a�<��0�1�1���1�2�2����4�5�5����2�3�3��Z�$�&�
�#�%���	��;�;�+�7�+�6�I�� � ��E�6�B��9�9��%��������	��;�;�9�0��K�K��)�Y�7��(�"�"��s�B7C0�9C.�:5C0cr�rA)r�rrr!r�get_exception_handlerZ#BaseEventLoop.get_exception_handlers���&�&�&rcsT�Q_WQ1%aWOQ8/1bTid)Nz+A callable object or None is expected, got )r�r4r�)rdZhandlerrr�set_exception_handlerZ#BaseEventLoop.set_exception_handlers6����x��'8�'8��#�#*�+�/�0�
0�")�rcs��QMO1kQ%aOkQMO1kQ_WQ1T3M0kJOkOQ7^AQM_4QMM%^QMMQO$Q+kWQ1C�kQO7^HTkQO6X^:OM
WMQ11kO	kTxM1*
kJKQO6X^:OM
WMQ11kO
kTxM1*
kJWQ1kQMQOQ/1H�	WMOM
Q1QO
5d)Nrz!Unhandled exception in event looprNFZsource_tracebackZhandle_traceback>rrNr.z+Object created at (most recent call last):
z+Handle created at (most recent call last):
r[Z
r�)�getr<Z
__traceback__r�r�Zsortedr�	tracebackZformat_listZrstriprr8rr�)	rdr�rrNr�Z	log_linesr�ZvalueZtbr?r�default_exception_handlerZ'BaseEventLoop.default_exception_handlersS���+�+�i�(���9�G��K�K��,�	�� ��Y���4K�4K�L�H��H��g�-��$�$�0��$�$�6�6��$�$�6�6�
�&�'��I�	��'�?�C��.�.���L�E��(�(��W�W�Y�2�2�5�9�:��F������$���*�*��W�W�Y�2�2�5�9�:��F������$���U�������u�B�u�g�.�/�#� 	���T�Y�Y�y�)�H�=rc	s��QM`QMQ1dOkQMO1kQ`QMO1kQ`QMO1kQ_!WQO1%^QM1kQ_.WQO1%^QMQMT1dQMT1dWW0^bW^W
MOOO5dc9cWW0^bW^^kQMO	O
OQOQ,1Ok=dWW0^bW^W
MO
OO5Ok=dc9cOk=cc9c)Nz&Exception in default exception handlerTr�r�rr�get_context�runrz$Unhandled error in exception handlerrNr�zeException in default exception handler while handling an unexpected error in custom exception handler)r�r�rOrPr|rr�r�r$r�r�)rdr�ZctxZthingrSr�rrZ$BaseEventLoop.call_exception_handlerJsy��,�"�"�*�	
,��.�.�w�7�$
0������F�+���=�$�K�K��1�E��=�#�K�K��1�E��$���
�)F�)F��+�+�-�C��?�w�s�E�':�':��G�G�D�3�3�T�C��+�+�D�:��3� 1�2�
�� �
,����E�&*�,�	
,��0� 1�2�
�� �
0�0��2�2�!�#I�#�S�!�7�4����
#�$5�6���$�0��L�L�"?�+/�0�0�0��
0�sG�C�BC<�2C<�2C9�8C9�<E4�D3�32E,�%E/�+E,�,E/�/E4cs^�QM%aQMMQ1ddrA)�
_cancelledr�r8�rdrrr�
_add_callbackZBaseEventLoop._add_callback�s"��� � ��K�K���v�&�!rcsF�QMQ1QM1drA)r�r�r�rr�_add_callback_signalsafeZ&BaseEventLoop._add_callback_signalsafe�s�����6�"����rcsR�QM%^Q9MO*
piddrV)r�r�r�rr�_timer_handle_cancelledZ%BaseEventLoop._timer_handle_cancelled�s!������'�'�1�,�'�rcst�WQM1kQW6�^{QMQ*W6�^d+kQMC.kQM
%^	OQiHQM
Q1H0	WMQ1T iOQiJmQM%^\QMOM
%^>Q9MO*piWMQM1kOQiHmOkQM%aQM%^OkJTQM%^CQMOMQM1*
kQW6�^WkJQO6^OkQMM!Q1kQM#Q1OkQM1QM$*kQM%^dQMOkQMQ6�^JDWMQM1kOQiQMM
Q1HuWQM1kW'Q1C�kQMM)1kQM
%^H0QM*%^sT0iQM1k	QM/1QM1Q	*
k
T�M06�^!W2M4OW7Q1Q
1OQiH�QM/1H�	OkdOQic9c)NFrrzExecuting %s took %.3f seconds)r�r��_MIN_SCHEDULED_TIMER_HANDLESr��%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr�r8r/ZheapifyZheappopr�r�Z_whenr��MAXIMUM_SELECT_TIMEOUTZ	_selectorZselectr�r�ZrangeZpopleftrr�Z_runr�rr�r)rdZsched_countZ
new_scheduledrrr�Zend_timeZntodoZir<r>r?rr"ZBaseEventLoop._run_once�si���$�/�/�*���6�6��'�'�+�5�5�
6��M��/�/���$�$�(-�F�%�!�(�(��0�	*�
�M�M�-�(�+�O�*+�D�'��/�/�d�o�o�a�&8�&C�&C��+�+�q�0�+����t���7��$)��!����;�;�$�.�.��G�
�_�_��o�o�a�(�.�.�����<�G��/�/�0���1�����^�^�*�*�7�3�
����Z�(��
��9�9�;��!7�!7�7���o�o��_�_�Q�'�F��|�|�x�'���]�]�4�?�?�3�F� %�F���K�K���v�&��D�K�K� ���u��A��[�[�(�(�*�F�� � ���{�{�	0�+1�(�����B��K�K�M�����r�)�B��8�8�8����'G�'5�f�'=�r�C�,0�D�(����
�!�"���,0�D�(�s
�%A)L.�.	L7cs"�WQ1WQM16X^dQ%^?WM1QiWM
WM1J WM
QM1TidrA)rxr�rZ#get_coroutine_origin_tracking_depthr�Z#set_coroutine_origin_tracking_depthrZDEBUG_STACK_DEPTH�rdZenabledrrrZ,BaseEventLoop._set_coroutine_origin_tracking�sk����=�D��!H�!H�I�I����7�7�9�
�7��3�3��+�+�
-�
�3�3��;�;�
=�3:�/rcr�rA)rrrr!rr�ZBaseEventLoop.get_debugs���{�{�rcst�TiQM1%^QMQMQ1ddrA)rr�r�rr�rrr�ZBaseEventLoop.set_debugs/�����?�?����%�%�d�&I�&I�7�S�r)r�r�r�r�r�r�r�rr�r�r�r�r�r�r�r�r�r�r�r�rA)NNNr�)r)rN)FNN)Zr~rr�r�rfr�rbr�r�r�r�r�r�r�r�r�r�r�r�r�rrrrrrr r!r#r$rQr�r�rrr(r�r�r,r)r0r.r1r-r�r3r6r@r8rArJrDrFrCrcrwrtr{ryrzr}r�r%r0rsr�r5Z
AI_PASSIVEr�r�r�r�r�rrr�r�r�r�r�rr�r�r�r"rr�r�r�r�r�r�rrr�s����/�@
�)����d��*%�"�"�%)�"�26�"�9=�"� �"�26�"��"� $�"�#'�	"�
"&�"�"&�
"�CG�"�
@D�(,�"�
AE�)-�"�04�"�"�"�7�D�G�
"��2�0D�K�'�((� 	(�$�L�*�.�%�M�M��-� ����0�T��$���&%��(�"	�D�	�5� *�
�0H�!"�H�)*�H�23�H�;<�H�7�
A�(,�
A�.�/�4�*).�X59�Q#��Q#� !�Q#��Q#��Q#�$(�Q#��	Q#�.2�	Q#�
#'�Q#�"&�
Q#�"&�Q#�37�Q#��Q#�j*/�"&�!%�	#�8-<�#'�-<�^1�"�2.+�$)�.+�(,�.+�/3�.+�.2�	.+�bEI�D#�./�D#�78�D#�@A�D#�37�D#�8<�	D#�CG�	D#�L
D�&'�
D�.4�.@�.@�
D�%&�
D�./�
D��59�M��#�#�M��#�#�	M�
�M��
M��M��M��M��M�#'�M�"&�M��M�^#��#�#'�#�"&�	#�<#� #� %�"#�%/�_�_�"#�&0�o�o�"#�'1�o�o�"#�38�	"#�
&*�"#�
45�"#�)-�
"#�6:�
"#�AE�
"#�H #�$.�O�O� #�<F�O�O� #�%/�_�_� #�IN� #�%*� #�45� #�(,�	 #�59�	 #�@D�	 #�D'�
*�"0>�dF0�P'�
�
-�
Q�f
:��Trr)rr)r)6rEZcollections.abcZconcurrent.futuresr4r_r/rGr�r%r�rrr�r�rrr�rXZImportErrorr.rrrrrrrr	r
rrr
ZlogrZ__all__r�r�r$r7r�rr"r,r@rLrTrWrYZProtocolrZZAbstractServerrZAbstractEventLooprrBrr�<module>r�s+�� ������	�
������
������������������$��
 #��),�%�
�F�J�'�	�#����J�8�v�,"��6�=�!�!�G�
�>�
A)�	� 2� 2�A)�HK�V�
"�
"�K�\iT�F�,�,�iT��}��
�C��s�D�D�D