OwlCyberSecurity - MANAGER
Edit File: windows_events.cpython-312.opt-2.pyc
� ������hK���������������������������� �d�dl�Z�e�j������������������dk7��r�ed��������d�dlZd�dlZd�dlZd�dlmZ�d�dlZd�dl Z d�dl Z d�dlZd�dlZd�dl Z ddlmZ�ddlmZ�ddlmZ�dd lmZ�dd lmZ�ddlmZ�ddlmZ�dd lmZ�ddlmZ�dZej4������������������Zej6������������������ZdZdZdZdZ�G�d��dej@�������������������������Z!�G�d��dej@�������������������������Z"�G�d��de"�������Z#�G�d��de"�������Z$�G�d��de%�������Z&�G�d��dejN�������������������������Z(�G�d ��d!ejR�������������������������Z*�G�d"��d#�������Z+�G�d$��d%ejX�������������������������Z-e(Z.�G�d&��d'ej^�������������������������Z0�G�d(��d)ej^�������������������������Z1e1Z2y)*�����N�win32z win32 only)�partial����)�events)�base_subprocess)�futures)� exceptions)�proactor_events)�selector_events)�tasks)� windows_utils)�logger)�SelectorEventLoop�ProactorEventLoop�IocpProactor�DefaultEventLoopPolicy�WindowsSelectorEventLoopPolicy�WindowsProactorEventLoopPolicyi���i���g����MbP?g�������?c��������������������V�������e�Zd�Z �dd���fd� Z��fd�Zd��Zd ��fd� Z��fd�Z��fd�Z��xZ S�) �_OverlappedFutureN��loopc�����������������f������t����������|����|���������|�j������������������r |�j������������������d=�||�_��������y��Nr������)�super�__init__�_source_traceback�_ov)�self�ovr���� __class__s��� ��=/opt/alt/python312/lib64/python3.12/asyncio/windows_events.pyr���z_OverlappedFuture.__init__7���s1������� ���d��#��!�!��&�&�r�*��������c�������������������������t����������|������������}|�j�������������������H|�j������������������j������������������rdnd}|j ������������������dd|��d|�j������������������j ������������������d�d���������|S�)N�pending� completedr���zoverlapped=<z, �#x�>)r���� _repr_infor���r&����insert�address�r ����info�stater"���s��� �r#���r*���z_OverlappedFuture._repr_info=���s\��������w�!�#���8�8��!%���!1�!1�I�{�E��K�K��\�%���4�8�8�3C�3C�B�2G�q�I�J��r$���c����������������������|�j��������������������y� �|�j�������������������j���������������������������d�|�_���������y�#�t��������$�rM}d||�d�}|�j������������������r|�j������������������|d<���|�j������������������j������������������|��������Y�d�}~d�|�_���������y�d�}~ww�xY�w)Nz&Cancelling an overlapped future failed��message� exception�future�source_traceback)r����cancel�OSErrorr����_loop�call_exception_handler)r ����exc�contexts��� r#����_cancel_overlappedz$_OverlappedFuture._cancel_overlappedD���s��������8�8��� 7��H�H�O�O���������� 7�C� ���G� ��%�%�.2�.D�.D��*�+��J�J�-�-�g�6�6����� 7�s����1�� B�<B�Bc������������������D������|�j���������������������������t���������|�� ��|��������S��N)�msg)r<���r���r6����r ���r?���r"���s��� �r#���r6���z_OverlappedFuture.cancelT���s ����������!��w�~�#�~�&�&r$���c������������������D������t����������|����|��������|�j���������������������������y��N)r���� set_exceptionr<����r ���r3���r"���s��� �r#���rC���z_OverlappedFuture.set_exceptionX���s������� ���i�(����!r$���c������������������2������t����������|����|��������d�|�_��������y�rB���)r���� set_resultr����r ����resultr"���s��� �r#���rF���z_OverlappedFuture.set_result\���s������� ���6�"���r$���rB���) �__name__� __module__�__qualname__r���r*���r<���r6���rC���rF���� __classcell__�r"���s���@r#���r���r���1���s0�������� �$(����� '�"���r$���r���c��������������������b�������e�Zd�Z �dd���fd� Zd��Z��fd�Zd��Zd��Zd��fd� Z��fd �Z ��fd �Z ��xZS�)�_BaseWaitHandleFutureNr���c�����������������������t����������|����|���������|�j������������������r |�j������������������d=�||�_��������||�_��������||�_��������d|�_��������y�)Nr���r���T)r���r���r���r����_handle�_wait_handle�_registered)r ���r!����handle�wait_handler���r"���s��� �r#���r���z_BaseWaitHandleFuture.__init__d���sL������� ���d��#��!�!��&�&�r�*��������'���� ��r$���c������������������d�����t��������j������������������|�j������������������d�������t���������j������������������k(��S��Nr���)�_winapi�WaitForSingleObjectrQ���� WAIT_OBJECT_0�r ���s��� r#����_pollz_BaseWaitHandleFuture._pollr���s)�������+�+�D�L�L�!�<��%�%�&�� 'r$���c�����������������������t����������|������������}|j������������������d|�j������������������d����������|�j�������������������%|�j ��������������������������rdnd}|j������������������|��������|�j �������������������|j������������������d|�j ������������������d����������|S�)Nzhandle=r(����signaled�waitingzwait_handle=)r���r*����appendrQ���r\���rR���r-���s��� �r#���r*���z _BaseWaitHandleFuture._repr_infow���s|��������w�!�#�����g�d�l�l�2�.�/�0��<�<�#�"&�*�*�,�J�I�E��K�K������(��K�K�,�t�'8�'8��&<�=�>��r$���c�����������������������d�|�_���������y�rB���)r���)r ����futs��� r#����_unregister_wait_cbz)_BaseWaitHandleFuture._unregister_wait_cb����s���������r$���c����������������������|�j�������������������sy�d|�_���������|�j������������������}d�|�_�������� �t��������j������������������|��������|�j������������������d���������y�#�t��������$�rh}|j ������������������t��������j������������������k7��rAd||�d�}|�j������������������r|�j������������������|d<���|�j������������������j������������������|��������Y�d�}~y�Y�d�}~�~d�}~ww�xY�w�NFz$Failed to unregister the wait handler1���r5���)rS���rR����_overlapped�UnregisterWaitr7����winerror�ERROR_IO_PENDINGr���r8���r9���rc����r ���rU���r:���r;���s��� r#����_unregister_waitz&_BaseWaitHandleFuture._unregister_wait����s����������� ����'�'�� ��� ��&�&�{�3�� � � ��&����� ��|�|�{�;�;�;�E�!$�"��� ��)�)�26�2H�2H�G�.�/�� � �1�1�'�:���<�� �s����A�� C�AB<�<Cc������������������D������|�j���������������������������t���������|�� ��|��������S�r>���)rk���r���r6���r@���s��� �r#���r6���z_BaseWaitHandleFuture.cancel����s ������������w�~�#�~�&�&r$���c������������������D������|�j���������������������������t���������|�� ��|��������y�rB���)rk���r���rC���rD���s��� �r#���rC���z#_BaseWaitHandleFuture.set_exception����s����������� ���i�(r$���c������������������D������|�j���������������������������t���������|�� ��|��������y�rB���)rk���r���rF���rG���s��� �r#���rF���z _BaseWaitHandleFuture.set_result����s����������� ���6�"r$���rB���)rI���rJ���rK���r���r\���r*���rc���rk���r6���rC���rF���rL���rM���s���@r#���rO���rO���a���s6�������<�8<�� �'� �� '�0'�)�#��#r$���rO���c��������������������@�������e�Zd�Z �dd���fd� Zd��Z��fd�Z��fd�Z��xZS�)�_WaitCancelFutureNr���c�����������������:������t����������|����||||���������d�|�_��������y�)Nr���)r���r����_done_callback)r ���r!����eventrU���r���r"���s��� �r#���r���z_WaitCancelFuture.__init__����s!������� ����U�K�d��;�"��r$���c�����������������������t��������d��������)Nz'_WaitCancelFuture must not be cancelled)�RuntimeErrorr[���s��� r#���r6���z_WaitCancelFuture.cancel����s�������D�E�Er$���c������������������`������t����������|����|��������|�j�������������������|�j������������������|���������y�y�rB���)r���rF���rr���rG���s��� �r#���rF���z_WaitCancelFuture.set_result����s/������� ���6�"����*�����%��+r$���c������������������`������t����������|����|��������|�j�������������������|�j������������������|���������y�y�rB���)r���rC���rr���rD���s��� �r#���rC���z_WaitCancelFuture.set_exception����s/������� ���i�(����*�����%��+r$���)rI���rJ���rK���r���r6���rF���rC���rL���rM���s���@r#���rp���rp�������s'���������8<��#� F�&� &��&r$���rp���c��������������������4�������e�Zd�Zdd���fd� Z��fd�Zd��Z��xZS�)�_WaitHandleFutureNr���c�����������������������t����������|����||||���������||�_��������d|�_��������t ��������j ������������������d�ddd��������|�_��������d�|�_��������y�)Nr���TF)r���r���� _proactor�_unregister_proactorrf����CreateEvent�_event� _event_fut)r ���r!���rT���rU����proactorr���r"���s��� �r#���r���z_WaitHandleFuture.__init__����sG������� ����V�[�t��<�!���$(��!�!�-�-�d�D�%��F�����r$���c�������������������������|�j��������������������-t��������j������������������|�j���������������������������d�|�_���������d�|�_��������|�j������������������j������������������|�j��������������������������d�|�_��������t���������|��!��|��������y�rB���) r~���rX����CloseHandler���r{����_unregisterr���r���rc���)r ���rb���r"���s��� �r#���rc���z%_WaitHandleFuture._unregister_wait_cb����sY��������;�;�"�������,��D�K�"�D�O�� ���"�"�4�8�8�,���� ��#�C�(r$���c�����������������������|�j�������������������sy�d|�_���������|�j������������������}d�|�_�������� �t��������j������������������||�j��������������������������|�j������������������j������������������|�j������������������|�j�������������������������|�_��������y�#�t ��������$�rh}|j������������������t��������j������������������k7��rAd||�d�}|�j������������������r|�j������������������|d<���|�j������������������j������������������|��������Y�d�}~y�Y�d�}~��d�}~ww�xY�wre���)rS���rR���rf����UnregisterWaitExr~���r7���rh���ri���r���r8���r9���r{����_wait_cancelrc���r���rj���s��� r#���rk���z"_WaitHandleFuture._unregister_wait����s����������� ����'�'�� ��� ��(�(��d�k�k�B���.�.�5�5�d�k�k�6:�6N�6N�P������� ��|�|�{�;�;�;�E�!$�"��� ��)�)�26�2H�2H�G�.�/�� � �1�1�'�:���<�� �s���� A?��? C0�AC+�+C0)rI���rJ���rK���r���rc���rk���rL���rM���s���@r#���ry���ry�������s�������BF���)�$Pr$���ry���c��������������������0�����e�Zd�Z �d��Zd��Zd��Zd��Zd��ZeZy)� PipeServerc�����������������������||�_���������t��������j��������������������������|�_��������d�|�_��������d�|�_��������|�j ������������������d�������|�_��������y��NT)�_address�weakref�WeakSet�_free_instances�_pipe�_accept_pipe_future�_server_pipe_handle)r ���r,���s��� r#���r���zPipeServer.__init__����s;�������� �&���0������ �#'�� ��-�-�d�3�� r$���c������������������L�����|�j�������������������|�j������������������d�������c}|�_���������|S��NF)r����r����)r ����tmps��� r#����_get_unconnected_pipez PipeServer._get_unconnected_pipe��s%������ ��*�*�d�&>�&>�u�&E���T�Z�� r$���c����������� �������,����|�j��������������������������ry�t��������j������������������t��������j������������������z��}|r|t��������j������������������z��}t��������j ������������������|�j������������������|t��������j������������������t��������j������������������z��t��������j������������������z��t��������j������������������t��������j������������������t��������j������������������t��������j������������������t��������j�������������������������}t��������j������������������|�������}|�j ������������������j#������������������|��������|S�rB���)�closedrX����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� PipeHandler�����add)r ����first�flags�h�pipes��� r#���r����zPipeServer._server_pipe_handle��s��������;�;�=���*�*�W�-I�-I�I����W�:�:�:�E��#�#��M�M�5��%�%��(E�(E�E���� ��,�,��!�!�=�#8�#8��(�(�'�,�,� 8����'�'��*����� � ��&��r$���c�����������������������|�j�������������������d�u�S�rB���)r����r[���s��� r#���r����zPipeServer.closed ��s������� � ��%�&r$���c������������������ ����|�j��������������������!|�j�������������������j���������������������������d�|�_���������|�j�������������������J|�j������������������D�]��}|j �����������������������������d�|�_��������d�|�_��������|�j������������������j ���������������������������y�y�rB���)r����r6���r����r�����closer�����clear)r ���r����s��� r#���r����zPipeServer.close#��sp�������#�#�/��$�$�+�+�-�'+�D�$��=�=�$��,�,��� � ���-��D�J� �D�M�� � �&�&�(��%r$���N) rI���rJ���rK���r���r����r����r����r�����__del__��r$���r#���r����r��������s'�������4���$'� )���Gr$���r����c�������������������������e�Zd�Zy)�_WindowsSelectorEventLoopN)rI���rJ���rK���r����r$���r#���r����r����2��s������1r$���r����c��������������������B�������e�Zd�Z �d��fd� Z��fd�Zd��Zd��Z �dd�Z��xZS�)r���c������������������<������|� t����������������}t���������|�� ��|��������y�rB���)r���r���r���)r ���r����r"���s��� �r#���r���zProactorEventLoop.__init__9��s���������#�~�H� ����"r$���c����������������������� �|�j������������������|�j��������������������������t���������|�� �����������|�j�������������������a|�j������������������j ������������������}|�j������������������j ���������������������������|�'|j������������������s|�j������������������j������������������|��������d�|�_��������y�y�#�|�j�������������������a|�j������������������j ������������������}|�j������������������j ���������������������������|�'|j������������������s|�j������������������j������������������|��������d�|�_��������w�w�xY�wrB���) � call_soon�_loop_self_readingr����run_forever�_self_reading_futurer���r6���r&���r{���r����)r ���r!���r"���s��� �r#���r����zProactorEventLoop.run_forever>��s�������� 1��N�N�4�2�2�3��G��!��(�(�4��.�.�2�2���)�)�0�0�2���>�"�*�*��N�N�.�.�r�2�,0��)��5��t�(�(�4��.�.�2�2���)�)�0�0�2���>�"�*�*��N�N�.�.�r�2�,0��)��5�s����)B��A/D c����������������������K����|�j�������������������j������������������|�������}|��d�{������}�|��������}|�j������������������||d|i��������}||fS�7��%�w)N�addr��extra)r{����connect_pipe�_make_duplex_pipe_transport)r ����protocol_factoryr,����fr�����protocol�transs��� r#����create_pipe_connectionz(ProactorEventLoop.create_pipe_connectionQ��sZ����������N�N�'�'��0���w��#�%���0�0��x�8>��7H��1��J���h��� ��s����!A�A �&Ac�������������������f���������K����t�����������������d������fd� ���j����������������������������gS��w)Nc������������������J�����d�} �|�ri|�j��������������������������}�j������������������j������������������|���������j��������������������������r|j ���������������������������y�����������}�j������������������||d�i����������j ��������������������������}|�y��j������������������j������������������|�������}�|��_ ��������|�j���������������������������y�#�t��������$�r9�|r#|j��������������������������dk7��r|j ����������������������������j���������������������������Y�y�t��������$�rz}|r9|j��������������������������dk7��r&�j������������������d||d���������|j ���������������������������n$�j ������������������rt#��������j$������������������d|d����������j���������������������������Y�d�}~y�d�}~wt&��������j(������������������$�r�|r|j ���������������������������Y�y�Y�y�w�xY�w) Nr����r����r���zPipe accept failed)r2���r3���r����zAccept pipe failed on pipe %rT)�exc_info)rH���r�����discardr����r����r����r����r{����accept_piper�����add_done_callback�BrokenPipeError�filenor����r7���r9����_debugr����warningr ����CancelledError) r����r����r����r:���r,����loop_accept_piper����r ����servers ��� �����r#���r����z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_pipe\��st�������D�) 6���8�8�:�D��*�*�2�2�4�8��}�}���� � ���/�1�H��4�4��h�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�%(� $�1��� ��J�J�L��[�[��N�N�#B�#'�$�8����/�0�0���,�,�� !���J�J�L��� !�s1����A B7��/B7��B7��7?F"�8F"��A0E5�5(F"�!F"rB���)r����r����)r ���r����r,���r����r����s���```@@r#����start_serving_pipez$ProactorEventLoop.start_serving_pipeY��s2�����������G�$��+ 6��+ 6�Z� ���'�(��x��s����*1c ����������� �����������K����|�j��������������������������} t��������|�|||||||f| |d�| ��} �| ��d�{�������|S�7��#�t��������t��������f$�r���t��������$�r+�|j���������������������������|j ����������������������������d�{�����7�����w�xY�w�w)N)�waiterr����)� create_future�_WindowsSubprocessTransport� SystemExit�KeyboardInterrupt� BaseExceptionr�����_wait)r ���r�����args�shell�stdin�stdout�stderr�bufsizer�����kwargsr�����transps��� r#����_make_subprocess_transportz,ProactorEventLoop._make_subprocess_transport���s������������#�#�%��,�T�8�T�5�-2�F�F�G�7�4:�%�7��06�7�� ��L�L��� �� ���-�.�� ���� ��L�L�N��,�,�.� � �� �s1����'A>�8��6�8��A>�8��;A;�3A6�4A;�;A>rB���) rI���rJ���rK���r���r����r����r����r����rL���rM���s���@r#���r���r���6��s%�������<�#� 1�&�1�j�04�r$���r���c��������������������������e�Zd�Z �efd�Zd��Zd��Zd��Zd d�Zd��Z e d����������Zed ����������Z d!d �Zd!d�Zd!d�Zd!d �Zd"d�Zd!d�Zd��Zd��Zd��Zd��Zd��Zd d�Zd��Zd��Zd��Zd��Zd��Zd��Zd d�Z d��Z!d��Z"d��Z#y)#r���c�����������������������d�|�_���������g�|�_��������t��������j������������������t��������j������������������t ��������d|�������|�_��������i�|�_��������t��������j��������������������������|�_ ��������g�|�_��������t��������j��������������������������|�_��������y�rW���) r8����_resultsrf����CreateIoCompletionPort�INVALID_HANDLE_VALUEr�����_iocp�_cacher����r����rS���� _unregistered�_stopped_serving)r ����concurrencys��� r#���r���zIocpProactor.__init__���s_�������� ��� � �7�7��,�,�d�A�{�D�� ����"�?�?�,������ '��� 1��r$���c������������������2�����|�j��������������������t��������d��������y�)NzIocpProactor is closed)r����ru���r[���s��� r#���� _check_closedzIocpProactor._check_closed���s�������:�:���7�8�8��r$���c������������������������dt��������|�j�������������������������z��dt��������|�j�������������������������z��g}|�j�������������������|j ������������������d��������d|�j ������������������j�������������������ddj������������������|��������d�S�)Nzoverlapped#=%sz result#=%sr�����<� r)���)�lenr����r����r����r`���r"���rI����join)r ���r.���s��� r#����__repr__zIocpProactor.__repr__���s_������ �3�t�{�{�#3�3��s�4�=�=�1�1�3���:�:���K�K��!�� �N�N�3�3�S�X�X�d�^�D�Dr$���c�����������������������||�_���������y�rB���)r8���)r ���r���s��� r#����set_loopzIocpProactor.set_loop���s �������� r$���Nc������������������z�����|�j�������������������s|�j������������������|��������|�j�������������������}g�|�_��������� �|d�}S�#�d�}w�xY�wrB���)r����r\���)r ����timeoutr����s��� r#����selectzIocpProactor.select���s:�������}�}��J�J�w���m�m���� � ����C��$�C�s����6��:c������������������\�����|�j�������������������j��������������������������}|j������������������|��������|S�rB���)r8���r����rF���)r ����valuerb���s��� r#����_resultzIocpProactor._result���s%�������j�j�&�&�(�����u��� r$���c������������������������ �|j��������������������������S�#�t��������$�rD}|j������������������t��������j������������������t��������j ������������������fv�rt ��������|j�����������������������d�}~ww�xY�wrB���)� getresultr7���rh���rf����ERROR_NETNAME_DELETED�ERROR_OPERATION_ABORTED�ConnectionResetErrorr����)r�����keyr!���r:���s��� r#����finish_socket_funczIocpProactor.finish_socket_func���sY������ ��<�<�>�!���� ��|�|�� A� A� +� C� C� E��E�*�C�H�H�5�5��� �s������ A�?A�Ac���������������������� �|�j������������������|||�������S�#�t��������$�r,}|j������������������t��������j������������������k(��r |d�fcY�d�}~S���d�}~ww�xY�wrB���)r��r7���rh���rf����ERROR_PORT_UNREACHABLE)�clsr����r��r!����empty_resultr:���s��� r#����_finish_recvfromzIocpProactor._finish_recvfrom���sN������ ��)�)�%��b�9�9���� ���|�|�{�A�A�A�#�T�)�)��� �s������ A � A�A �A�A c����������������������|�j������������������|��������t��������j������������������t���������������} �t ��������|t ��������j �������������������������r"|j ������������������|j��������������������������||��������n |j������������������|j��������������������������|��������|�j������������������|||�j�������������������������S�#�t��������$�r�|�j������������������d�������cY�S�w�xY�w)Nr$���) �_register_with_iocprf���� Overlappedr����� isinstance�socket�WSARecvr�����ReadFiler����r����� _registerr���r ����conn�nbytesr����r!���s��� r#����recvzIocpProactor.recv���s�������� � ��&� � #� #�D� )�� %��$�� � �.�� � �4�;�;�=�&�%�8����D�K�K�M�6�2���~�~�b�$��(?�(?�@�@����� %��<�<��$�$� %������AB%��%C�Cc����������������������|�j������������������|��������t��������j������������������t���������������} �t ��������|t ��������j �������������������������r"|j ������������������|j��������������������������||��������n |j������������������|j��������������������������|��������|�j������������������|||�j�������������������������S�#�t��������$�r�|�j������������������d�������cY�S�w�xY�wrW���) r ��rf���r ��r����r��r���WSARecvIntor�����ReadFileIntor����r����r��r���r ���r���bufr����r!���s��� r#���� recv_intozIocpProactor.recv_into���s�������� � ��&� � #� #�D� )�� #��$�� � �.����t�{�{�}�c�5�9������� �s�3���~�~�b�$��(?�(?�@�@����� #��<�<��?�"� #�r��c������������������*����|�j������������������|��������t��������j������������������t���������������} �|j ������������������|j��������������������������||��������|�j������������������||t��������|�j������������������d���������������S�#�t��������$�r�|�j������������������d�������cY�S�w�xY�w)N)r$���Nr$����r��)r ��rf���r ��r�����WSARecvFromr����r����r����r��r���r��r��s��� r#����recvfromzIocpProactor.recvfrom���s�������� � ��&� � #� #�D� )�� -��N�N�4�;�;�=�&�%�8���~�~�b�$���0E�0E�=@�)B��C�� C����� -��<�<��,�,� -������!A5��5B�Bc������������������*����|�j������������������|��������t��������j������������������t���������������} �|j ������������������|j��������������������������||��������|�j������������������||t��������|�j������������������d���������������S�#�t��������$�r�|�j������������������d�������cY�S�w�xY�w)N�r���Nr���r��)r ��rf���r ��r�����WSARecvFromIntor����r����r����r��r���r��r��s��� r#���� recvfrom_intozIocpProactor.recvfrom_into��s�������� � ��&� � #� #�D� )�� +����t�{�{�}�c�5�9���~�~�b�$���0E�0E�=>�)@��A�� A����� +��<�<� �*�*� +�r��c������������������������|�j������������������|��������t��������j������������������t���������������}|j ������������������|j��������������������������|||��������|�j ������������������|||�j�������������������������S�rB���)r ��rf���r ��r����� WSASendTor����r��r��)r ���r��r��r����r����r!���s��� r#����sendtozIocpProactor.sendto��sQ������� � ��&� � #� #�D� )�� ���T�[�[�]�C���5��~�~�b�$��(?�(?�@�@r$���c������������������H����|�j������������������|��������t��������j������������������t���������������}t ��������|t ��������j �������������������������r"|j ������������������|j��������������������������||��������n |j������������������|j��������������������������|��������|�j������������������|||�j�������������������������S�rB���)r ��rf���r ��r����r��r���WSASendr����� WriteFiler��r��r��s��� r#����sendzIocpProactor.send��sq������� � ��&� � #� #�D� )���d�F�M�M�*��J�J�t�{�{�}�c�5�1��L�L������,��~�~�b�$��(?�(?�@�@r$���c������������������|������|�j���������������������������|�j�������������������j��������������������������t��������j������������������t ���������������}|j �������������������j���������������������������j������������������������������������fd�}d��}|�j������������������|�|�������}�||��������}t��������j������������������||�j���������������������������|S�)Nc������������������,�����|j���������������������������t��������j������������������d�j���������������������������������}�j ������������������t ��������j������������������t��������j������������������|���������j�������������������j������������������������������������j��������������������������fS�)Nz@P)r�����struct�packr����� setsockoptr��� SOL_SOCKETrf����SO_UPDATE_ACCEPT_CONTEXT� settimeout� gettimeout�getpeername)r����r��r!���r��r���listeners��� ��r#���� finish_acceptz*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�������������������v���K���� �|���d�{�������y�7��#�t���������j������������������$�r�|j�����������������������������w�xY�w�wrB���)r ���r����r����)r4���r��s��� r#����accept_coroz(IocpProactor.accept.<locals>.accept_coro3��s2��������� ������,�,�� �� � ��� �s ����9������9���%6�9r���)r ���_get_accept_socket�familyrf���r ��r�����AcceptExr����r��r���� ensure_futurer8���)r ���r5��r!���r6��r8��r4����coror��s��� ` @r#����acceptzIocpProactor.accept$��s��������� � ��*��&�&�x���7�� � #� #�D� )�� ���H�O�O�%�t�{�{�}�5� ,� ������H�m�<���6�4�(�� ���D�t�z�z�2�� r$���c������������������������j�������������������t��������j������������������k(��rQt��������j�������������������j��������������������������|��������|�j������������������j��������������������������}|j������������������d���������|S�|�j��������������������������� �t��������j�������������������j���������������������������j��������������������������t��������j"������������������t$���������������}|j'�������������������j��������������������������|���������fd�}|�j)������������������|�|�������S�#�t��������$�r?}|j������������������t��������j������������������k7��r���j!��������������������������d���dk(��r��Y�d�}~��d�}~ww�xY�w)Nr���r���c������������������������|j����������������������������j������������������t��������j������������������t��������j ������������������d���������S�rW���)r����r/��r��r0��rf����SO_UPDATE_CONNECT_CONTEXT)r����r��r!���r��s��� �r#����finish_connectz,IocpProactor.connect.<locals>.finish_connectV��s1��������L�L�N��O�O�F�-�-�'�A�A�1� F��Kr$���)�typer��� SOCK_DGRAMrf���� WSAConnectr����r8���r����rF���r ��� BindLocalr:��r7���rh����errno� WSAEINVAL�getsocknamer ��r����� ConnectExr��)r ���r��r,���rb����er!���rB��s��� ` r#����connectzIocpProactor.connect@��s��������9�9��)�)�)�� �"�"�4�;�;�=�'�:��*�*�*�*�,�C��N�N�4� ��J�� � ��&� ��!�!�$�+�+�-����=��� #� #�D� )�� ���T�[�[�]�G�,� ���~�~�b�$��7�7��!��� ��z�z�U�_�_�,�����!�!�$��)���*�� �s����.D�� E � 5E�E c����������� �������6����|�j������������������|��������t��������j������������������t���������������}|dz��}|dz ��dz��}|j ������������������|j��������������������������t ��������j������������������|j���������������������������������|||dd��������|�j������������������|||�j�������������������������S�)Nl������� ���r���) r ��rf���r ��r�����TransmitFiler�����msvcrt� get_osfhandler��r��)r ����sock�file�offset�countr!���� offset_low�offset_highs��� r#����sendfilezIocpProactor.sendfile_��s�������� � ��&� � #� #�D� )���k�)� ���|�{�2�� ������ ��,�,�T�[�[�]�;�"�K��q�!� %� ��~�~�b�$��(?�(?�@�@r$���c�������������������������|�j���������������������������t��������j������������������t���������������}|j �������������������j���������������������������������}|r|�j ��������������������������S��fd�}|�j������������������|�|�������S�)Nc������������������(������|j����������������������������S�rB���)r����)r����r��r!���r����s��� �r#����finish_accept_pipez4IocpProactor.accept_pipe.<locals>.finish_accept_pipev��s��������L�L�N��Kr$���)r ��rf���r ��r�����ConnectNamedPiper����r����r��)r ���r����r!���� connectedr[��s��� ` r#���r����zIocpProactor.accept_pipek��sf�������� � ��&� � #� #�D� )���'�'���� �6� ����<�<��%�%� ���~�~�b�$�(:�;�;r$���c�������������������<��K����t���������} � �t��������j������������������|�������} �t��������j������������������|�������S�#�t��������$�r(}|j������������������t��������j ������������������k7��r��Y�d�}~nd�}~ww�xY�wt ��������|dz��t���������������}t��������j������������������|���������d�{�����7������w)N����)�CONNECT_PIPE_INIT_DELAYrf����ConnectPiper7���rh����ERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYr����sleepr ���r����)r ���r,����delayrT���r:���s��� r#���r����zIocpProactor.connect_pipe|��s����������'��� �$�0�0��9�����'�'��/�/����� ��<�<�;�#>�#>�>���?�� �� ���� �#9�:�E��+�+�e�$�$�$���s6����B�6��B� A'�A"�B�"A'�'.B�B�Bc������������������*����� �|�j������������������||d�������S�r����)�_wait_for_handle)r ���rT���r����s��� r#����wait_for_handlezIocpProactor.wait_for_handle���s������ � ��$�$�V�W�e�<�<r$���c������������������:�����|�j������������������|d�d�������}||_��������|S�r����)rh��rr���)r ���rs���� done_callbackrb���s��� r#���r����zIocpProactor._wait_cancel���s%�������#�#�E�4��6���+���� r$���c������������������������|�j���������������������������|�t��������j������������������}nt��������j������������������|dz���������}t��������j������������������t���������������}t��������j������������������||�j������������������|j������������������|�������}|rt��������||||�j���������������������������nt��������||||�|�j����������������������������j������������������r �j������������������d=��fd�}�|d|f|�j������������������|j������������������<����S�)N������@�@r���r���c������������������$�������j��������������������������S�rB���)r\���)r����r��r!���r����s��� �r#����finish_wait_for_handlez=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handle���s���������7�7�9�r$���r���)r����rX����INFINITE�math�ceilrf���r ��r�����RegisterWaitWithQueuer����r,���rp���r8���ry���r���r����) r ���rT���r����� _is_cancel�msr!���rU���ro��r����s ��� @r#���rh��zIocpProactor._wait_for_handle���s�������������?��!�!�B�����7�S�=�)�B��� #� #�D� )��!�7�7��D�J�J�� � �B�0���!�"�f�k�� � �K�A�!�"�f�k�4�'+�z�z�3�A�����#�#�B�'� ��$%�b�!�-C�"D����B�J�J���r$���c�����������������������||�j�������������������vrL|�j�������������������j������������������|��������t��������j������������������|j ��������������������������|�j ������������������dd��������y�y�rW���)rS���r����rf���r����r����r�����r ����objs��� r#���r ��z IocpProactor._register_with_iocp���sI��������d�&�&�&���� � ��%��.�.�s�z�z�|�T�Z�Z��A�N��'r$���c������������������^����|�j���������������������������t��������||�j��������������������������}|j������������������r |j������������������d=�|j������������������s ��|d�d�|�������}|j������������������|��������||||f|�j������������������|j������������������<���|S�#�t��������$�r}|j������������������|��������Y�d�}~�>d�}~ww�xY�wr���) r����r���r8���r���r&���rF���r7���rC���r����r,���)r ���r!���rx���callbackr����r����rK��s��� r#���r��zIocpProactor._register���s����������� � �b�t�z�z�2������#�#�B�'��z�z� $� ��t�R�0������U�#��$%�b�#�x�"8����B�J�J�������� #�����"�"�� #�s���� B�� B,�B'�'B,c������������������\����� �|�j���������������������������|�j������������������j������������������|��������y�rB���)r����r����r`���)r ���r!���s��� r#���r����zIocpProactor._unregister���s)������ �� �������!�!�"�%r$���c������������������R�����t��������j�������������������|�������}|j������������������d��������|S�rW���)r��r2��)r ���r:���ss��� r#���r9��zIocpProactor._get_accept_socket���s �������M�M�&�!�� ���Q���r$���c����������� �������"����|�t���������}n<|dk��rt��������d��������t��������j������������������|dz���������}|t���������k\��rt��������d�������� �t ��������j ������������������|�j������������������|�������}|�n�d}|\��}}}} �|�j������������������j������������������|�������\��}} } }| |�j ������������������v�r|j#���������������������������nI|j%��������������������������s9 ��|||| �������}|j'������������������|��������|�j(������������������j+������������������|��������d�}��|�j0������������������D�](��} |�j������������������j������������������| j2������������������d����������*�|�j0������������������j5���������������������������y�#�t��������$�rl�|�j������������������j��������������������������r%|�j������������������j������������������dd||||fz��d���������|dt��������j������������������fvrt��������j������������������|��������Y���}w�xY�w#�t,��������$�r7} |j/������������������| ��������|�j(������������������j+������������������|��������Y�d�} ~ ��d�} ~ ww�xY�w#�d�}w�xY�w)Nr���znegative timeoutrm��ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r2����status)rp��� ValueErrorrq��rr��rf����GetQueuedCompletionStatusr����r�����pop�KeyErrorr8���� get_debugr9���r����rX���r����r����r6����donerF���r����r`���r7���rC���r����r,���r����)r ���r����ru��r���err�transferredr��r,���r����r!���rx��rz��r����rK��s��� r#���r\���zIocpProactor._poll���s�������?��B� �q�[��/�0�0�����7�S�=�)�B��X�~� �!2�3�3�� �:�:�4�:�:�r�J�F��~���B�-3�*�C��c�7� �'+�{�{���w�'?�$��2�s�H� ��d�+�+�+���� ���V�V�X� �$�[�#�r�:�E� ��L�L��'��M�M�(�(��+��A�M��R��$�$�B��K�K�O�O�B�J�J��-��%���� � �"��E��� ��:�:�'�'�)��J�J�5�5�%7�#N�&)�;��W�%E�$F�7�����q�+�"B�"B�C�C��'�'��,�� ��,���,��O�O�A�&��M�M�(�(��+�+��,����A�sC����4 E�� G��,H ��A1G�G� H�,H�<H ��H�H �� Hc������������������:�����|�j�������������������j������������������|��������y�rB���)r����r����rw��s��� r#���� _stop_servingzIocpProactor._stop_serving2��s������� ���!�!�#�&r$���c������������������4����|�j��������������������y�t��������|�j������������������j���������������������������������D�]:��\��}}}}|j ��������������������������r�t��������|t���������������r�* �|j����������������������������<�d}t��������j��������������������������}||z���} |�j������������������rx| t��������j��������������������������k��rCt��������j������������������d|�t��������j��������������������������|z ����������t��������j��������������������������|z���} |�j!������������������|��������|�j������������������r�xg�|�_��������t%��������j&������������������|�j���������������������������d�|�_���������y�#�t��������$�rS}|�j�������������������<d||d�}|j������������������r|j������������������|d<���|�j������������������j������������������|��������Y�d�}~��ad�}~ww�xY�w)NzCancelling a future failedr1���r5���g�������?z,%r is running after closing for %.1f seconds)r�����listr�����values� cancelledr��rp���r6���r7���r8���r���r9����time� monotonicr����debugr\���r����rX���r����) r ���rb���r!���rx��rz��r:���r;���� msg_update� start_time�next_msgs ��� r#���r����zIocpProactor.close8��s[������:�:����'+�4�;�;�+=�+=�+?�&@�"�C��S�(��}�}����C�!2�3��C��J�J�L��'A�0�� ��^�^�%� �� �*���k�k��4�>�>�+�+����K�!�4�>�>�#3�j�#@�B��>�>�+�j�8��� �J�J�z�"���k�k���� ����D�J�J�'��� ��;��� C��z�z�-�'C�),�&)�#�� ��0�0�:=�:O�:O�G�$6�7�� � �9�9�'�B��� C�s����D;�; F�AF�Fc������������������$�����|�j���������������������������y�rB���)r����r[���s��� r#���r����zIocpProactor.__del__g��s������� � �r$���rB���)r���r!��)$rI���rJ���rK���rp��r���r����r����r����r����r�����staticmethodr���classmethodr��r��r��r��r#��r&��r*��r>��rL��rX��r����r����ri��r����rh��r ��r��r����r9��r\���r���r����r����r����r$���r#���r���r������s�������-�#+��2�9�E�� �� �������� ��� �A�A� C� A�A�A��88�> A�<�"0�&=�� �DO��@&�� 7#�r'�-�^r$���r���c�������������������������e�Zd�Zd��Zy)r����c����������� ��������������t��������j������������������|f|||||d�|����_����������fd�}��j������������������j������������������j������������������t ����������j������������������j��������������������������������} | j������������������|��������y�)N)r����r����r����r����r����c������������������\�������j�������������������j��������������������������}�j������������������|��������y�rB���)�_proc�poll�_process_exited)r����� returncoder ���s��� �r#���rz��z4_WindowsSubprocessTransport._start.<locals>.callbackr��s!������������*�J�� � ��,r$���) r ����Popenr���r8���r{���ri���intrQ���r����) r ���r����r����r����r����r����r����r����rz��r����s ���` r#����_startz"_WindowsSubprocessTransport._startm��so�������"�(�(��'��U�6�&��'�%�'�� � -�� �J�J� � �0�0��T�Z�Z�5G�5G�1H�I�� ���H�%r$���N)rI���rJ���rK���r���r����r$���r#���r����r����k��s������ &r$���r����c�������������������������e�Zd�ZeZy)r���N)rI���rJ���rK���r���� _loop_factoryr����r$���r#���r���r���}���������%�Mr$���r���c�������������������������e�Zd�ZeZy)r���N)rI���rJ���rK���r���r���r����r$���r#���r���r������r���r$���r���)3�sys�platform�ImportErrorrf���rX���rG��� functoolsr���rq��rP��r��r-��r���r������r���r���r���r ���r ���r���r���r ����logr����__all__r����rp���ERROR_CONNECTION_REFUSED�ERROR_CONNECTION_ABORTEDr`��rd���Futurer���rO���rp���ry����objectr�����BaseSelectorEventLoopr�����BaseProactorEventLoopr���r����BaseSubprocessTransportr����r����BaseDefaultEventLoopPolicyr���r���r���r����r$���r#����<module>r������s\�����4�� ��<�<�7�� �l� #�#������������ �� �� ���������������������������|�|������������� �������-�����-�`G#�G�N�N��G#�T&�-��&�01P�-��1P�h8���8�v2�� E� E��2�g��=�=��g�TH��H�V&�/�"I�"I��&��.���&�V�%F�%F��&�&�V�%F�%F��&��8��r$���