codekingpro/portable-devtools
115k
1�
2 ��j� � � � S r SSKrSSKJrJrJrJrJrJr SSK J3r4 SSK J r SSK
Jr SSKJrJrJr SS KJr S5r " S S 5 rg)
zLow level HTTP server.� N)�Any� Awaitable�Callable�Dict�List�Optional� )�AbstractStreamWriter)�RawRequestMessage)� StreamReader)�RequestHandler�_RequestFactory�_RequestHandler)� BaseRequest)�Serverc
�" � \ rS rSrSSSS.S\S\\ S\S\\R S \6S7S4 S jjr \ S8\
\ 4S j5 rS\S
\R S9S4S jr S S\S\\ S10S4S jjrS\S\S\S\SSS11\4 S jrS S jrS S\\ S12S4S jjrS13\4S jr S r g) r � NF)�request_factory�handler_cancellation�loop�handlerr r r �kwargs�returnc � � U=( d [ R " 5 U l 0 U l XPl SU l Xl U=( d U R U l X0l g )Nr )14�asyncio�get_running_loop�_loop� _connections�_kwargs�requests_count�request_handler�
_make_requestr r )�selfr r r r r s �XD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/web_server.py�__init__�Server.__init__ sO � � �7�W� 5� 5� 7��15�EG��� � � ��� &� � .� D�$�2D�2D�� �$8�!� c �H � [ U R R 5 5 $ �N)�listr �keys)r# s r$ � connections�Server.connections# s � ��D�%�%�*�*�,�-�-r' � transportc � � X R U' g r) )r )r# r r. s r$ �connection_made�Server.connection_made' s � � &/���'�"r' �excc � ^ ^� TT R ; a@ TR ( a! TR R UU 4S j5 g T R T g g )Nc �< >� TR R TS 5 $ r) )r �pop)�fr r# s ��r$ �<lambda>�(Server.connection_lost.<locals>.<lambda>2 s �� �d� /� /� 3� 3�G�T� Br' )r �
_task_handler�add_done_callback)r# r r2 s `` r$ �connection_lost�Server.connection_lost, sH �� � �d�'�'� '��$�$��%�%�7�7�B�� �%�%�g�.�
(r' �message�payload�protocol�writer�taskzasyncio.Task[None]c �0 � [ XX4XPR 5 $ r) )r r )r# r= r> r? r@ rA s r$ r" �Server._make_request7 s � � �7�X�t�Z�Z�P�Pr' c �J � U R H nUR 5 M g r) )r �close)r# �conns r$ � pre_shutdown�Server.pre_shutdownA s � ��%�%�D� �J�J�L� &r' �timeoutc � � ^# � U4S jU R 5 n[ R " U6 I S h v�N U R R 5 g N 7f)Nc 3 �D ># � U H oR T5 v � M g 7fr) )�shutdown)�.0rF rI s �r$ � <genexpr>�"Server.shutdown.<locals>.<genexpr>F s �� � �F�4E�D� � �w�'�'�4E�s � )r r �gather�clear)r# rI �coross ` r$ rL �Server.shutdownE s? �� � �F�D�4E�4E�F���n�n�e�$�$�$� ��� � �!� %�s �-A�A� Ac � � [ U 4SU R 0U R D6$ ! [ aX U R R 5 VVs0 s H u pUS; d M
X_M Os snnf nnn[ U 4SU R 0UD6s $ f = f)Nr )�debug�access_log_class)r
r r � TypeError�items)r# �k�vr s r$ �__call__�Server.__call__J s� � � C�!�$�H�T�Z�Z�H�4�<�<�H� H��� C� !�L�L� .� .� 0�� 0�D�A��5�5� ��� 0���F� �16 "�$�B�T�Z�Z�B�6�B� B� C�s! �!$ �'B� A"�A"�!"B�B)r r r r r r! r r) )r N) �__name__�17__module__� __qualname__�__firstlineno__r r r �boolr �AbstractEventLoopr r% �propertyr r
r, � Transportr0 �
BaseExceptionr; r r r18 r r" rG �floatrL r[ �__static_attributes__� r' r$ r r s8 � �19 6:�%*�48�
9� �9� "�/�2� 9�20 #� 9� �w�0�0�1�
9� �9� 21�9�& �.�T�.� 1� .� �.�/�%�/�29�2C�2C�/�
�/� GK� /�%� /�,4�]�,C� /�
� /�Q�"�Q� �Q� !� Q�22 %� Q� #�
Q� 23�Q��"�h�u�o� "�� "�24 25C�.� 26Cr' r )�__doc__r �typingr r r r r r �abcr27 � http_parserr �streamsr � web_protocolr
r r � web_requestr �__all__r rh r' r$ �<module>rq s6 �� � � A� A� %� *� !� J� J� $�28��EC� ECr'