Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
web_runner.cpython-313.pyc131 linesDownload Raw Back to __pycache__
1�

2��j�/���SSKrSSKrSSKrSSKrSSKJrJr SSKJrJ	r	J3r4JrJr SSK
Jr SSKJr SSKJr SSKJr \(aSS	KJr OSS	KJr S5r"SS\5rSS
jr"SS\5r"SS\5r"SS\5r"SS\5r "SS\5r!"SS\5r""SS\"5r#"SS\"5r$g!\a \rNuf=f)�N)�ABC�abstractmethod)�
TYPE_CHECKING�Any�List�Optional�Set)�URL�)�PathLike)�Application)�Server)�6SSLContext)	�BaseSite�TCPSite�UnixSite�
NamedPipeSite�SockSite�7BaseRunner�	AppRunner�ServerRunner�GracefulExitc��\rSrSrSrSrg)r�#r�N)�__name__�8__module__�__qualname__�__firstlineno__�code�__static_attributes__r��XD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/web_runner.pyrr#s���Dr"rc��[5e�N)rrr"r#�_raise_graceful_exitr&'s9��10�.�r"c��\rSrSrSrSSSS.SSS	\S11\\S\SS412S
jjr	\13\S\4Sj55r
\SSj5rSSjrSrg)r�+)�_runner�_ssl_context�_backlog�_server�N@N���shutdown_timeout�ssl_context�backlog�runnerrr0r1r2�returnc��URc[S5eUS:wa"Sn[R"U[SS9 X!lXlX0lX@lSUl	g)Nz(Call runner.setup() before making a siter-z,shutdown_timeout should be set on BaseRunner�)�14stacklevel)15�server�RuntimeError�warnings�warn�DeprecationWarning�_shutdown_timeoutr)r*r+r,)�selfr3r0r1r2�msgs      r#�__init__�BaseSite.__init__.sU���=�=� ��I�J�J��t�#�@�C��M�M�#�1�a�@�'7�$���'���
�9=��r"c��gr%r�r>s r#�name�
BaseSite.nameAs��	
r"c��B# �URRU5 g7fr%)r)�	_reg_siterCs r#�start�BaseSite.startFs��������t�$�s�c���# �URRU5 URbURR5 URR	U5 g7fr%)r)�_check_siter,�close�_unreg_siterCs r#�stop�
BaseSite.stopJsC������ � ��&��<�<�#��L�L��� ���� � ��&�s�AA!)r+r)r,r*�r4N)rrrr�	__slots__�floatrr�intr@�propertyr�strrDrHrNr!rr"r#rr+s���B�I�#'�,0��
>��>� �	>�16�j�)�>��
>�17�>�&��
�c�
���
��%��%�'r"rc�^�\rSrSrSrSSSSSSS.SSS	\\S18\\S\S\\	S
\S\\19S\\20SS4U4Sjjjjr\S\4Sj5r
SU4SjjrSrU=r$)r�R)�_host�_port�_reuse_address�_reuse_portNr-r.)r0r1r2�
reuse_address�21reuse_portr3r�host�portr0r1r2r\r]r4c�>�[T	U]UUUUS9 X lUcUR(aSOSnX0lXplX�lg)Nr/i� i�)�superr@rXr*rYrZr[)22r>r3r^r_r0r1r2r\r]�	__class__s23         �r#r@�TCPSite.__init__UsO���	����-�#��		�	24��25��<��,�,�4�$�D��26�+��%�r"c��UR(aSOSnUR(dSOURn[[R"XUR27S95$)N�https�httpz0.0.0.0��schemer^r_)r*rXrUr28�buildrY)r>rhr^s   r#rD�TCPSite.namens<�� �-�-��6�� $�29�30�y��31�32���3�9�9�F�D�J�J�G�H�Hr"c33��^># �[TU]5IShv�N [R"5nURR34nUceUR
UURURURURURURS9IShv�NUl
gN�N7f)N)�sslr2r\r])rarH�asyncio�get_event_loopr)r8�
create_serverrXrYr*r+rZr[r,�r>�loopr8rbs   �r#rH�
TCPSite.startts������g�m�o����%�%�'�����$�$���!�!�!�!�/�/���J�J��J�J��!�!��M�M��-�-��'�'�0�35�36���		�37�s"�B-�B)�BB-�B+�B-�+B-)rXrYrZr[r,)NNrP)rrrrrQrrUrSrRr�boolr@rTrDrHr!�
__classcell__�rbs@r#rrRs����C�I�38#�"�	&�#'�,0��(,�%)�&��&��s�m�&��s�m�	&� �
&��j�)�&��&� ��~�&��T�N�&�39�&�&�2�I�c�I��I�40
41�
42r"rc
�^�\rSrSrSrSSSS.SSS	\S43\S\\S\	S
S4U4Sjjjr44\S
\4Sj5r
SU4SjjrSrU=r$)r���_pathr-Nr.r/r3r�pathr0r1r2r4c�2>�[TU]UUUUS9 X lg)Nr/)rar@ry)r>r3rzr0r1r2rbs      �r#r@�UnixSite.__init__�s*���	����-�#��		�	45��46r"c�P�UR(aSOSnUSURS3$)Nrerf�://unix:�:)r*ry)r>rhs  r#rD�
UnixSite.name�s(�� �-�-��6�����$�*�*��Q�/�/r"c��># �[TU]5IShv�N [R"5nURR47nUceUR
UURURURS9IShv�NUl48gNrN7f)N)rlr2)rarHrmrnr)r8�create_unix_serverryr*r+r,rps   �r#rH�UnixSite.start�s~�����g�m�o����%�%�'�����$�$���!�!�!�!�4�4���J�J��!�!��M�M�	5�49�50���		�51�s"�B�B�A'B�=B52�>B�53B�ryr,rP)rrrrrQrrRrrrSr@rTrUrDrHr!rtrus@r#rr�s�����I�#'�,0�������54 ���j�)�
���55���"�0�c�0��0�5657�5859r"rc	�p^�\rSrSrSrSS.SSS\S\S	S604U4Sjjjr\S	\4Sj5r	SU4S
jjr61SrU=r$)r�rxr-�r0r3rrzr0r4Nc�>�[R"5n[U[R5(d[	S5e[62TU]XS9 X lg)Nz9Named Pipes only available in proactor loop under windowsr�)rmrn�63isinstance�ProactorEventLoopr9rar@ry)r>r3rzr0rqrbs     �r#r@�NamedPipeSite.__init__�sT����%�%�'����'�+�+�64�65��K��
�	�����C��66r"c��UR$r%rxrCs r#rD�NamedPipeSite.name�����z�z�r"c���># �[TU]5IShv�N [R"5nURR67nUceUR
X R5IShv�NnUSUlgNbN7f�Nr)	rarHrmrnr)r8�start_serving_piperyr,)r>rqr8r,rbs    �r#rH�NamedPipeSite.start�sq�����g�m�o����%�%�'�����$�$���!�!�!��/�/��J�J�68�69���q�z���	�70�s"�A<�A8�AA<�(A:�)A<�:A<r�rP)
rrrrrQrUrRr@rTrDrHr!rtrus@r#rr�s^����I�MQ��"��*-��DI��	
�����c����"�"r"rc
�^�\rSrSrSrSSSS.SSS	\R71S72\S\\S\	S
S4U4Sjjjr73\S
\4Sj5r
SU4SjjrSrU=r$)r��)�_sock�_namer-Nr.r/r3r�sockr0r1r2r4c�b>�[T74U]UUUUS9 X lUR(aSOSn[	[75S5(a5UR[76R:XaUSUR5S3nO3UR5SSup�[[R"XhU	S95nXplg)	Nr/rerf�AF_UNIXr~rr6rg)
rar@r�r*�hasattr�socket�familyr��getsocknamerUr77rir�)r>r3r�r0r1r2rhrDr^r_rbs          �r#r@�SockSite.__init__�s����	����-�#��		�	78��79� �-�-��6���6�9�%�%�$�+�+����*G��X�X�d�&6�&6�&8�%9��;�D��)�)�+�B�Q�/�J�D��s�y�y���E�F�D��80r"c��UR$r%)r�rCs r#rD�
SockSite.name�r�r"c��># �[TU]5IShv�N [R"5nURR81nUceUR
X RURURS9IShv�NUl82gNqN7f)N)r�rlr2)rarHrmrnr)r8ror�r*r+r,rps   �r#rH�SockSite.start�sy�����g�m�o����%�%�'�����$�$���!�!�!�!�/�/�����):�):�D�M�M�0�83�84���		�85�s"�B�B�A&B�<B	�=B�	B)r�r,r�rP)rrrrrQr�rRrrrSr@rTrUrDrHr!rtrus@r#rr�s����"�I�#'�,0������m�m��86 ���j�)�
���87���0��c����88�89r"rc	� �\rSrSrSrSSS.S\S\S\S	S904Sjjr\	S	\91\4Sj5r\	S	\
\4S
j5r\	S	\\4Sj5rSSjr\SSj5rSSjr\S	\4Sj5r\SSj5rS\S	S924SjrS\S	S934SjrS\S	S944SjrSrg95)r����_handle_signals�_kwargsr,�_sitesr=Fr-)�handle_signalsr0r�r0�kwargsr4Nc�D�XlX0lSUl/UlX lgr%r�)r>r�r0r�s    r#r@�BaseRunner.__init__�s#�� .����)-���&(���!1�r"c��UR$r%)r,rCs r#r8�BaseRunner.servers���|�|�r"c���/nURHMnURnUcMURnUcM%UH"nURUR	55 M$ MO U$r%)r�r,�sockets�appendr�)r>�ret�siter8r�r�s      r#�	addresses�BaseRunner.addressessY�����K�K�D��\�\�F��!� �.�.���&� '���96�97�4�#3�#3�#5�6�!(� ��98r"c�,�[UR5$r%)�setr�rCs r#�sites�BaseRunner.sitess���4�;�;��r"c��H# �[R"5nUR(aIUR[R99[5 UR[R[5 UR5IShv�NUl100g![a N*f=fN7fr%)rmrnr��add_signal_handler�signal�SIGINTr&�SIGTERM�NotImplementedError�_make_serverr,�r>rqs  r#�setup�BaseRunner.setupsy����%�%�'�����
��'�'��
�
�7K�L��'�'����8L�M�101"�.�.�0�0����	'�
��
��1�s5�'B"�AB�2B"�B �102B"�103B�B"�B�B"c��# �g7f)z8Call any shutdown hooks to help server close gracefully.NrrCs r#�shutdown�BaseRunner.shutdown#s�����c���# �[UR5HnUR5IShv�N M UR(a}[R104"S5IShv�N URR
5 UR5IShv�N URRUR5IShv�N UR5IShv�N SUlUR(aU[R"5nUR[R5 UR[R5 ggGNN�N�N�N{![ a gf=f7fr�)�listr�rNr,rm�sleep�pre_shutdownr�r=�_cleanup_serverr��get_running_loop�remove_signal_handlerr�r�r�r�)r>r�rqs   r#�cleanup�BaseRunner.cleanup's���105����%�D��)�)�+���&��<�<��-�-��"�"�"��L�L�%�%�'��-�-�/�!�!��,�,�'�'��(>�(>�?�?�?��"�"�$�$�$��������+�+�-�D�
��*�*�6�=�=�9��*�*�6�>�>�:�	 �
�106
#�!�?�$��'�
��
�s{�,E&�E�2E&�!E�"1E&�E�,E&�E�E&�E�1E&�>E�	E&�E&�E&�E&�E&�107E#� E&�"E#�#E&c��# �g7fr%rrCs r#r��BaseRunner._make_serverB�����r�c��# �g7fr%rrCs r#r��BaseRunner._cleanup_serverFr�r�r�c�z�XR;a[SUSU35eURRU5 g)N�Site z! is already registered in runner )r�r9r��r>r�s  r#rG�BaseRunner._reg_siteJs7���;�;����t�f�,M�d�V�T�U�U������4� r"c�D�XR;a[SUSU35eg�Nr�z is not registered in runner )r�r9r�s  r#rK�BaseRunner._check_siteOs*���{�{�"���t�f�,I�$��P�Q�Q�#r"c�z�XR;a[SUSU35eURRU5 gr�)r�r9�remover�s  r#rM�BaseRunner._unreg_siteSs7���{�{�"���t�f�,I�$��P�Q�Q������4� r")r�r�r,r=r�rP)rrrrrQrsrRrr@rTrrr8rr�r	rr�r�rr�r�r�r�rGrKrMr!rr"r#rr�s%��X�I�108 %�"&�	2��2� �	2�109�2�110�
2�����(�����	�4��9�	��	�� �s�8�}� �� �1��G��G��6�
�F�
��
��
��
�!�h�!�4�!�111R��R�T�R�!��!�T�!r"rc	�n^�\rSrSrSrSrSS.S\S\S\S	S1124U4Sjjjr	SSjr113S	\4S
jrSSjrSr
U=r$)riYzLow-level web server runner��_web_serverF�r��114web_serverr�r�r4Nc�6>�[TU]"SSU0UD6 Xlg)Nr�r)rar@r�)r>r�r�r�rbs    �r#r@�ServerRunner.__init__^s ���	���A��A�&�A�%�r"c��# �g7fr%rrCs r#r��ServerRunner.shutdownd�����r�c��"# �UR$7fr%r�rCs r#r��ServerRunner._make_servergs�������s�
c��# �g7fr%rrCs r#r��ServerRunner._cleanup_serverjr�r�rP)rrrr�__doc__rQrrsrr@r�r�r�r!rtrus@r#rrYsV���%� �I�=B�&� �&�59�&�MP�&�	
�&�&�
� �F� �
�
r"rc	�^�\rSrSrSrSrSS.S\S\S\S	S1154U4Sjjjr	\116S	\4Sj5rSS
jrS	\
4SjrSSjrSrU=r$)rinzWeb Application runner��_appFr��appr�r�r4Nc�>�[TU]"SSU0UD6 [U[5(d[	SRU55eXlg)Nr�z?The first argument should be web.Application instance, got {!r}r)rar@r�r
�	TypeError�formatr�)r>r�r�r�rbs    �r#r@�AppRunner.__init__ssI���	���A��A�&�A��#�{�+�+��%�%+�V�C�[��
��	r"c��UR$r%r�rCs r#r��
AppRunner.app~s���y�y�r"c��T# �URR5IShv�N gN7fr%)r�r�rCs r#r��AppRunner.shutdown�s����i�i� � �"�"�"���(�&�(c��~# �[R"5nURRU5 URRR5 URR
5IShv�N URR5 URR"SSU0URD6$NF7f)Nrqr)	rmrnr��	_set_loop�117on_startup�freeze�startup�
_make_handlerr�r�s  r#r��AppRunner._make_server�s�����%�%�'���	�	���D�!��	�	���#�#�%��i�i���!�!�!��	�	�����y�y�&�&�A�D�A�D�L�L�A�A�	"�s�A2B=�4B;�5AB=c��T# �URR5IShv�N gN7fr%)r�r�rCs r#r��AppRunner._cleanup_server�s����i�i���!�!�!�r�rP)rrrrr�rQr
rsrr@rTr�r�rr�r�r!rtrus@r#rrnss��� ��I�;@�	��	�37�	�KN�	�	
�	�	���[����#�B�F�B�"�"r"rrP)%rmr�r�r:�abcrr�typingrrrrr	�yarlr118�typedefsr�web_appr
r�rrlr�ImportError�object�__all__�119SystemExitrr&rrrrrrrrrr"r#�<module>rs����
�
��#�:�:��� �����"�120��
�:�
��$'�s�$'�N/121�h�/122�d#123�x�#124�L"�H�"�>&125�x�&126�Rd!��d!�N
�:�
�*!"�127�!"��w128���129��s�B?�?C130�	C131
codekingpro/portable-devtools · Team Ai