Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��j!o���SSKJr SSKJrJr SSKJrJrJrJ	r	J3r4Jr SSKJr SSK
JrJr SSKJr SSKJrJr SSKJrJrJrJr SS	KJr SS5KJr SSKrSSKrSSK r SSK!r!SSK"r"SSK#r#SSK$r$SSK%r%SSK&r&SSK'J(r( SSK)r*SS
K+J,r,J-r-J.r.J/r/J0r0J1r1 SSK2J3r3 SSK+r+\+Rh(a6SSK+J5r5J6r6J7r7 "SS\5r8"SS\5r9"SS\5r:"SS\Rv5r<\=S:Xa\R|"\:5 \	"5 gg)�)�_unicode)�gen�version)�HTTPResponse�	HTTPError�AsyncHTTPClient�main�
_RequestProxy�HTTPRequest)�httputil)�HTTP1Connection�HTTP1ConnectionParameters)�IOLoop)�StreamClosedError�IOStream)�Resolver�OverrideResolver�_client_ssl_defaults�is_valid_ip)�gen_log)�	TCPClientN)�BytesIO)�Dict�Any�Callable�Optional�Type�Union)�
TracebackType)�Deque�Tuple�Listc�F^�\rSrSrSrS\SS4U4SjjrS\4SjrSrU=r	$)	�HTTPTimeoutError�,z�Error raised by SimpleAsyncHTTPClient on timeout.7 8For historical reasons, this is a subclass of `.HTTPClientError`9which simulates a response code of 599.10 11.. versionadded:: 5.112�message�returnNc�">�[TU]SUS9 g�N�W�r&��super�__init__��selfr&�	__class__s  ��_D:\code\apps\devtools\python\user_packages\Python313\site-packages\tornado/simple_httpclient.pyr.�HTTPTimeoutError.__init__5����
����g��.�c�,�UR=(d S$)N�Timeoutr+�r0s r2�__str__�HTTPTimeoutError.__str__8s���|�|�(�y�(r5��13�__name__�14__module__�__qualname__�__firstlineno__�__doc__�strr.r9�__static_attributes__�
__classcell__�r1s@r2r$r$,s,����/��/��/�)��)�)r5r$c�F^�\rSrSrSrS\SS4U4SjjrS\4SjrSrU=r	$)	�HTTPStreamClosedError�<aBError raised by SimpleAsyncHTTPClient when the underlying stream is closed.15 16When a more specific exception is available (such as `ConnectionResetError`),17it may be raised instead of this one.18 19For historical reasons, this is a subclass of `.HTTPClientError`20which simulates a response code of 599.21 22.. versionadded:: 5.123r&r'Nc�">�[TU]SUS9 gr)r,r/s  �r2r.�HTTPStreamClosedError.__init__Hr4r5c�,�UR=(d S$)N�
Stream closedr+r8s r2r9�HTTPStreamClosedError.__str__Ks���|�|�.��.r5r;r<rEs@r2rGrG<s,���	�/��/��/�/��/�/r5rGc�R^�\rSrSrSrSS\S\\\\4S\S\\	S\\\\244S	\\S25\\SS4U4SjjjrSU4S
jjrS\
S\\/S4SS4SjrSSjrS\4SjrS\
S\/S4S\\/S4SS4SjrS\SS4SjrS\SS4SjrSS\S\\SS4SjjrSrU=r$)�SimpleAsyncHTTPClient�Oa7Non-blocking HTTP client with no external dependencies.26 27This class implements an HTTP 1.1 client on top of Tornado's IOStreams.28Some features found in the curl-based AsyncHTTPClient are not yet29supported.  In particular, proxies are not supported, connections30are not reused, and callers cannot select the network interface to be31used.32 33This implementation supports the following arguments, which can be passed34to ``configure()`` to control the global singleton, or to the constructor35when ``force_instance=True``.36 37``max_clients`` is the number of concurrent requests that can be38in progress; when this limit is reached additional requests will be39queued. Note that time spent waiting in this queue still counts40against the ``request_timeout``.41 42``defaults`` is a dict of parameters that will be used as defaults on all43`.HTTPRequest` objects submitted to this client.44 45``hostname_mapping`` is a dictionary mapping hostnames to IP addresses.46It can be used to make local DNS changes when modifying system-wide47settings like ``/etc/hosts`` is not possible or desirable (e.g. in48unittests). ``resolver`` is similar, but using the `.Resolver` interface49instead of a simple mapping.50 51``max_buffer_size`` (default 100MB) is the number of bytes52that can be read into memory at once. ``max_body_size``53(defaults to ``max_buffer_size``) is the largest response body54that the client will accept.  Without a55``streaming_callback``, the smaller of these two limits56applies; with a ``streaming_callback`` only ``max_body_size``57does.58 59.. versionchanged:: 4.260    Added the ``max_body_size`` argument.61N�max_clients�hostname_mapping�max_buffer_size�resolver�defaults�max_header_size�
max_body_sizer'c�^>�[TU]US9 Xl[R"5Ul0Ul0UlX0lX`l	Xpl62U(aX@lSUlO[5UlSUlUb[URUS9Ul[URS9Ulg)N)rUFT)rT�mapping)rT)r-�63initializerQ�collections�deque�queue�active�waitingrSrVrWrT�own_resolverrrr�64tcp_client)	r0rQrRrSrTrUrVrWr1s	        �r2rZ� SimpleAsyncHTTPClient.initializevs����	���H��-�&������	
�65�
�	
��
�	
�� /��.��*���$�M� %�D��$�J�D�M� $�D���'�,����0@��D�M�$�T�]�]�;��r5c�>�[TU]5 UR(aURR5 URR5 g�N)r-�closer`rTra)r0r1s �r2re�SimpleAsyncHTTPClient.close�s5���
��
������M�M���!������r5�request�callbackc��[5nURRX1U45 URceURceSn[UR5UR:�a�[URUR5=(d UR=(d URnU(aWURRURR5U-[R"URUS55nXU4URU'UR!5 UR(aB["R$"S[UR5[UR54-5 gg)Nzin request queuezImax_clients limit reached, request queued. %d active, %d queued requests.)�objectr]�append�connect_timeout�request_timeout�lenr^rQ�min�io_loop�add_timeout�time�	functools�partial�_on_timeoutr_�_process_queuer�debug)r0rgrh�key�timeout_handle�timeouts      r2�66fetch_impl� SimpleAsyncHTTPClient.fetch_impl�s=���h���67�68���3��2�3��&�&�2�2�2��&�&�2�2�2����t�{�{��t�/�/�/��G�+�+�W�-D�-D�E�+��*�*�+��*�*�
�69�!%���!9�!9��L�L�%�%�'�'�1��%�%�d�&6�&6��=O�P�"��%��?����S�������:�:��M�M�1�47����4D�c�$�*�*�o�3V�W�
�r5c���UR(a�[UR5UR:a�URR	5upnXR70;aMbUR
U5 X#4URU'[R"URU5nURX$U5 UR(a&[UR5UR:aM�ggggrd)r]rnr^rQ�popleftr_�_remove_timeoutrsrt�_release_fetch�_handle_request)r0rxrgrh�release_callbacks     r2rv�$SimpleAsyncHTTPClient._process_queue�s����j�j�S����-��0@�0@�@�%)�Z�Z�%7�%7�%9�"�C�(��,�,�&��� � ��%� '�2�D�K�K���(�0�0��1D�1D�c�J��� � ��H�E��j�j�S����-��0@�0@�@�j�@�jr5c��[$rd)�_HTTPConnectionr8s r2�_connection_class�'SimpleAsyncHTTPClient._connection_class�s���r5r��final_callbackc71��UR5"UUUUURURURUR5 grd)r�rSrarVrW)r0rgr�r�s    r2r��%SimpleAsyncHTTPClient._handle_request�sC��	
��� ������ � ��O�O�� � ����		72r5rxc�>�URU	UR5 grd)r^rv)r0rxs  r2r��$SimpleAsyncHTTPClient._release_fetch�s���K�K������r5c��XR;a>URUup#nUbURRU5 URU	ggrd)r_rp�remove_timeout)r0rxrgrhrys     r2r�%SimpleAsyncHTTPClient._remove_timeout�sH���,�,��04���S�0A�-�G�~��)����+�+�N�;����S�!�	r5�infoc�B�URUup4nURRXU45 U(aSU3OSn[US[	U5UR73R
5UR-74S9nUR75RXG5 URU	g)z�Timeout callback of request.76 77Construct a timeout HTTPResponse when a timeout occurs.78 79:arg object key: A simple object to mark the request.80:info string key: More detailed timeout information.81�Timeout r7r*)�error�request_timeN)	r_r]�removerr$rprr�82start_time�add_callback)r0rxr�rgrhry�
error_message�timeout_responses        r2ru�!SimpleAsyncHTTPClient._on_timeout�s���-1�L�L��,=�)��>��83�84���3��2�3�-1�(�4�&�)�y�
�'���"�=�1����*�*�,�w�/A�/A�A�	85��	
���!�!�(�=��L�L��r5)86r^rWrSrQrVr`r]rTrar_)�87Ni@NNNN�r'Nrd)r=r>r?r@rA�intrrrBrrrZrerrrr{rv�typer�r�rjr�rrurCrDrEs@r2rOrOOsi���$�P�59�(�'+�-1�)-�'+�$<��$<�#�4��S��>�2�$<��	$<�88�8�$�$<��4��S��>�*�
$<�"�#��$<� ��}�$<�89�$<�$<�L ��"��.6��~�t�7K�.L��	
��6F��4��90��91�#�2�t�8�,�92�!�,���!5�6�	93�9495�96�"�&��T��"�6�"�d�"��v��X�c�]��d��r5rOc���\rSrSr1SkrS\\S\S\/S4S\\	/S4S\97S	\S98\99S\100SS4S
jrS*Sjr
S\S\S\\\4\R&44SjrS+S\\SS4SjjrS*SjrS\S\4SjrS\SS4SjrS*SjrS\	SS4SjrSSS\\S\\S\4Sjr S*S jr!S!\\"RF\"RH4S"\"RJSS4S#jr&S\4S$jr'S*S%jr(S*S&jr)S'\*SS4S(jr+S)r,g),r���>�GET�PUT�HEAD�POST�PATCH�DELETE�OPTIONS�clientrgr�Nr�rSrarVrWr'c	���[R"5UlURR5Ul[R"5UlXlX lX0lX@l	XPl101X`lXplX�l
SUlSUl/UlSUlSUlSUl[R"5R)[*R,"UR/55S5 g)Nc�"�UR5$rd��result)�fs r2�<lambda>�*_HTTPConnection.__init__.<locals>.<lambda>s102��q�x�x�zr5)r�currentrprrr��start_wall_timer�rgr�r�rSrarVrW�code�headers�chunks�
_decompressor�_timeout�	_sockaddr�103add_futurer�convert_yielded�run)	r0r�rgr�r�rSrarVrWs	         r2r.�_HTTPConnection.__init__�s����~�~�'����,�,�+�+�-���#�y�y�{������� 0��,��.��$��.��*����	�������!�����
��������#�#�������104�+�-A�	105r5c	���# �[RR[URR10655UlURRS;a"[SURR107-5eURRnSU;aURS5up#n[R"U5upEUcURRS:XaSOSn[R"SU5(aUSS	nX@lURR S108La["R$nO["R&nUR)URR5nSnURR*(a^[-URR*5(aURR*nO#[SURR*<35eURR.(aPURR0(a5[3URR.URR05n	OfURR.(aURR.n	O4URR0(aURR0n	OSn	U	(aMUR4R7UR8U	-[:R<"UR>S
55Ul URBREUUUUURFUS9IShv�Nn109URHcU110RK5 gX�l&URLROURP5 URS5 URHcgURR0(aaUR4R7UR8URR0-[:R<"UR>S55Ul URRTURV;a=URRX(d"[[SURRT-5eSH-n[]URUS5(dM![_SU-5e SURR`;aSURR`S'SURR`;a�SURR;a@URRRS5S	URR`S'O-URRURR`S'Sup�URRbb,URRbURRdp�OLURRfb5URRfnURRh=(d Sn
Ub�U
ceURRjS;a [SURRj5eS[[lRn"[Rp"X�555-URR`S'URRr(a.URRrURR`S'OFURR`RuS5c S[v3URR`S'URRX(d�URRTS;nURRxSL=(d URRzSLnU(aU(aU(a8U(d1[SU(aS OS<S!URRT<S"35eURR|(aS#URR`S$'URRxb?[[�URRx55URR`S%'URRTS&:Xa3S'URR`;aS(URR`S''URR�(aS)URR`S*'URR�=(d S+URR�(aS,URR�-OS-nUR�U1115UlE[R�"URRTUS5nUR�R�UURR`5 URR|(a$UR�R�U5IShv�N gUR�S-5IShv�N gGN�N"N112![�a+ UR�"[�R�"56(degf=f7f).N)�http�httpszUnsupported url scheme: %s�@r�i��Pz^\[.*\]$������Fz=Unrecognized IPv4 or IPv6 address for network_interface, got rzwhile connecting)�af�ssl_optionsrS�	source_ipzduring requestzunknown method %s)�113proxy_host�114proxy_port�proxy_username�proxy_password�proxy_auth_modez%s not supported�115Connectionre�Host)NN�)N�basiczunsupported auth_mode %szBasic �
Authorizationz116User-AgentzTornado/)r�r�r�z117Body must znot zbe None for method z+ (unless allow_nonstandard_methods is true)z100-continue�Expect�Content-Lengthr��Content-Typez!application/x-www-form-urlencoded�gzipzAccept-Encoding�/�?T)N�urllib�parse�urlsplitrrg�url�parsed�scheme�118ValueError�netloc�119rpartitionr�split_host_and_port�re�match�parsed_hostname�120allow_ipv6�socket�AF_INET�	AF_UNSPEC�_get_ssl_options�network_interfacerrlrmrorprqr�rsrtrur�ra�connectrSr�re�stream�set_close_callback�on_connection_closer�method�_SUPPORTED_METHODS�allow_nonstandard_methods�KeyError�getattr�NotImplementedErrorr��username�password�
auth_username�
auth_password�	auth_mode�base64�	b64encode�encode_username_password�121user_agent�getr�body�
body_producer�expect_100_continuerBrn�decompress_response�path�query�_create_connection�122connection�RequestStartLine�
write_headers�
read_response�_write_body�	Exception�_handle_exception�sys�exc_info)r0r��userpass�_�host�portr�r�r�rzr�rxr�r��
body_expected�body_present�req_path�123start_lines                  r2r��_HTTPConnection.run s����^	� �,�,�/�/�����9I�9I�0J�K�D�K��{�{�!�!�):�:� �!=����@P�@P�!P�Q�Q��[�[�'�'�F��f�}�&,�&7�&7��&<�#��V�!�5�5�f�=�J�D��|�"�k�k�0�0�G�;�s����x�x��T�*�*��A�b�z��#'� ��|�|�&�&�%�/��^�^���%�%���/�/����0B�0B�C�K��I��|�|�-�-��t�|�|�=�=�>�>� $��� >� >�I�$��<�<�9�9�<���124�|�|�+�+����0L�0L���L�L�0�0�$�,�,�2N�2N������-�-��,�,�6�6�����-�-��,�,�6�6����� $��� 8� 8��O�O�g�-��%�%�d�&6�&6�8J�K�!��
� �?�?�2�2����'� $� 4� 4�#�
3���F��"�"�*������ �K��K�K�*�*�4�+C�+C�D�� � �"��"�"�*���|�|�+�+� $��� 8� 8��O�O�d�l�l�&B�&B�B��%�%�d�&6�&6�8H�I�!��
�125���#�#�4�+B�+B�B����>�>��2�T�\�\�5H�5H�H�I�I����4�<�<��d�3�3�-�.@�3�.F�G�G���4�<�<�#7�#7�7�5<����$�$�\�2��T�\�\�1�1�1��$�+�+�,�,�,�37�;�;�3E�3E�3P�3P�QT�3U��4�D�L�L�(�(��0�48�;�;�3E�3E�D�L�L�(�(��0�!+��H��{�{�#�#�/�%)�[�[�%9�%9�4�;�;�;O�;O�(����+�+�7��<�<�5�5���<�<�5�5�;����#��+�+�+��<�<�)�)��@�$�%?����AW�AW�X�X�8@�8��$�$� �9�9�(�M��D�9����$�$�_�5�126�|�|�&�&�59�\�\�5L�5L����$�$�\�2����%�%�)�)�,�7�?�7?��y�5I����$�$�\�2��<�<�9�9�!%��� 3� 3�7O� O�
��L�L�%�%�T�1�>��|�|�1�1��=��"�,� ��$�&3�6��:�D�L�L�<O�<O�Q���127�|�|�/�/�1?����$�$�X�.��|�|� � �,�:=�S����AR�AR�=S�9T����$�$�%5�6����#�#�v�-�"�$�,�,�*>�*>�>�8����$�$�^�4��|�|�/�/�:@����$�$�%6�7����(�(�/�C�-1�[�[�->�->��t�{�{�(�(�(�B��H�#�5�5�f�=�D�O�!�2�2�4�<�<�3F�3F��RT�U�J��O�O�)�)�*�d�l�l�6J�6J�K��|�|�/�/��o�o�3�3�D�9�9�9��&�&�t�,�,�,�U�P:�,���	��)�)�3�<�<�>�:��;�	�s��i�L7h'�;h �<!h'�i�Ah'�&i�'C<h'�'Uh'�h#�h'�i�h'�h%�h'�i� h'�#h'�%h'�'2i�i�i�ir�c�>�US:XGa�URRbURR$URR(aKURRc4URRcURR128c[$[R"[RRURRS9nURR(dSUl[RUl
URRb:URURRURR1295 [[S5(a#U=R [R"-slU$g)Nr�)�cafileF�OP_NO_COMPRESSION)rgr��
validate_cert�ca_certs�client_cert�130client_keyr�ssl�create_default_context�Purpose�SERVER_AUTH�check_hostname�	CERT_NONE�verify_mode�load_cert_chain�hasattr�optionsr)r0r��ssl_ctxs   r2r�� _HTTPConnection._get_ssl_options�s ���W���|�|�'�'�3��|�|�/�/�/����*�*��L�L�)�)�1��L�L�,�,�4��L�L�+�+�3�+�+��0�0����'�'����0E�0E��G��<�<�-�-�).��&�&)�m�m��#��|�|�'�'�3��'�'��L�L�,�,�d�l�l�.E�.E���s�/�0�0����3�#8�#8�8���N�r5r�c��SUlU(aSU3OSnURb!UR[[U5S5 gg)z�Timeout callback of _HTTPConnection instance.131 132Raise a `HTTPTimeoutError` when a timeout occurs.133 134:info string key: More detailed timeout information.135Nr�r7)r�r�r136r$)r0r�r�s   r2ru�_HTTPConnection._on_timeout�sG����
�-1�(�4�&�)�y�
����*��"�"� �"2�=�"A�4�
�+r5c�x�URb-URRUR5 SUlggrd)r�rpr�r8s r2r�_HTTPConnection._remove_timeout�s.���=�=�$��L�L�'�'��
�
�6� �D�M�%r5r�c���URS5 [US[SURUR[URR5S9UR5nU$)NT)�
no_keep_aliverVrW�137decompress)	�set_nodelayr
rrVrW�boolrgrr�)r0r�rs   r2r�"_HTTPConnection._create_connection�s`�����4� �$���%�"� $� 4� 4�"�0�0����� @� @�A�	
�
�N�N�138139�140��r5�141start_readc��D# �URRb0URRURR5 OSURRb<URR	URR5nUb142UIShv�N URR5 U(a%URR
U5IShv�N ggNKN![a+ UR"[R"56(degf=f7frd)rgr�r�writer��finishrrr143rr)r0r3�futs   r2r�_HTTPConnection._write_bodys�����<�<���(��O�O�!�!�$�,�,�"3�"3�4�
�\�\�
'�
'�
3��,�,�,�,�T�_�_�-B�-B�C�C����	�	������ ��
��o�o�3�3�D�9�9�9���:��$�
��-�-�s�|�|�~�>��?�
�sH�BD �C$�%D �?C(�C&�C(�"D �&C(�(2D�D �D�D c�T�URbURnSUlU"5 ggrd)r�)r0r�s  r2�_release�_HTTPConnection._releases-��� � �,�#�4�4��$(�D�!���-r5�responsec��UR5 URb/URnSUlURRX!5 ggrd)r:r�rpr�)r0r<r�s   r2�
_run_callback�_HTTPConnection._run_callbacksA���
�
�����*�!�0�0�N�"&�D���L�L�%�%�n�?�+r5�typzOptional[Type[BaseException]]�value�tbc144���URb�UR5 [U[5(a%URc[S5nOURnUR
[URSUURR5UR-145URS95 [US5(aURR5 g[U[5$)NrLr*)r�r�r�r�T)r�r�146isinstancer�147real_errorrGr>rrgrprrr�r�r%r�re)r0r@rArBs    r2r148�!_HTTPConnection._handle_exceptions������*�� � �"��%�!2�3�3��#�#�+�1�/�B�E�!�,�,�E������L�L���!%���!2�!2�!4�t���!F�#�3�3��
��t�X�&�&����!�!�#���e�%6�7�7r5c��URb?SnURR(aURRe[U5eg![a% UR"[149R"56 gf=f)NzConnection closed)r�r�r�rGr150rr)r0r&s  r2r��#_HTTPConnection.on_connection_closeBsj�����*�)�G��{�{� � ��k�k�'�'�'�
8�+�G�4�4�+��)�
8��&�&�����7�
8�s�A�,A=�<A=�151first_liner�c��# �[U[R5(deURR(a*UR152S:XaUR
S5IShv�N gUR153UlURUlX lUR5(agURRb~URRSU-5 URR5H&up4URRUSUS35 M( URRS5 ggN�7f)N�dFz154%s %s %s
155z: z
156)rDr�ResponseStartLinergr�r�r�reasonr��_should_follow_redirect�header_callback�get_all)r0rIr��k�vs     r2�headers_received� _HTTPConnection.headers_receivedLs����157�*�h�&@�&@�A�A�A�A��<�<�+�+�158���3�0F��"�"�5�)�)�)���O�O��	� �'�'������'�'�)�)���<�<�'�'�3��L�L�(�(��*�)D�E����,�,�.������,�,��s�"�Q�C�t�_�=�/��L�L�(�(��0�4�
*�s�A!D?�#D=�$CD?c�<�URR(a�URRceURS;=(aR URRS:�=(a2 URSL=(a URRS5SL$g)N)�-�.�/i3i4r�LocationF)rg�follow_redirects�
max_redirectsr�r�r�r8s r2rN�'_HTTPConnection._should_follow_redirectcs����<�<�(�(��<�<�-�-�9�9�9��	�	�6�6�=��L�L�.�.��2�=��L�L��,�=��L�L�$�$�Z�0��<�	
�r5c�R^�URceSRUR5nUR5 [	UR159SUR1605nUR
5(Ga�[UR161[5(deURce[R"UR162R1635n[RRUR164RURS5UlUR165RceUR166RS-167UlURS	URS:XaUR168R S:wd*URS;aIUR169R S	:Xa/S170UlSUlSHnUR171RU	M X#lUR(mSUlUR+5 UR,ceUR,R/USS
9nUR1U4Sj5 UR35 gUR172R4(a[75nO[7U5n[9UUR[	USS5URUR:R=5UR>-173UR@UUR174RS9nURCU5 UR35 g![$a GMjf=f)Nr5�original_requestrYr�r�rXr�)rVrWr�r�)r�r�zContent-EncodingzTransfer-EncodingF)�raise_errorc�0>�T"UR55$rdr�)r�r�s �r2r��(_HTTPConnection.finish.<locals>.<lambda>�s���N�1�8�8�:�,Fr5rM)rMr�r�r��buffer�
effective_url)"r��joinr�rr�rgrNrDr175r��copyr�r��urljoinr�r[r�r�r�r^r�r:r��fetch�add_done_callback�_on_end_request�streaming_callbackrrrprrr�r�r>)	r0�datar^�new_request�hr7rbr<r�s	        @r2r6�_HTTPConnection.finishns�����y�y�$�$�$��x�x����$������"�4�<�<�1C�T�\�\�R���'�'�)�)��d�l�l�M�:�:�:�:��<�<�+�+�+��)�)�D�L�L�$8�$8�9�K�$�l�l�2�2���� � �$�,�,�z�":��K�O��<�<�-�-�9�9�9�(,���(B�(B�Q�(F�K�%��#�#�F�+��	�	�S� �T�\�\�%8�%8�F�%B��	�	�Z�'�D�L�L�,?�,?�6�,I�%*��"�#'�� ��A�� �L�L�0�0��3��,<�(�!�0�0�N�"&�D���M�M�O��;�;�*�*�*��+�+�#�#�K�U�#�C�C��!�!�"F�G�� � �"���<�<�*�*��Y�F��T�]�F����I�I��4��4�0��L�L����*�*�,�t���>��+�+���,�,�*�*�	176��	
���8�$������5$����s�?L�177L&�%L&c�8�URR5 grd)r�rer8s r2ri�_HTTPConnection._on_end_request�s�������r5�chunkc���UR5(agURRbURRU5 gURR	U5 grd)rNrgrjr�rk)r0rqs  r2�
data_received�_HTTPConnection.data_received�sH���'�'�)�)���<�<�*�*�6��L�L�+�+�E�2��K�K���u�%r5)r�r�r�r�r�r�rr�r�rprWrSrVr�r�rMr�rgr�r�r�rar�rd)-r=r>r?r@r�rrOrrrr�rr.r�rBrrrr�178SSLContextr�rurrr
rr1rr:r>�
BaseExceptionrr179r�rrLr�HTTPHeadersrSrNr6ri�bytesrsrCr;r5r2r�r��s���U��180��.�/�181��182�#�2�t�8�,�	183�184!�,���!5�6�185��
186��187��188��189�190�191�B_�B���	�t�T�#�s�(�^�S�^�^�3�	4��>���
����!�192
��
�o�
�
�D�
�T�
��@�l�@�t�@�"8�
,�"8��
�&�"8�
�]�#�	"8�193194�"8�H8�1��(�4�4�h�6O�6O�O�P�1��%�%�1�195�	1�.	��	�?�B�&�5�&�T�&r5r��__main__)?�tornado.escaper�tornadorr�tornado.httpclientrrrr	r196rr�tornado.http1connectionr
r�tornado.ioloopr�tornado.iostreamrr�tornado.netutilrrrr�tornado.logr�tornado.tcpclientrr�r[rersr�r�rrrr�ior�urllib.parser��typingrrrrrr�typesr�
TYPE_CHECKINGr r!r"r$rGrO�HTTPMessageDelegater�r=�	configurer;r5r2�<module>r�s���#� ����N�!�8��� �'�
����	�
�197�198����=�=��
�	���)�)�
)�y�
)� /�I�/�&j�O�j�Z}&�h�2�2�}&�@�z�����3�4��F�r5
codekingpro/portable-devtools · Team Ai