← Back
Editing: web_server.cpython-311.pyc
� �|oi � � � d Z ddlZddlmZmZmZmZmZmZ ddl m Z ddl m Z ddl mZ ddlmZ dd lmZmZmZ dd lmZ d Z G d � d � � ZdS )zLow level HTTP server.� N)�Any� Awaitable�Callable�Dict�List�Optional� )�AbstractStreamWriter)�get_running_loop)�RawRequestMessage)� StreamReader)�RequestHandler�_RequestFactory�_RequestHandler)� BaseRequest)�Serverc � � e Zd Zdddd�dedee dedeej de d df d �Z e d e e fd �� � Zde d ej d dfd �Z dde dee d dfd�Zdedede deddd ef d�Zd d�Zddee d dfd�Zd e fd�ZdS ) r NF)�request_factory�handler_cancellation�loop�handlerr r r �kwargs�returnc � � t |� � | _ i | _ || _ d| _ || _ |p| j | _ || _ d S )Nr ) r �_loop� _connections�_kwargs�requests_count�request_handler� _make_requestr r )�selfr r r r r s �I/opt/cloudlinux/venv/lib64/python3.11/site-packages/aiohttp/web_server.py�__init__zServer.__init__ sP � � &�d�+�+�� �EG��� �� � ��� &�� � .� D�$�2D�� �$8��!�!�!� c �N � t | j � � � � � S �N)�listr �keys)r! s r" � connectionszServer.connections! s � ��D�%�*�*�,�,�-�-�-r$ � transportc � � || j |< d S r& �r )r! r r* s r" �connection_madezServer.connection_made% s � � &/���'�"�"�"r$ �excc �, � || j v r | j |= d S d S r& r, )r! r r. s r" �connection_lostzServer.connection_lost* s+ � � �d�'� '� '��!�'�*�*�*� (� 'r$ �message�payload�protocol�writer�taskzasyncio.Task[None]c �4 � t |||||| j � � S r& )r r )r! r1 r2 r3 r4 r5 s r" r zServer._make_request0 s � � �7�G�X�v�t�T�Z�P�P�Pr$ c �B � | j D ]}|� � � �d S r& )r �close)r! �conns r" � pre_shutdownzServer.pre_shutdown: s- � ��%� � �D� �J�J�L�L�L�L� � r$ �timeoutc � � �K � �fd�| j D � � }t j |� � d {V �� | j � � � d S )Nc 3 �B �K � | ]}|� �� � V � �d S r& )�shutdown)�.0r9 r; s �r" � <genexpr>z"Server.shutdown.<locals>.<genexpr>? s/ �� � � �F�F�D�� � �w�'�'�F�F�F�F�F�Fr$ )r �asyncio�gather�clear)r! r; �coross ` r" r> zServer.shutdown> s] �� � � �F�F�F�F�D�4E�F�F�F���n�e�$�$�$�$�$�$�$�$� �� � �!�!�!�!�!r$ c �� � t | fd| j i| j ��S # t $ r: d� | j � � � D � � }t | fd| j i|��cY S w xY w)Nr c �" � i | ] \ }}|d v � ||�� S ))�debug�access_log_class� )r? �k�vs r" � <dictcomp>z#Server.__call__.<locals>.<dictcomp>H s4 � � � � ��A�q��5�5�5� �1�5�5�5r$ )r r r � TypeError�items)r! r s r" �__call__zServer.__call__C s� � � C�!�$�H�H�T�Z�H�4�<�H�H� H��� C� C� C�� � �L� .� .� 0� 0�� � �F� "�$�B�B�T�Z�B�6�B�B� B� B� B� C���s � �AA � A r& )r N) �__name__� __module__� __qualname__r r r �boolrA �AbstractEventLoopr r# �propertyr r r) � Transportr- � BaseExceptionr0 r r r r r r: �floatr> rO rI r$ r" r r s� � � � � � � 6:�%*�48� 9� 9� 9� �9� "�/�2� 9� #� 9� �w�0�1� 9� �9� �9� 9� 9� 9�" �.�T�.� 1� .� .� .� �X�.�/�%�/�29�2C�/� �/� /� /� /� GK�+� +�%�+�,4�]�,C�+� �+� +� +� +� Q�"�Q� �Q� !� Q� %� Q� #� Q� �Q� Q� Q� Q�� � � �"� "�h�u�o� "�� "� "� "� "� C�.� C� C� C� C� C� Cr$ r )�__doc__rA �typingr r r r r r �abcr �helpersr � http_parserr �streamsr � web_protocolr r r � web_requestr �__all__r rI r$ r" �<module>rb s� �� � � ���� A� A� A� A� A� A� A� A� A� A� A� A� A� A� A� A� %� %� %� %� %� %� %� %� %� %� %� %� *� *� *� *� *� *� !� !� !� !� !� !� J� J� J� J� J� J� J� J� J� J� $� $� $� $� $� $� ��>C� >C� >C� >C� >C� >C� >C� >C� >C� >Cr$
Save File
Cancel