OwlCyberSecurity - MANAGER
Edit File: proactor_events.cpython-311.opt-1.pyc
� �����/�g����������������������������d�Z�dZddlZddlZddlZddlZddlZddlZddlZddl m Z �ddl mZ�ddl mZ�ddl m Z �dd l mZ�dd l mZ�ddl mZ�ddl mZ�dd lmZ�d��Z�G�d��dej��������ej��������������������Z�G�d��deej��������������������Z�G�d��deej��������������������Z�G�d��de������������Z�G�d��deej��������������������Z�G�d��deeej��������������������Z �G�d��deeej��������������������Z!�G�d��de j"��������������������Z#dS�)z�Event loop using a proactor and related classes. A proactor is a "notify-on-completion" multiplexer. Currently a proactor is only implemented on Windows with IOCP. )�BaseProactorEventLoop�����N����)�base_events)� constants)�futures)� exceptions)� protocols)�sslproto)� transports)�trsock)�loggerc����������������������t����������j��������|������������|�j��������d<��� �|�����������������������������������|�j��������d<���nE#�t����������j��������$�r3�|�j�������������������������������������������rt����������j ��������d|d��������������Y�nw�xY�wd|�j��������vr? �|� ����������������������������������|�j��������d<���d�S�#�t����������j��������$�r�d�|�j��������d<���Y�d�S�w�xY�wd�S�)N�socket�socknamezgetsockname() failed on %rT��exc_info�peername)r����TransportSocket�_extra�getsocknamer����error�_loop� get_debugr ����warning�getpeername)� transport�socks��� �>/opt/alt/python311/lib64/python3.11/asyncio/proactor_events.py�_set_socket_extrar������s �����!'�!7��!=�!=�I��X��C�'+�'7�'7�'9�'9� ���$�$���<��C��C��C��?�$�$�&�&�� C��N�,�d�T� C�� C�� C�� C���C���� ���)�)�)� 0�+/�+;�+;�+=�+=�I��Z�(�(�(���|�� 0�� 0�� 0�+/�I��Z�(�(�(�(� 0�����*�)s!����;��?A=�<A=� B(��(C�Cc��������������������z�������e�Zd�ZdZ � �d��fd� Zd��Zd��Zd��Zd��Zd��Z d ��Z ej��������fd �Z dd�Zd ��Zd��Zd��Z��xZS�)�_ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc������������������ �����t���������������������������������������������||�������������|����������������������|�������������||�_��������|����������������������|�������������||�_��������d�|�_��������d�|�_��������d�|�_��������d|�_ ��������d|�_ ��������d|�_��������d|�_��������d|�_ ��������|�j���������|�j��������������������������������������������|�j�����������������������������|�j��������j��������|��������������|�(|�j�����������������������������t&����������j��������|d��������������d�S�d�S�)Nr���F)�super�__init__� _set_extra�_sock�set_protocol�_server�_buffer� _read_fut� _write_fut�_pending_write� _conn_lost�_closing�_called_connection_lost�_eof_written�_attachr���� call_soon� _protocol�connection_mader����_set_result_unless_cancelled��self�loopr����protocol�waiter�extra�server� __class__s��� �r���r$���z#_ProactorBasePipeTransport.__init__2���s������ �������%�%�%���������� ����(�#�#�#��������������������� �',��$�!����<�#��L� � �"�"�"�� ���T�^�;�T�B�B�B����J� � ��!E�!'�� /�� /�� /�� /�� /��������c������������������t����|�j���������j��������g}|�j���������|���������������������d�������������n|�j��������r|���������������������d�������������|�j���������/|���������������������d|�j�����������������������������������������������������������|�j���������|���������������������d|�j�����������������������|�j���������|���������������������d|�j�����������������������|�j��������r*|���������������������dt����������|�j������������������������������������|�j ��������r|���������������������d�������������d���������������������d ���������������������|������������������������S�) N�closed�closingzfd=zread=zwrite=zwrite_bufsize=zEOF writtenz<{}>� ) r=����__name__r&����appendr.����filenor*���r+���r)����lenr0����format�join)r7����infos��� r����__repr__z#_ProactorBasePipeTransport.__repr__I���s+�������'�(���:���K�K��!�!�!�!� �]�� #��K�K� �"�"�"��:�!��K�K�3�d�j�/�/�1�1�3�3�4�4�4��>�%��K�K�2���2�2�3�3�3��?�&��K�K�4���4�4�5�5�5��<�� >��K�K�<��T�\�):�):�<�<�=�=�=���� '��K�K� �&�&�&��}�}�S�X�X�d�^�^�,�,�,r>���c�����������������������||�j���������d<���d�S�)N�pipe)r����r7���r���s��� r���r%���z%_ProactorBasePipeTransport._set_extra[���s������"���F���r>���c�����������������������||�_���������d�S��N�r3���)r7���r9���s��� r���r'���z'_ProactorBasePipeTransport.set_protocol^���s ������!����r>���c�����������������������|�j���������S�rO���rP����r7���s��� r����get_protocolz'_ProactorBasePipeTransport.get_protocola���s �������~�r>���c�����������������������|�j���������S�rO���)r.���rR���s��� r���� is_closingz%_ProactorBasePipeTransport.is_closingd���s �������}�r>���c������������������������|�j���������rd�S�d|�_���������|�xj��������dz ��c_��������|�j��������s'|�j��������� |�j�����������������������������|�j��������d��������������|�j���������"|�j��������������������������������������������d�|�_��������d�S�d�S�)NTr���) r.���r-���r)���r+���r���r2����_call_connection_lostr*����cancelrR���s��� r����closez _ProactorBasePipeTransport.closeg���s��������=�� ��F��� ����1�����|�� C��� 7��J� � ��!;�T�B�B�B��>�%��N�!�!�#�#�#�!�D�N�N�N��&�%r>���c������������������v�����|�j����������1�|d|���t����������|���������������|�j���������������������������������������������d�S�d�S�)Nzunclosed transport )�source)r&����ResourceWarningrY���)r7����_warns��� r����__del__z"_ProactorBasePipeTransport.__del__r���sL�������:�!��E�0��0�0�/�$�O�O�O�O��J���������"�!r>����Fatal error on pipe transportc������������������<���� �t����������|t����������������������r2|�j�������������������������������������������rt ����������j��������d|�|d��������������n$|�j�����������������������������|||�|�j��������d��������������|����������������������|�������������d�S�#�|����������������������|�������������w�xY�w)Nz%r: %sTr���)�message� exceptionr���r9���) � isinstance�OSErrorr���r���r ����debug�call_exception_handlerr3����_force_close)r7����excra���s��� r����_fatal_errorz'_ProactorBasePipeTransport._fatal_errorw���s������� #��#�w�'�'�� ��:�'�'�)�)��I��L��4��4�H�H�H�H��� �1�1�&�!$�!%� $�� 3��3�������� ���c�"�"�"�"�"��D���c�"�"�"�"���s����A+B��Bc����������������������|�j����������P|�j��������������������������������������������s7|�|�j������������������������������d��������������n|�j������������������������������|�������������|�j��������r |�j��������rd�S�d|�_��������|�xj��������dz ��c_��������|�j��������r |�j��������������������������������������������d�|�_��������|�j ��������r |�j ��������������������������������������������d�|�_ ��������d|�_ ��������d�|�_��������|�j��������� ��������������������|�j��������|�������������d�S�)NTr���r���)� _empty_waiter�done� set_result� set_exceptionr.���r/���r-���r+���rX���r*���r,���r)���r���r2���rW���)r7���rh���s��� r���rg���z'_ProactorBasePipeTransport._force_close����s���������)�$�2D�2I�2I�2K�2K�)��{��"�-�-�d�3�3�3�3��"�0�0��5�5�5��=�� �T�9�� ��F��� ����1�����?�� #��O�"�"�$�$�$�"�D�O��>�� "��N�!�!�#�#�#�!�D�N�������� ���T�7��=�=�=�=�=r>���c�����������������������|�j���������rd�S� �|�j�����������������������������|�������������t����������|�j��������d������������rA|�j�������������������������������������������dk����r$|�j�����������������������������t����������j���������������������|�j��������� �����������������������������������d�|�_��������|�j ��������}|�|������������������������������������d�|�_ ��������d|�_���������d�S�#�t����������|�j��������d������������rA|�j�������������������������������������������dk����r$|�j�����������������������������t����������j���������������������|�j��������� �����������������������������������d�|�_��������|�j ��������}|�|������������������������������������d�|�_ ��������d|�_���������w�xY�w)N�shutdown���T)r/���r3����connection_lost�hasattrr&���rE���rp���r���� SHUT_RDWRrY���r(����_detach)r7���rh���r<���s��� r���rW���z0_ProactorBasePipeTransport._call_connection_lost����s\������'�� ��F� 0��N�*�*�3�/�/�/���t�z�:�.�.�� 6�4�:�3D�3D�3F�3F�"�3L�3L�� �#�#�F�$4�5�5�5��J�������D�J��\�F��!���� � � �#���+/�D�(�(�(����t�z�:�.�.�� 6�4�:�3D�3D�3F�3F�"�3L�3L�� �#�#�F�$4�5�5�5��J�������D�J��\�F��!���� � � �#���+/�D�(�/�/�/�/s����C��B#E+c������������������P�����|�j���������}|�j���������|t����������|�j��������������������z ��}|S�rO���)r,���r)���rF���)r7����sizes��� r����get_write_buffer_sizez0_ProactorBasePipeTransport.get_write_buffer_size����s+�������"���<�#��C���%�%�%�D��r>����NNN)r_���)rC���� __module__�__qualname__�__doc__r$���rJ���r%���r'���rS���rU���rY����warnings�warnr^���ri���rg���rW���rx���� __classcell__�r=���s���@r���r!���r!���.���s����������������4�4�48�$(�/��/��/��/��/��/�.-��-��-�$#��#��#�"��"��"����������� "�� "�� "��%�M��������� #�� #�� #�� #�>��>��>�(0��0��0�(������������r>���r!���c��������������������N�������e�Zd�ZdZ � �d��fd� Zd��Zd��Zd��Zd��Zd ��Z dd �Z ��xZS�) �_ProactorReadPipeTransportzTransport for read pipes.N����c�������������������������d|�_���������d|�_��������t���������������������������������������������||||||�������������t ����������|������������|�_��������|�j�����������������������������|�j���������������������d|�_��������d�S�)Nrq���TF) �_pending_data_length�_pausedr#���r$���� bytearray�_datar���r2���� _loop_reading) r7���r8���r���r9���r:���r;���r<����buffer_sizer=���s ��� �r���r$���z#_ProactorReadPipeTransport.__init__����sg�������$&��!���� ������t�X�v�u�f�E�E�E��{�+�+�� �� ���T�/�0�0�0�����r>���c������������������"�����|�j����������o|�j���������S�rO���)r����r.���rR���s��� r���� is_readingz%_ProactorReadPipeTransport.is_reading����s�������<��5�� �$5�5r>���c�����������������������|�j���������s|�j��������rd�S�d|�_��������|�j�������������������������������������������rt ����������j��������d|��������������d�S�d�S�)NTz%r pauses reading)r.���r����r���r���r ���re���rR���s��� r���� pause_readingz(_ProactorReadPipeTransport.pause_reading����s\�������=�� �D�L�� ��F������:���!�!�� 4��L�,�d�3�3�3�3�3� 4�� 4r>���c������������������f����|�j���������s|�j��������sd�S�d|�_��������|�j��������� |�j�����������������������������|�j��������d��������������|�j��������}d|�_��������|dk����r.|�j�����������������������������|�j��������|�j��������d�|����������|�������������|�j��������� ����������������������������������rt����������j��������d|��������������d�S�d�S�)NFrq���z%r resumes reading)r.���r����r*���r���r2���r����r�����_data_receivedr����r���r ���re���)r7����lengths��� r����resume_readingz)_ProactorReadPipeTransport.resume_reading����s��������=�� ���� ��F�����>�!��J� � ��!3�T�:�:�:��*��$&��!��B�;�;�� �J� � ��!4�d�j��&��6I�6�R�R�R��:���!�!�� 5��L�-�t�4�4�4�4�4� 5�� 5r>���c������������������F����|�j��������������������������������������������rt����������j��������d|�������������� �|�j�������������������������������������������}n?#�t����������t����������f$�r���t����������$�r!}|�� ��������������������|d�������������Y�d�}~d�S�d�}~ww�xY�w|s|�� �����������������������������������d�S�d�S�)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)r���r���r ���re���r3����eof_received� SystemExit�KeyboardInterrupt� BaseExceptionri���rY���)r7���� keep_openrh���s��� r���� _eof_receivedz(_ProactorReadPipeTransport._eof_received����s��������:���!�!�� 2��L�*�D�1�1�1� ���3�3�5�5�I�I���-�.�� �� �� ���� �� �� �����H� J�� J�� J��F�F�F�F�F����� ���� ��� ��J�J�L�L�L�L�L� �� s����A �� B�%B�Bc����������������������|�j���������r ||�_��������d�S�|dk����r|�������������������������������������d�S�t����������|�j��������t ����������j��������������������r\ �t����������j��������|�j��������|�������������d�S�#�t����������t����������f$�r���t����������$�r!}|����������������������|d�������������Y�d�}~d�S�d�}~ww�xY�w|�j�����������������������������|�������������d�S�)Nr���z3Fatal error: protocol.buffer_updated() call failed.) r����r����r����rc���r3���r ����BufferedProtocol�_feed_data_to_buffered_protor����r����r����ri���� data_received)r7����datar����rh���s��� r���r����z)_ProactorReadPipeTransport._data_received����s��������<�� ��)/�D�%��F��Q�;�;���� � � ��F��d�n�i�&@�A�A�� /� ��6�t�~�t�L�L�L�L�L��� 1�2�� �� �� �� �� �� �� ��!�!�#�#1�2��2��2������������ ����� �N�(�(��.�.�.�.�.s���� A)��)B%�B � B%c������������������(����d}d�} �|�zd�|�_���������|�����������������������������������rK|�����������������������������������}|dk����r! �|dk����r|����������������������||�������������d�S�d�S�|�j��������d�|����������}n|������������������������������������|�j��������r! �|dk����r|����������������������||�������������d�S�d�S�|�j��������s/|�j��������j ��������� ��������������������|�j��������|�j��������������������|�_���������|�j��������s|�j������������������������������|�j ���������������������n�#�t����������$�rW}|�j��������s|����������������������|d�������������n/|�j�������������������������������������������rt#����������j��������dd��������������Y�d�}~nod�}~wt&����������$�r}|����������������������|�������������Y�d�}~nHd�}~wt*����������$�r }|����������������������|d�������������Y�d�}~n d�}~wt,����������j��������$�r�|�j��������s��Y�nw�xY�w|dk����r|����������������������||�������������d�S�d�S�#�|dk����r|����������������������||�������������w�w�xY�w)Nrq���r���z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr���)r*���rl����resultr����r����rX���r.���r����r���� _proactor� recv_intor&����add_done_callbackr�����ConnectionAbortedErrorri���r���r ���re����ConnectionResetErrorrg���rd���r����CancelledError)r7����futr����r����rh���s��� r���r����z(_ProactorReadPipeTransport._loop_reading��s����������- 2����"&����8�8�:�:�� !� �Z�Z�\�\�F���{�{��D���{�{��#�#�D�&�1�1�1�1�1���{�A� �:�g�v�g�.�D�D���J�J�L�L�L��}�� ��2���{�{��#�#�D�&�1�1�1�1�1���{�)��<�� X�!%��!5�!?�!?�� �D�J�!W�!W�����<�� E���0�0��1C�D�D�D����&�� ,�� ,�� ,��=�� ,��!�!�#�'K�L�L�L�L���%�%�'�'�� ,���I�&*�,��,��,��,����������#�� #�� #�� #����c�"�"�"�"�"�"�"�"������� I�� I�� I����c�#G�H�H�H�H�H�H�H�H������(�� �� �� ��=�� �� �� � �������{�{��#�#�D�&�1�1�1�1�1���{��v��{�{��#�#�D�&�1�1�1�1�����sl����7D��+D��*6D�� 'G2�� G�A E#�G2��# G�0F �G2�� G�F2�-G2��2G�G2��G�G2��2H)NNNr����rO���)rC���rz���r{���r|���r$���r����r����r����r����r����r����r���r����s���@r���r����r��������s����������������#�#�48�6;������������6��6��6�4��4��4�&5��5��5�$����� /��/��/�202��02��02��02��02��02��02��02r>���r����c��������������������R�������e�Zd�ZdZdZ��fd�Zd��Zdd�Zd��Zd��Z d ��Z d ��Zd��Z��xZ S�) �_ProactorBaseWritePipeTransportzTransport for write pipes.Tc������������������H�������t������������������������j��������|i�|���d�|�_��������d�S�rO���)r#���r$���rk����r7����args�kwr=���s��� �r���r$���z(_ProactorBaseWritePipeTransport.__init__M��s-������������$�%�"�%�%�%�!����r>���c����������������������t����������|t����������t����������t����������f������������s$t ����������dt����������|������������j������������������������|�j��������rt����������d�������������|�j ���������t����������d�������������|sd�S�|�j ��������r;|�j ��������t����������j��������k����rt����������j��������d�������������|�xj ��������dz ��c_ ��������d�S�|�j���������%|����������������������t����������|��������������������������d�S�|�j��������s*t����������|������������|�_��������|�������������������������������������d�S�|�j�����������������������������|�������������|�������������������������������������d�S�)Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progresszsocket.send() raised exception.r���)r����)rc����bytesr����� memoryview� TypeError�typerC���r0����RuntimeErrorrk���r-���r����!LOG_THRESHOLD_FOR_CONNLOST_WRITESr ���r���r+���� _loop_writingr)����_maybe_pause_protocol�extend)r7���r����s��� r����writez%_ProactorBaseWritePipeTransport.writeQ��sW������$�� �:� >�?�?�� .��-��D�z�z�*�-��-�.��.�� .����� =��;�<�<�<���)��I�J�J�J��� ��F��?�� ���)�"M�M�M���@�A�A�A��O�O�q� �O�O��F���?�"�� ���E�$�K�K��0�0�0�0�0���� )�$�T�?�?�D�L��&�&�(�(�(�(�(�� �L����%�%�%��&�&�(�(�(�(�(r>���Nc���������������������� �|�|�j���������� |�j��������rd�S�d�|�_���������d|�_��������|r|������������������������������������|�|�j��������}d�|�_��������|sg|�j��������r |�j�����������������������������|�j��������d��������������|�j��������r$|�j ��������� ��������������������t����������j���������������������|�� �����������������������������������n�|�j��������j�����������������������������|�j ��������|������������|�_���������|�j��������������������������������������������sHt#����������|������������|�_��������|�j������������������������������|�j���������������������|�������������������������������������n|�j������������������������������|�j���������������������|�j���������#|�j����������|�j�����������������������������d��������������d�S�d�S�d�S�#�t.����������$�r }|����������������������|�������������Y�d�}~d�S�d�}~wt2����������$�r!}|����������������������|d�������������Y�d�}~d�S�d�}~ww�xY�w)Nr���z#Fatal write error on pipe transport)r+���r.���r,���r����r)���r���r2���rW���r0���r&���rp���r����SHUT_WR�_maybe_resume_protocolr�����sendrl���rF���r����r����r����rk���rm���r����rg���rd���ri���)r7����fr����rh���s��� r���r����z-_ProactorBaseWritePipeTransport._loop_writingw��s�����& J��}���!8�T�]�!8����"�D�O�"#�D���� ���� � � ��|��|��#����� J��=��K��J�(�(��)C�T�J�J�J��$��8��J�'�'���7�7�7���+�+�-�-�-�-�"&�*�"6�";�";�D�J��"M�"M�����+�+�-�-��J�*-�d�)�)�D�'��O�5�5�d�6H�I�I�I��.�.�0�0�0�0��O�5�5�d�6H�I�I�I��!�-�$�/�2I��"�-�-�d�3�3�3�3�3��.�-�2I�2I��#�� #�� #�� #����c�"�"�"�"�"�"�"�"�"������� J�� J�� J����c�#H�I�I�I�I�I�I�I�I�I����� J���s)����F ��E/F �� G�F.�. G�;G�Gc�����������������������dS��NT��rR���s��� r���� can_write_eofz-_ProactorBaseWritePipeTransport.can_write_eof�����������tr>���c������������������.�����|��������������������������������������d�S�rO���)rY���rR���s��� r���� write_eofz)_ProactorBaseWritePipeTransport.write_eof���s������� � �����r>���c������������������0�����|�����������������������d��������������d�S�rO����rg���rR���s��� r����abortz%_ProactorBaseWritePipeTransport.abort�������������$�����r>���c�����������������������|�j����������t����������d�������������|�j�������������������������������������������|�_���������|�j���������|�j������������������������������d��������������|�j���������S�)NzEmpty waiter is already set)rk���r����r���� create_futurer+���rm���rR���s��� r����_make_empty_waiterz2_ProactorBaseWritePipeTransport._make_empty_waiter���sX��������)��<�=�=�=�!�Z�5�5�7�7����?�"���)�)�$�/�/�/��!�!r>���c�����������������������d�|�_���������d�S�rO���)rk���rR���s��� r����_reset_empty_waiterz3_ProactorBaseWritePipeTransport._reset_empty_waiter���s������!����r>����NN)rC���rz���r{���r|����_start_tls_compatibler$���r����r����r����r����r����r����r����r���r����s���@r���r����r����G��s����������������$�$� ��"��"��"��"��"�$)��$)��$)�L'J��'J��'J��'J�R���������� �� �� �"��"��"�"��"��"��"��"��"��"r>���r����c��������������������$�������e�Zd�Z��fd�Zd��Z��xZS�)�_ProactorWritePipeTransportc��������������������������t������������������������j��������|i�|���|�j��������j�����������������������������|�j��������d������������|�_��������|�j�����������������������������|�j���������������������d�S�)N����) r#���r$���r���r�����recvr&���r*���r�����_pipe_closedr����s��� �r���r$���z$_ProactorWritePipeTransport.__init__���s\������������$�%�"�%�%�%���-�2�2�4�:�r�B�B�����(�(��):�;�;�;�;�;r>���c������������������������|������������������������������������rd�S�|�j��������rd�S�d�|�_��������|�j���������#|����������������������t�������������������������������������d�S�|�������������������������������������d�S�rO���)� cancelledr.���r*���r+���rg����BrokenPipeErrorrY���)r7���r����s��� r���r����z(_ProactorWritePipeTransport._pipe_closed���sf�������=�=�?�?�� ��F��=�� ��F�����?�&����o�/�/�0�0�0�0�0��J�J�L�L�L�L�Lr>���)rC���rz���r{���r$���r����r���r����s���@r���r����r�������sG���������������<��<��<��<��<� �� �� �� �� �� �� r>���r����c��������������������R�������e�Zd�ZdZ � �d ��fd� Zd��Zd��Zd��Zdd�Zdd�Z dd �Z ��xZS�)�_ProactorDatagramTransporti���Nc�������������������������||�_���������d�|�_��������d|�_��������t���������������������������������������������|||||��������������t����������j����������������������|�_��������|�j��������� ��������������������|�j ���������������������d�S�)Nr���)r:���r;���)�_addressrk����_buffer_sizer#���r$����collections�dequer)���r���r2���r����)r7���r8���r���r9����addressr:���r;���r=���s��� �r���r$���z#_ProactorDatagramTransport.__init__���sp��������� �!������� ������t�X�f�E��J�J�J��#�(�*�*���� ���T�/�0�0�0�0�0r>���c������������������&�����t����������|�|�������������d�S�rO����r���rM���s��� r���r%���z%_ProactorDatagramTransport._set_extra�����������$��%�%�%�%�%r>���c�����������������������|�j���������S�rO���)r����rR���s��� r���rx���z0_ProactorDatagramTransport.get_write_buffer_size���s������� � r>���c������������������0�����|�����������������������d��������������d�S�rO���r����rR���s��� r���r����z _ProactorDatagramTransport.abort���r����r>���c������������������Z����t����������|t����������t����������t����������f������������st ����������dt����������|�������������������������|sd�S�|�j���������"|d�|�j��������fvrt����������d|�j������������������������|�j��������rB|�j��������r;|�j��������t����������j ��������k����rt����������j��������d�������������|�xj��������dz ��c_��������d�S�|�j �����������������������������t����������|������������|f�������������|�xj��������t!����������|������������z ��c_��������|�j���������|�������������������������������������|�������������������������������������d�S�)Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r���)rc���r����r����r����r����r����r����� ValueErrorr-���r���r����r ���r���r)���rD���r����rF���r+���r����r����)r7���r�����addrs��� r����sendtoz!_ProactorDatagramTransport.sendto���s?������$�� �:� >�?�?�� (��J� ��J�J�(��(�� (���� ��F��=�$��d�D�M�5J�)J�)J��C�D�M�C�C�E��E�� E���?�� �t�}�� ���)�"M�M�M���B�C�C�C��O�O�q� �O�O��F�� ����U�4�[�[�$�/�0�0�0����S��Y�Y�&����?�"���� � � �� �"�"�$�$�$�$�$r>���c���������������������� �|�j���������rd�S�d�|�_��������|r|������������������������������������|�j��������r|�j���������r0|�j��������r)|�j��������r |�j�����������������������������|�j��������d��������������d�S�|�j��������� ����������������������������������\��}}|�xj ��������t����������|������������z��c_ ��������|�j���������+|�j��������j��������� ��������������������|�j��������|������������|�_��������n,|�j��������j�����������������������������|�j��������||�������������|�_��������|�j�����������������������������|�j���������������������|�������������������������������������d�S�#�t&����������$�r%}|�j�����������������������������|�������������Y�d�}~d�S�d�}~wt,����������$�r!}|����������������������|d�������������Y�d�}~d�S�d�}~ww�xY�w)N)r����z'Fatal write error on datagram transport)r-���r+���r����r)���r����r.���r���r2���rW����popleftr����rF���r����r����r&���r����r����r����r����rd���r3����error_received� Exceptionri���)r7���r����r����r����rh���s��� r���r����z(_ProactorDatagramTransport._loop_writing��s������ *���� ����#�D�O��� �� � �����<�� �D�O�� �� �� ��=��K��J�(�(��)C�T�J�J�J�����-�-�/�/�J�D�$�����T���*����}�(�"&�*�"6�";�";�D�J�<@�#B��#B�����#'�*�"6�"=�"=�d�j�>B�CG��#>��#I��#I���� �O�-�-�d�.@�A�A�A��'�'�)�)�)�)�)�� ��� /�� /�� /��N�)�)�#�.�.�.�.�.�.�.�.�.������� N�� N�� N����c�#L�M�M�M�M�M�M�M�M�M����� N���s0����D2��AD2��&BD2��2 F �<E� F �)F�F c����������������������d�} �|�j���������r" �|r|�j�����������������������������||�������������d�S�d�S�d�|�_��������|�U|�����������������������������������}|�j��������r$d�} �|r|�j�����������������������������||�������������d�S�d�S�|�j��������� ||�j��������}}n|\��}}|�j���������r" �|r|�j�����������������������������||�������������d�S�d�S�|�j���������0|�j��������j��������� ��������������������|�j ��������|�j��������������������|�_��������n/|�j��������j�����������������������������|�j ��������|�j��������������������|�_��������|�j���������|�j��������� ��������������������|�j���������������������nI#�t����������$�r$}|�j�����������������������������|�������������Y�d�}~n d�}~wt"����������j��������$�r�|�j��������s��Y�nw�xY�w|r|�j�����������������������������||�������������d�S�d�S�#�|r|�j�����������������������������||�������������w�w�xY�wrO���)r-���r3����datagram_receivedr*���r����r.���r����r���r����r����r&����max_size�recvfromr����r����rd���r����r���r����)r7���r����r����r�����resrh���s��� r���r����z(_ProactorDatagramTransport._loop_reading#��sY�������' =���� ��H��� =���0�0��t�<�<�<�<�<� =�� =�?�"�D�N����j�j�l�l���=����D��0��� =���0�0��t�<�<�<�<�<� =�� =�-��=�,�!$�d�m�$�D�D�!$�J�D�$���� �� ��� =���0�0��t�<�<�<�<�<� =�� =���}�(�!%��!5�!:�!:�4�:�;?�=�"J��"J�����"&��!5�!>�!>�t�z�?C�}�"N��"N�����~�)���0�0��1C�D�D�D������ /�� /�� /��N�)�)�#�.�.�.�.�.�.�.�.������(�� �� �� ��=�� �� �� � ������� =���0�0��t�<�<�<�<�<� =�� =��t�� =���0�0��t�<�<�<�<� =���sM����E��&E��5E��4A&E��'F+�� F�E*�%F+��*F�F+��F�F+��+ Gry���rO���)rC���rz���r{���r����r$���r%���rx���r����r����r����r����r���r����s���@r���r����r�������s�����������������H�59�$(�1��1��1��1��1��1�&��&��&�!��!��!� �� �� �%��%��%��%�: *�� *�� *�� *�D)=��)=��)=��)=��)=��)=��)=��)=r>���r����c�������������������������e�Zd�ZdZd��Zd��ZdS�)�_ProactorDuplexPipeTransportzTransport for duplex pipes.c�����������������������dS�)NFr����rR���s��� r���r����z*_ProactorDuplexPipeTransport.can_write_eofT��s�������ur>���c�����������������������t������������rO���)�NotImplementedErrorrR���s��� r���r����z&_ProactorDuplexPipeTransport.write_eofW��s������!�!r>���N)rC���rz���r{���r|���r����r����r����r>���r���r����r����O��s:���������������&�%������"��"��"��"��"r>���r����c��������������������R�������e�Zd�ZdZej��������j��������Z � �d��fd� Zd��Z d��Z d��Z��xZS�)�_ProactorSocketTransportz Transport for connected sockets.Nc������������������|������t���������������������������������������������||||||�������������t����������j��������|�������������d�S�rO���)r#���r$���r����_set_nodelayr6���s��� �r���r$���z!_ProactorSocketTransport.__init__b��s<������� ������t�X�v�u�f�E�E�E�� ��&�&�&�&�&r>���c������������������&�����t����������|�|�������������d�S�rO���r����rM���s��� r���r%���z#_ProactorSocketTransport._set_extrag��r����r>���c�����������������������dS�r����r����rR���s��� r���r����z&_ProactorSocketTransport.can_write_eofj��r����r>���c�����������������������|�j���������s|�j��������rd�S�d|�_��������|�j���������&|�j�����������������������������t ����������j���������������������d�S�d�S�r����)r.���r0���r+���r&���rp���r���r����rR���s��� r���r����z"_ProactorSocketTransport.write_eofm��sQ�������=�� �D�-�� ��F� ����?�"��J�����/�/�/�/�/��#�"r>���ry���) rC���rz���r{���r|���r���� _SendfileMode� TRY_NATIVE�_sendfile_compatibler$���r%���r����r����r���r����s���@r���r����r����[��s�����������������+�*�$�2�=��48�$(�'��'��'��'��'��'� &��&��&������0��0��0��0��0��0��0r>���r����c����������������������������e�Zd�Z��fd�Z � �d d�Z �d!ddddddd�d�Z �d d�Z � �d"d�Z � �d"d �Z � �d"d �Z ��fd�Z d��Zd ��Zd��Z d#d�Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd!d�Zd��Z � � �d$d�Zd��Zd��Zd��Z��xZS�)%r���c�����������������������t������������������������������������������������������������t����������j��������d|j��������j���������������������||�_��������||�_��������d�|�_��������i�|�_ ��������|� ��������������������|��������������|�������������������������������������t����������j ����������������������t����������j����������������������u�r-t����������j��������|�j��������������������������������������������������������d�S�d�S�)NzUsing proactor: %s)r#���r$���r ���re���r=���rC���r����� _selector�_self_reading_future�_accept_futures�set_loop�_make_self_pipe� threading�current_thread�main_thread�signal� set_wakeup_fd�_csockrE���)r7����proactorr=���s��� �r���r$���zBaseProactorEventLoop.__init__w��s�������� ����������)�8�+=�+F�G�G�G�!���!���$(��!�!������$�����������#�%�%��)>�)@�)@�@�@�� ���!3�!3�!5�!5�6�6�6�6�6��A�@r>���Nc������������������*�����t����������|�|||||������������S�rO���)r����)r7���r���r9���r:���r;���r<���s��� r����_make_socket_transportz,BaseProactorEventLoop._make_socket_transport���s!������'��d�H�f�(-�v�7��7�� 7r>���F)�server_side�server_hostnamer;���r<����ssl_handshake_timeout�ssl_shutdown_timeoutc���������� �������p�����t����������j��������|�|||||| | �������������}t����������|�||||��������������|j��������S�)N)r��r���r;���r<���)r ����SSLProtocolr�����_app_transport)r7����rawsockr9���� sslcontextr:���r��r��r;���r<���r��r���ssl_protocols��� r����_make_ssl_transportz)BaseProactorEventLoop._make_ssl_transport���s\������� �+��h� �F��_�&;�%9� ;��;��;�� � !��w��',�V� =�� =�� =�� =��*�*r>���c������������������*�����t����������|�|||||������������S�rO���)r����)r7���r���r9���r����r:���r;���s��� r����_make_datagram_transportz.BaseProactorEventLoop._make_datagram_transport���s!������)�$��h��*0�%�9��9�� 9r>���c������������������(�����t����������|�||||������������S�rO���)r�����r7���r���r9���r:���r;���s��� r����_make_duplex_pipe_transportz1BaseProactorEventLoop._make_duplex_pipe_transport���s"������+�D�,0�(�F�E�K��K�� Kr>���c������������������(�����t����������|�||||������������S�rO���)r����r!��s��� r����_make_read_pipe_transportz/BaseProactorEventLoop._make_read_pipe_transport���s������)�$��h���N�N�Nr>���c������������������(�����t����������|�||||������������S�rO���)r����r!��s��� r����_make_write_pipe_transportz0BaseProactorEventLoop._make_write_pipe_transport���s$�������+�4�+/��6�5�J��J�� Jr>���c������������������������|�������������������������������������rt����������d�������������|������������������������������������rd�S�t����������j����������������������t����������j����������������������u�rt ����������j��������d�������������|�������������������������������������|�� �����������������������������������|�j ��������������������������������������������d�|�_ ��������d�|�_��������t������������������������������������������������������������d�S�)Nz!Cannot close a running event looprq���)� is_runningr����� is_closedr ��r ��r��r��r ���_stop_accept_futures�_close_self_piper����rY���r��r#���)r7���r=���s��� �r���rY���zBaseProactorEventLoop.close���s���������?�?���� D��B�C�C�C��>�>���� ��F��#�%�%��)>�)@�)@�@�@�� ��$�$�$�� �!�!�#�#�#��������������������� ��� � �����r>���c�������������������H���K����|�j������������������������������||��������������d�{V���S�rO���)r����r����)r7���r����ns��� r���� sock_recvzBaseProactorEventLoop.sock_recv���s0�����������^�(�(��q�1�1�1�1�1�1�1�1�1r>���c�������������������H���K����|�j������������������������������||��������������d�{V���S�rO���)r����r����)r7���r����bufs��� r����sock_recv_intoz$BaseProactorEventLoop.sock_recv_into���s0�����������^�-�-�d�C�8�8�8�8�8�8�8�8�8r>���c�������������������H���K����|�j������������������������������||��������������d�{V���S�rO���)r����r����)r7���r����bufsizes��� r���� sock_recvfromz#BaseProactorEventLoop.sock_recvfrom���s0�����������^�,�,�T�7�;�;�;�;�;�;�;�;�;r>���r���c�������������������l���K����|st����������|������������}|�j�����������������������������|||��������������d�{V���S�rO���)rF���r����� recvfrom_into)r7���r���r0���nbytess��� r����sock_recvfrom_intoz(BaseProactorEventLoop.sock_recvfrom_into���sE������������ ���X�X�F��^�1�1�$��V�D�D�D�D�D�D�D�D�Dr>���c�������������������H���K����|�j������������������������������||��������������d�{V���S�rO���)r����r����)r7���r���r����s��� r����sock_sendallz"BaseProactorEventLoop.sock_sendall���s0�����������^�(�(��t�4�4�4�4�4�4�4�4�4r>���c�������������������L���K����|�j������������������������������||d|��������������d�{V���S�)Nr���)r����r����)r7���r���r����r����s��� r����sock_sendtoz!BaseProactorEventLoop.sock_sendto���s4�����������^�*�*�4��q�'�B�B�B�B�B�B�B�B�Br>���c�������������������H���K����|�j������������������������������||��������������d�{V���S�rO���)r�����connect)r7���r���r����s��� r����sock_connectz"BaseProactorEventLoop.sock_connect���s0�����������^�+�+�D�'�:�:�:�:�:�:�:�:�:r>���c�������������������F���K����|�j������������������������������|��������������d�{V���S�rO���)r�����acceptrM���s��� r����sock_acceptz!BaseProactorEventLoop.sock_accept���s.�����������^�*�*�4�0�0�0�0�0�0�0�0�0r>���c���������������������K���� �|������������������������������������}n2#�t����������t����������j��������f$�r}t ����������j��������d�������������d�}~ww�xY�w �t ����������j��������|������������j��������}n"#�t����������$�r�t ����������j��������d�������������w�xY�w|r|n|}|sdS�t����������|d������������}|rt����������||z���|������������n|} t����������||������������}d} � �t����������| |z ��|������������}|dk����r| | dk����r|���������������������|�������������S�S�|�j��������� ��������������������||||��������������d�{V����||z ��}| |z ��} �e#�| dk����r|���������������������|�������������w�w�xY�w)Nznot a regular filer���l������)rE����AttributeError�io�UnsupportedOperationr����SendfileNotAvailableError�os�fstat�st_sizerd����min�seekr�����sendfile)r7���r����file�offset�countrE����err�fsize� blocksize�end_pos� total_sents��� r����_sock_sendfile_nativez+BaseProactorEventLoop._sock_sendfile_native���s���������� M��[�[�]�]�F�F���� 7�8�� M�� M�� M��6�7K�L�L�L����� M���� M��H�V�$�$�,�E�E���� M�� M�� M��6�7K�L�L�L� M����"�-�E�E�� ��� ��1�� �;�/�/� �05�@�#�f�u�n�e�,�,�,�5���V�U�#�#��� � "� (���&� 0�)�<�<� ���>�>�%� ��A�~�~�� � �&�!�!�!�!��� ��n�-�-�d�D�&�)�L�L�L�L�L�L�L�L�L��)�#���i�'� � (����A�~�~�� � �&�!�!�!�!�����s2������A�A�A�A&��&B�D2��.D2��2Ec���������������������K����|������������������������������������}|������������������������������������|�������������������������������������d�{V���� �|����������������������|j��������|||d���������������d�{V��� �|������������������������������������|r|������������������������������������S�S�#�|������������������������������������|r|������������������������������������w�w�xY�w)NF)�fallback)r����r����r����� sock_sendfiler&���r����r����)r7����transprN��rO��rP��r����s��� r����_sendfile_nativez&BaseProactorEventLoop._sendfile_native���s ����������*�*�,�,���������'�'�)�)�)�)�)�)�)�)�)� (��+�+�F�L�$���5:��,��<��<��<��<��<��<��<��<�� <�� �&�&�(�(�(��� (��%�%�'�'�'�'� (��� �&�&�(�(�(��� (��%�%�'�'�'�'� (���s����$B��-Cc������������������������|�j���������� |�j���������������������������������������������d�|�_���������|�j��������������������������������������������d�|�_��������|�j��������������������������������������������d�|�_��������|�xj��������dz��c_��������d�S�)Nr���)r��rX����_ssockrY���r��� _internal_fdsrR���s��� r���r+��z&BaseProactorEventLoop._close_self_pipe��sx�������$�0��%�,�,�.�.�.�(,�D�%������������������������a�����r>���c������������������������t����������j����������������������\��|�_��������|�_��������|�j�����������������������������d�������������|�j�����������������������������d�������������|�xj��������dz ��c_��������d�S�)NFr���)r���� socketpairr]��r���setblockingr^��rR���s��� r���r��z%BaseProactorEventLoop._make_self_pipe��s_������#)�#4�#6�#6� ���T�[������&�&�&������&�&�&����a�����r>���c������������������r���� �|�|�������������������������������������|�j��������|urd�S�|�j�����������������������������|�j��������d������������}||�_��������|���������������������|�j���������������������d�S�#�t����������j��������$�r�Y�d�S�t����������t����������f$�r���t����������$�r$}|����������������������d||�d��������������Y�d�}~d�S�d�}~ww�xY�w)Ni���z.Error on reading from the event loop self pipe)ra���rb���r8���) r����r��r����r����r]��r�����_loop_self_readingr���r����r����r����r����rf���)r7���r����rh���s��� r���rc��z(BaseProactorEventLoop._loop_self_reading��s����� 9��}���� � � ��(��1�1������#�#�D�K��6�6�A��)*�D�%� ���� 7�8�8�8�8�8����(�� �� �� ��F�F��-�.�� �� �� ���� �� �� ��'�'�K� ��)��)�� �� �� �� �� �� �� �� �� ����� ���s"����A&�� A&��&B6�8B6�B1�1B6c�����������������������|�j���������}|�d�S� �|���������������������d�������������d�S�#�t����������$�r$�|�j��������rt ����������j��������dd��������������Y�d�S�Y�d�S�w�xY�w)N�����z3Fail to write a null byte into the self-pipe socketTr���)r��r����rd����_debugr ���re���)r7����csocks��� r����_write_to_selfz$BaseProactorEventLoop._write_to_self1��s������������=��F� ,��J�J�u��������� ,�� ,�� ,��{�� ,����0�&*�,��,��,��,��,��,��,� ,�� ,�� ,� ,���s����$��'A�A�d���c����������� �������Z��������������d���������fd� ���������������������������������������d�S�)Nc����������� �������F����� �|��||�������������������������������������\��}}�j��������rt����������j��������d�||�����������������������������}�� ����������������������||�dd|i�� ���������������n����������������������||d|i���������������������������������������������������rd�S��j������������������������������ ������������}�|��j ��������� � ����������������������������������<���|������������������������������������d�S�#�t����������$�r�}� � ����������������������������������dk����r@�� ��������������������d|t����������j��������� ������������d��������������� ������������������������������������n*�j��������rt����������j��������d � d� �������������Y�d�}~d�S�Y�d�}~d�S�Y�d�}~d�S�d�}~wt"����������j��������$�r�� ������������������������������������Y�d�S�w�xY�w)Nz#%r got a new connection from %r: %rTr���)r��r;���r<���r��r��r��rq���zAccept failed on a socket)ra���rb���r���zAccept failed on socket %rr���)r����rf��r ���re���r��r��r)��r����rA��r��rE���r����rd���rf���r���r���rY���r���r����) r�����connr����r9���rh���r8����protocol_factoryr7���r<���r���r��r��r��s ��� ��������r���r8���z2BaseProactorEventLoop._start_serving.<locals>.loopH��sD������# *��=�!"�����J�D�$��{��9���%J�%+�T�4�9��9��9�/�/�1�1�H�!�-��0�0� �(�J�D�#-�t�"4�V�2G�1E� �1��G��G��G��G���3�3� �(�#-�t�"4�V��4��E��E��E���>�>�#�#����F��N�)�)�$�/�/���78��$�T�[�[�]�]�3��#�#�D�)�)�)�)�)����� 6�� 6�� 6��;�;�=�=�B�&�&��/�/�#>�%(�"(�"8��">�">�1��1������� ��J�J�L�L�L�L��[��6��L�!=�!%��6��6��6��6��6��6��6��6��6��6�6��6��6��6��6��6��!�L�L�L�L�L�������,�� �� �� �� � ������� ���s%����BC$��C$��$ F �.A6E6�6&F �F rO���)r2���) r7���rm��r���r��r<����backlogr��r��r8���s ���````` ``@r����_start_servingz$BaseProactorEventLoop._start_servingC��sf�������������� $ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *��$ *�L� ���t�����r>���c�����������������������d�S�rO���r����)r7���� event_lists��� r����_process_eventsz%BaseProactorEventLoop._process_eventsp��s�������r>���c�����������������������|�j��������������������������������������������D�]}|�������������������������������������|�j���������������������������������������������d�S�rO���)r���valuesrX����clear)r7����futures��� r���r*��z*BaseProactorEventLoop._stop_accept_futurest��sJ�������*�1�1�3�3�� �� �F��M�M�O�O�O�O���"�"�$�$�$�$�$r>���c������������������������|�j������������������������������|�����������������������������������d�������������}|r|������������������������������������|�j�����������������������������|�������������|������������������������������������d�S�rO���)r���poprE���rX���r����� _stop_servingrY���)r7���r���rv��s��� r���ry��z#BaseProactorEventLoop._stop_servingy��s^�������%�)�)�$�+�+�-�-��>�>���� ��M�M�O�O�O���$�$�T�*�*�*�� � �����r>���ry���rO���r����)r���)NNri��NN)rC���rz���r{���r$���r��r��r��r"��r$��r&��rY���r.��r1��r4��r8��r:��r<��r?��rB��rV��r[��r+��r��rc��rh��ro��rr��r*��ry��r���r����s���@r���r���r���u��sS��������������7��7��7��7��7��=A�26�7��7��7��7��9=� +� �$��t�"&�!%� +�� +�� +�� +�� +� �CG�9��9��9��9� �BF�*.�K��K��K��K� �@D�(,�O��O��O��O��AE�)-�J��J��J��J����������(2��2��2�9��9��9�<��<��<�E��E��E��E�5��5��5�C��C��C�;��;��;�1��1��1�"��"��"�: (�� (�� (� �� �� � �� �� �9��9��9��9�8,��,��,�&�>A�-1�,0�+��+��+��+�Z �� �� �%��%��%� ������������r>���r���)$r|����__all__rE��rH��r���r}���r��r ��r������r���r���r���r���r ���r ���r���r����logr ���r����_FlowControlMixin� BaseTransportr!���� ReadTransportr�����WriteTransportr����r�����DatagramTransportr����� Transportr����r����� BaseEventLoopr���r����r>���r����<module>r������s���������#��� � � � �� � � � �� � � � ������� � � � �����������������������������������������������������������������������������������������������������������������������������0��0��0�$D��D��D��D��D��!=�!+�!9�D��D��D�NO2��O2��O2��O2��O2�!;�!+�!9�O2��O2��O2�dk"��k"��k"��k"��k"�&@�&0�&?�k"��k"��k"�\���������"A�������,A=��A=��A=��A=��A=�!;�!+�!=�A=��A=��A=�H "�� "�� "�� "�� "�#=�#B�#-�#7� "�� "�� "�0��0��0��0��0�9�>�)�3�0��0��0�4I��I��I��I��I�K�5��I��I��I��I��Ir>���