����JFIF���������
1#@!#!123s
D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
alt
/
python312
/
lib64
/
python3.12
/
__pycache__
/
Filename :
socketserver.cpython-312.opt-2.pyc
back
Copy
� ����D[Yh�m�����������������������Z���� �d�Z�ddlZddlZddlZddlZddlZddlmZ�ddlm Z�g�d�Z �eed�������re j������������������g�d����������eed�������r/e j������������������g�d ����������eed�������re j������������������d dg���������eed�������r ej������������������Znej������������������Z�G�d ��d�������Z�G�d��de�������Z�G�d��de�������Z�eed�������r �G�d��d�������Z�G�d��de�������Z�G�d��d�������Z�G�d��d�������Z�eed�������r�G�d��dee�������Z�G�d��dee�������Z�G�d��d ee�������Z�G�d!��d"ee�������Z�eed�������rO�G�d#��d$e�������Z�G�d%��d&e�������Z�G�d'��d(ee�������Z�G�d)��d*ee�������Z�eed�������r�G�d+��d ee�������Z �G�d,��dee�������Z!�G�d-��d.�������Z"�G�d/��d0e"�������Z#�G�d1��d2e�������Z$�G�d3��d4e"�������Z%y)5z0.4�����N)�BufferedIOBase)� monotonic) � BaseServer� TCPServer� UDPServer�ThreadingUDPServer�ThreadingTCPServer�BaseRequestHandler�StreamRequestHandler�DatagramRequestHandler�ThreadingMixIn�fork)�ForkingUDPServer�ForkingTCPServer�ForkingMixIn�AF_UNIX)�UnixStreamServer�UnixDatagramServer�ThreadingUnixStreamServer�ThreadingUnixDatagramServer�ForkingUnixStreamServer�ForkingUnixDatagramServer�PollSelectorc��������������������z�����e�Zd�Z �dZd��Zd��Zdd�Zd��Zd��Zd��Z d��Z d ��Zd ��Zd��Z d��Zd ��Zd��Zd��Zd��Zd��Zd��Zy)r���Nc������������������b����� �||�_���������||�_��������t��������j��������������������������|�_��������d|�_��������y��NF)�server_address�RequestHandlerClass� threading�Event�_BaseServer__is_shut_down�_BaseServer__shutdown_request)�selfr���r���s��� �3/opt/alt/python312/lib64/python3.12/socketserver.py�__init__zBaseServer.__init__����s,������=�,���#6�� �'�o�o�/���"'�������c������������������������ �y��N���r#���s��� r$����server_activatezBaseServer.server_activate����������� � � r&���c���������������������� �|�j�������������������j��������������������������� �t����������������5�}|j������������������|�t��������j ��������������������������|�j������������������sM|j������������������|�������}|�j������������������rn/|r|�j���������������������������|�j���������������������������|�j������������������s�Md�d�d���������d|�_��������|�j�������������������j���������������������������y�#�1�sw�Y����+xY�w#�d|�_��������|�j�������������������j���������������������������w�xY�wr���)r!����clear�_ServerSelector�register� selectors� EVENT_READr"����select�_handle_request_noblock�service_actions�set)r#���� poll_interval�selector�readys��� r$���� serve_foreverzBaseServer.serve_forever����s������� �� ���!�!�#� &� �!�"�h��!�!�$� �(<�(<�=��1�1�$�O�O�M�:�E��.�.����4�4�6��(�(�*���1�1��#��',�D�#����#�#�%��#�"���',�D�#����#�#�%�s#���� C��A9C�!C��C�C��#C:c������������������H����� �d|�_���������|�j������������������j���������������������������y��NT)r"���r!����waitr*���s��� r$����shutdownzBaseServer.shutdown����s#������ ��#'������ � �"r&���c������������������������ �y�r(���r)���r*���s��� r$���r5���zBaseServer.service_actions��r,���r&���c����������������������� �|�j�������������������j��������������������������}|� |�j������������������}n"|�j�������������������t��������||�j�������������������������}|� t ����������������|z���}t����������������5�}|j ������������������|�t��������j�������������������������� �|j������������������|�������r|�j��������������������������cd�d�d���������S�|�+t ����������������z ��}|dk��r|�j��������������������������cd�d�d���������S��X#�1�sw�Y���y�xY�w)Nr���)�socket� gettimeout�timeout�min�timer/���r0���r1���r2���r3���r4����handle_timeout)r#���rC����deadliner8���s��� r$����handle_requestzBaseServer.handle_request��s������� ���+�+�(�(�*���?��l�l�G� �\�\� %��'�4�<�<�0�G����v��'�H��� �(����d�I�$8�$8�9���?�?�7�+��7�7�9��� ���*�"*�T�V�"3��"�Q�;�#'�#6�#6�#8��� ����� �s����&AC �2#C �C � C)c������������������B���� � �|�j��������������������������\��}}|�j������������������||�������r �|�j������������������||��������y�|�j ������������������|��������y�#�t��������$�r�Y�y�w�xY�w#�t��������$�r&�|�j������������������||��������|�j ������������������|��������Y�y��|�j ������������������|����������xY�wr(���)�get_request�OSError�verify_request�process_request� Exception�handle_error�shutdown_request�r#����request�client_addresss��� r$���r4���z"BaseServer._handle_request_noblock1��s������� � �&*�&6�&6�&8�#�G�^�����w��7� ��$�$�W�n�=�� �!�!�'�*����� �� �� ��� /��!�!�'�>�:��%�%�g�.� ��%�%�g�.��s"����A��A�� A�A�,B�Bc������������������������ �y�r(���r)���r*���s��� r$���rF���zBaseServer.handle_timeoutH��s������ �� r&���c������������������������ �yr<���r)���rQ���s��� r$���rL���zBaseServer.verify_requestO��s������ � �r&���c������������������L����� �|�j������������������||��������|�j������������������|��������y�r(���)�finish_requestrP���rQ���s��� r$���rM���zBaseServer.process_requestW��s'������ � � ���G�^�4����g�&r&���c������������������������ �y�r(���r)���r*���s��� r$����server_closezBaseServer.server_close`��r,���r&���c������������������,����� �|�j������������������|||���������y�r(���)r���rQ���s��� r$���rW���zBaseServer.finish_requesth��s������F�� � ��.�$�?r&���c������������������(����� �|�j������������������|��������y�r(����� close_request�r#���rR���s��� r$���rP���zBaseServer.shutdown_requestl��s������A����7�#r&���c������������������������ �y�r(���r)���r^���s��� r$���r]���zBaseServer.close_requestp��s������7�r&���c������������������������ �t��������dt��������j���������������������������t��������d|t��������j���������������������������dd�l}|j ���������������������������t��������dt��������j���������������������������y�)Nz(----------------------------------------)�filez4Exception occurred during processing of request fromr���)�print�sys�stderr� traceback� print_exc)r#���rR���rS���re���s��� r$���rO���zBaseServer.handle_errort��sH������ � � �f�3�:�:�&� �D����� -������ �f�3�:�:�&r&���c�����������������������|�S�r(���r)���r*���s��� r$���� __enter__zBaseServer.__enter__���s�������r&���c������������������$�����|�j���������������������������y�r(���)rY���)r#����argss��� r$����__exit__zBaseServer.__exit__���s���������r&���)g�������?)�__name__� __module__�__qualname__rC���r%���r+���r:���r>���r5���rH���r4���rF���rL���rM���rY���rW���rP���r]���rO���rh���rk���r)���r&���r$���r���r�������se������*�X��G�(� �&�:#� �&9�:+�. ��'� �@�$� �'��r&���r���c��������������������|�����e�Zd�Z �ej������������������Zej������������������ZdZdZ dZ dd�Zd��Zd��Z d��Zd��Zd��Zd ��Zd ��Zy) r�������Fc���������������������� �t���������j������������������|�||��������t��������j������������������|�j������������������|�j�������������������������|�_��������|r" �|�j���������������������������|�j ���������������������������y�y�#��|�j�����������������������������xY�wr(���)r���r%���rA����address_family�socket_type�server_bindr+���rY���)r#���r���r����bind_and_activates��� r$���r%���zTCPServer.__init__���st������=����D�.�2E�F��m�m�D�$7�$7�$(�$4�$4�6���� �� � �"��$�$�&���� ��!�!�#��s���� A-��-B�c������������������:���� �|�j�������������������rIt��������t��������d�������r9|�j������������������j������������������t��������j������������������t��������j ������������������d��������|�j������������������rut��������t��������d�������re|�j������������������t��������j������������������t��������j������������������fv�r9|�j������������������j������������������t��������j������������������t��������j������������������d��������|�j������������������j������������������|�j��������������������������|�j������������������j��������������������������|�_��������y�)N�SO_REUSEADDR�����SO_REUSEPORT)�allow_reuse_address�hasattrrA���� setsockopt� SOL_SOCKETrw����allow_reuse_portrr����AF_INET�AF_INET6ry����bindr����getsocknamer*���s��� r$���rt���zTCPServer.server_bind���s������� � ��#�#����(G��K�K�"�"�6�#4�#4�f�6I�6I�1�M�� �!�!�g�f�n�&E��#�#�������'H�H��K�K�"�"�6�#4�#4�f�6I�6I�1�M�������,�,�-�"�k�k�5�5�7��r&���c������������������P����� �|�j�������������������j������������������|�j��������������������������y�r(���)rA����listen�request_queue_sizer*���s��� r$���r+���zTCPServer.server_activate���s!������ � � �����4�2�2�3r&���c������������������:����� �|�j�������������������j���������������������������y�r(���)rA����closer*���s��� r$���rY���zTCPServer.server_close���s������ � � �����r&���c������������������8����� �|�j�������������������j��������������������������S�r(���)rA����filenor*���s��� r$���r����zTCPServer.fileno���������� � ��{�{�!�!�#�#r&���c������������������8����� �|�j�������������������j��������������������������S�r(���)rA����acceptr*���s��� r$���rJ���zTCPServer.get_request���r����r&���c����������������������� � �|j������������������t��������j��������������������������|�j ������������������|��������y�#�t��������$�r�Y��w�xY�wr(���)r>���rA����SHUT_WRrK���r]���r^���s��� r$���rP���zTCPServer.shutdown_request��sB������A� �� ���V�^�^�,�� ���7�#����� �� �s����4�� A��A�c������������������&����� �|j���������������������������y�r(���)r����r^���s��� r$���r]���zTCPServer.close_request��s������7�� � �r&���N)T)rl���rm���rn���rA���r���rr����SOCK_STREAMrs���r����rz���r~���r%���rt���r+���rY���r����rJ���rP���r]���r)���r&���r$���r���r������sX������,�\��^�^�N��$�$�K��������8�$4��$�$�$�r&���r���c��������������������J�����e�Zd�Z �dZdZej������������������ZdZd��Z d��Z d��Zd��Zy)r���Fi� ��c������������������r�����|�j�������������������j������������������|�j�������������������������\��}}||�j�������������������f|fS�r(���)rA����recvfrom�max_packet_size)r#����data�client_addrs��� r$���rJ���zUDPServer.get_request��s5������ �K�K�0�0��1E�1E�F���k��d�k�k�"�K�/�/r&���c������������������������y�r(���r)���r*���s��� r$���r+���zUDPServer.server_activate ���������r&���c������������������&�����|�j������������������|��������y�r(���r\���r^���s��� r$���rP���zUDPServer.shutdown_request$��s���������7�#r&���c������������������������y�r(���r)���r^���s��� r$���r]���zUDPServer.close_request(��r����r&���N) rl���rm���rn���rz���r~���rA���� SOCK_DGRAMrs���r����rJ���r+���rP���r]���r)���r&���r$���r���r�����s5������������#�#�K��O�0� �$� r&���r���c��������������������N�������e�Zd�Z �dZdZdZdZdd�d�Zd��Zd ��Z d ��Z ��fd�Z��xZS�)r���i,��N�(���TF��blockingc��������������������� �|�j��������������������y�t��������|�j��������������������������|�j������������������k\��rX �t��������j������������������dd�������\��}}|�j�������������������j������������������|��������t��������|�j��������������������������|�j������������������k\��r�X|�j�������������������j��������������������������D�]K��} �|rdnt��������j������������������}t��������j������������������||�������\��}}|�j�������������������j������������������|���������M�y�#�t��������$�r�|�j�������������������j���������������������������Y���t��������$�r�Y���w�xY�w#�t��������$�r�|�j�������������������j������������������|��������Y���t��������$�r�Y���w�xY�w)N���r���)�active_children�len�max_children�os�waitpid�discard�ChildProcessErrorr.���rK����copy�WNOHANG)r#���r�����pid�_�flagss��� r$����collect_childrenzForkingMixIn.collect_children6��s+�����I��#�#�+����d�*�*�+�t�/@�/@�@���Z�Z��A�.�F�C���(�(�0�0��5���d�*�*�+�t�/@�/@�@���+�+�0�0�2�� �!)�A�r�z�z�E��Z�Z��U�3�F�C����(�(�0�0��5� �3���)��1��(�(�.�.�0��������)��6��(�(�0�0��5������s0����4C2��'AD%�2#D"�D"�!D"�%$E�E�Ec������������������&����� �|�j���������������������������y�r(����r����r*���s��� r$���rF���zForkingMixIn.handle_timeoutY��������� �� �!�!�#r&���c������������������&����� �|�j���������������������������y�r(���r����r*���s��� r$���r5���zForkingMixIn.service_actions`��r����r&���c������������������@���� �t��������j��������������������������}|rH|�j�������������������t����������������|�_��������|�j������������������j ������������������|��������|�j������������������|��������y�d} �|�j ������������������||��������d} �|�j������������������|��������t��������j������������������|��������y�#�t��������$�r�|�j������������������||��������Y��Ew�xY�w#�t��������j������������������|��������w�xY�w#� �|�j������������������|��������t��������j������������������|��������w�#�t��������j������������������|��������w�xY�wxY�w)Nrx���r���)r����r���r����r6����addr]���rW���rN���rO���rP����_exit)r#���rR���rS���r�����statuss��� r$���rM���zForkingMixIn.process_requestg��s�������?��'�'�)�C���'�'�/�+.�5�D�(��$�$�(�(��-��"�"�7�+����� )��'�'���@��F�)��-�-�g�6�����(�� �!��?��%�%�g�~�>�?�������(��)��-�-�g�6�����(������(�sH����#B��8C���B=�:C��<B=�=C���C�D�D�-D�D�Dc������������������Z������t����������|�������������|�j������������������|�j���������������������������y�)Nr����)�superrY���r�����block_on_close�r#���� __class__s��� �r$���rY���zForkingMixIn.server_close���s%��������G� �"��!�!�4�+>�+>�!�?r&���) rl���rm���rn���rC���r����r����r����r����rF���r5���rM���rY���� __classcell__�r����s���@r$���r���r���-��s>�������C���������/4��! �F $� $� )�2 @�� @r&���r���c��������������������2�������e�Zd�Z ���fd�Zd��Zd��Zd��Z��xZS�)�_Threadsc������������������^������|�j���������������������������|j������������������ry�t���������|�� ��|��������y�r(���)�reap�daemonr�����append)r#����threadr����s��� �r$���r����z_Threads.append���s"�������� � ���=�=�� ���v�r&���c�����������������������g�|�d�d��c|�d�d��}|S�r(���r)���)r#����results��� r$����pop_allz_Threads.pop_all���s�������d�1�g���Q���� r&���c������������������N�����|�j��������������������������D�]��}|j�����������������������������y�r(���)r�����join�r#���r����s��� r$���r����z _Threads.join���s�������l�l�n�F��K�K�M��%r&���c�����������������������d��|�D���������|�d�d��y�)Nc��������������3����B���K����|�]��}|j��������������������������s�|�����y��wr(���)�is_alive)�.0r����s��� r$���� <genexpr>z _Threads.reap.<locals>.<genexpr>���s���������B��f����0A�6��s�����r)���r*���s��� r$���r����z _Threads.reap���s������B��B��Q�r&���)rl���rm���rn���r����r����r����r����r����r����s���@r$���r����r�������s�����������Cr&���r����c�������������������������e�Zd�Z �d��Zd��Zy)� _NoThreadsc������������������������y�r(���r)���r����s��� r$���r����z_NoThreads.append����������r&���c������������������������y�r(���r)���r*���s��� r$���r����z_NoThreads.join���r����r&���N)rl���rm���rn���r����r����r)���r&���r$���r����r�������s������� � r&���r����c��������������������B�������e�Zd�Z �dZdZ�e��������Zd��Zd��Z��fd�Z ��xZ S�)r ���FTc����������������������� � �|�j������������������||��������|�j������������������|��������y�#�t��������$�r�|�j������������������||��������Y��/w�xY�w#�|�j������������������|��������w�xY�wr(���)rW���rN���rO���rP���rQ���s��� r$����process_request_threadz%ThreadingMixIn.process_request_thread���s^������ � +������8�� �!�!�'�*����� 7����g�~�6� 7��� �!�!�'�*�s!����'��A�A��A�A��Ac������������������"���� �|�j�������������������r#t��������|��������j������������������dt������������������������t ��������j ������������������|�j������������������||f��������}|�j������������������|_��������|�j������������������j������������������|��������|j���������������������������y�)N�_threads)�targetrj���)r�����vars� setdefaultr����r����Threadr�����daemon_threadsr����r����r�����start)r#���rR���rS����ts��� r$���rM���zThreadingMixIn.process_request���sl������8������J�!�!�*�h�j�9����d�&A�&A�%,�n�$=� ?���&�&���� � ���Q�� ��� r&���c������������������V������t����������|�������������|�j������������������j���������������������������y�r(���)r����rY���r����r����r����s��� �r$���rY���zThreadingMixIn.server_close���s������� ����� � ���r&���)rl���rm���rn���r����r����r����r����r����rM���rY���r����r����s���@r$���r ���r ������s/�������>���N��N���|�H�+����r&���r ���c�������������������������e�Zd�Zy)r���N�rl���rm���rn���r)���r&���r$���r���r������������r&���r���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���r���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���r���c�������������������������e�Zd�Zy)r ���Nr����r)���r&���r$���r ���r ������r����r&���r ���c��������������������$�����e�Zd�Zej������������������Zy)r���N�rl���rm���rn���rA���r���rr���r)���r&���r$���r���r����������������r&���r���c��������������������$�����e�Zd�Zej������������������Zy)r���Nr����r)���r&���r$���r���r������r����r&���r���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���r���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���r���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���c�������������������������e�Zd�Zy)r���Nr����r)���r&���r$���r���r������r����r&���c��������������������&�����e�Zd�Z �d��Zd��Zd��Zd��Zy)r ���c�����������������������||�_���������||�_��������||�_��������|�j��������������������������� �|�j ���������������������������|�j���������������������������y�#�|�j���������������������������w�xY�wr(���)rR���rS����server�setup�handle�finish)r#���rR���rS���r����s��� r$���r%���zBaseRequestHandler.__init__���sB���������,������� � �� ��K�K�M��K�K�M��D�K�K�M�s����A��Ac������������������������y�r(���r)���r*���s��� r$���r����zBaseRequestHandler.setup��r����r&���c������������������������y�r(���r)���r*���s��� r$���r����zBaseRequestHandler.handle��r����r&���c������������������������y�r(���r)���r*���s��� r$���r����zBaseRequestHandler.finish��r����r&���N)rl���rm���rn���r%���r����r����r����r)���r&���r$���r ���r ������s������� � � � r&���r ���c��������������������*�����e�Zd�Z �dZdZdZdZd��Zd��Zy)r���r����r���NFc����������������������|�j�������������������|�_��������|�j�������������������%|�j������������������j������������������|�j��������������������������|�j������������������r9|�j������������������j������������������t��������j������������������t��������j������������������d��������|�j������������������j������������������d|�j�������������������������|�_��������|�j������������������dk(��rt��������|�j�������������������������|�_��������y�|�j������������������j������������������d|�j�������������������������|�_��������y�)NT�rbr����wb)rR���� connectionrC���� settimeout�disable_nagle_algorithmr|���rA����IPPROTO_TCP�TCP_NODELAY�makefile�rbufsize�rfile�wbufsize� _SocketWriter�wfiler*���s��� r$���r����zStreamRequestHandler.setup)��s��������,�,����<�<�#��O�O�&�&�t�|�|�4��'�'��O�O�&�&�v�'9�'9�'-�'9�'9�4� A��_�_�-�-�d�D�M�M�B�� ��=�=�A��&�t���7�D�J����1�1�$�� � �F�D�Jr&���c�����������������������|�j�������������������j������������������s �|�j�������������������j���������������������������|�j�������������������j���������������������������|�j������������������j���������������������������y�#�t��������j������������������$�r�Y��Jw�xY�wr(���)r���closed�flushrA����errorr����r��r*���s��� r$���r����zStreamRequestHandler.finish6��s`�������z�z� � � �� � � � �"� � � � ����� � �������<�<�� ��� �s����A'��'A=�<A=) rl���rm���rn���r��r��rC���r����r����r����r)���r&���r$���r���r�����s+������>���H��H���G��$��G� r&���r���c��������������������&�����e�Zd�Z �d��Zd��Zd��Zd��Zy)r��c�����������������������||�_���������y�r(���)�_sock)r#����socks��� r$���r%���z_SocketWriter.__init__F��s �������� r&���c������������������������yr<���r)���r*���s��� r$����writablez_SocketWriter.writableI��s������r&���c�����������������������|�j�������������������j������������������|��������t��������|�������5�}|j������������������cd�d�d���������S�#�1�sw�Y���y�xY�wr(���)r���sendall� memoryview�nbytes)r#����b�views��� r$����writez_SocketWriter.writeL��s.������� � ���1�� ��]�d��;�;���]�]�s ����=�Ac������������������6�����|�j�������������������j��������������������������S�r(���)r��r����r*���s��� r$���r����z_SocketWriter.filenoQ��s�������z�z� � �"�"r&���N)rl���rm���rn���r%���r��r��r����r)���r&���r$���r��r��A��s������J���� #r&���r��c�������������������������e�Zd�Z �d��Zd��Zy)r���c�����������������������ddl�m}�|�j������������������\��|�_��������|�_���������||�j�������������������������|�_���������|��������|�_��������y�)Nr���)�BytesIO)�ior��rR����packetrA���r��r��)r#���r��s��� r$���r����zDatagramRequestHandler.setupX��s0�������#'�<�<� ���T�[��T�[�[�)�� ��Y�� r&���c�����������������������|�j�������������������j������������������|�j������������������j��������������������������|�j��������������������������y�r(���)rA����sendtor���getvaluerS���r*���s��� r$���r����zDatagramRequestHandler.finish^��s)�����������4�:�:�.�.�0�$�2E�2E�Fr&���N)rl���rm���rn���r����r����r)���r&���r$���r���r���T��s������@��Gr&���r���)&�__version__rA���r1���r����rc���r���r��r���rE���r����__all__r{����extendr���r/����SelectSelectorr���r���r���r����listr����r����r ���r���r���r���r ���r���r���r���r���r���r���r ���r���r��r���r)���r&���r$����<module>r'�����s�����v�t�������� �� ������"�7����2�v���N�N�J�K� �6�9���N�N��3��4���r�6�����1�3N�O�P���9�n�%��,�,�O��.�.�O�j��j�ZE� ��E�P � �� �8��2�v��U@��U@�pC�t��C�, �� �%��%�P��2�v��9�<��9�9�<��9��9����9��9����9� �6�9��(�9��(�(�Y��(��L�N�4D�K�O�n�6H�O��r�6��K�l�4D�K�O��6H�O�# ��# �\+�-��+�Z#�N��#�&G�/��Gr&���