Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��j�0�	���SSKrSSKJr SSKJrJrJrJr SSKJ	r	 SSK3JrJrJ
r
JrJr SSKJrJrJrJrJr SSKJrJr SS	KJr SS4KJrJrJr "SS\	\\\\45rg)
�N)�suppress)�Any�Optional�Tuple�Union�)�BaseProtocol)�ClientConnectionError�
ClientOSError�ClientPayloadError�ServerDisconnectedError�SocketTimeoutError)�
_EXC_SENTINEL�EMPTY_BODY_STATUS_CODES�BaseTimerContext�
set_exception�5set_result)�HttpResponseParser�RawResponseMessage)�HttpProcessingError)�
EMPTY_PAYLOAD�	DataQueue�StreamReaderc�H^�\rSrSrSrS\RSS4Sjr\S\	S\RS44Sj5r\S\4Sj5r
\S\4S	j5rS3S6jrS3SjrS3SjrS\4S
jrS\\SS4U4SjjrS3SjrS3U4SjjrS3U4Sjjr\4S\S\SS4U4SjjjrS\S\SS4SjrSSSSSSSSSSS.7S\\S \S!\S"\S#\\S$\S%\S&\S'\S(\SS4S)jjr S3S*jr!S3S+jr"S3S,jr#\S\\4S-j5r$\$RJS#\\SS4S.j5r$S3S/jr&S0\'SS4S1jr(S2r)U=r*$)4�ResponseHandler�z8Helper class to adapt between Protocol and StreamReader.�loop�returnNc��[R"XS9 [R"X5 SUlSUlSUlSUlSUlSUlSUl	SUl8SUlSUlSUl
SUlSUlg)N)rF��)r	�__init__r�
_should_close�_payload�
_skip_payload�_payload_parser�_timer�_tail�	_upgraded�_parser�
_read_timeout�_read_timeout_handle�_timeout_ceil_threshold�_closed�_connection_lost_called)�selfrs  �ZD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/client_proto.pyr"�ResponseHandler.__init__s������d�.����4�&�"���04��
�"���#��������9����59���.2���CG��!�89��$�:>���',��$r c��URc0UR(dURR5UlUR$)a�Future that is set when the connection is closed.10 11This property returns a Future that will be completed when the connection12is closed. The Future is created lazily on first access to avoid creating13futures that will never be awaited.14 15Returns:16    - A Future[None] if the connection is still open or was closed after17      this property was accessed18    - None if connection_lost() was already called before this property19      was ever accessed (indicating no one is waiting for the closure)20)r.r/�_loop�
create_future�r0s r1�closed�ResponseHandler.closed4s4���<�<���(D�(D��:�:�3�3�5�D�L��|�|�r c��UR$�N)r)r6s r1�upgraded�ResponseHandler.upgradedFs���~�~�r c�h�[UR=(d� URSL=(a URR5(+=(d\ UR=(dI UR21SL=(d4 URSL=(d UR=(d UR5$r:)	�boolr#r$�is_eofr)�22_exceptionr&�_bufferr(r6s r1�should_close�ResponseHandler.should_closeJs�������
��
�
�T�)�H�$�-�-�2F�2F�2H�.H�
��~�~�
����d�*�
��#�#�4�/�	
�23�|�|�
��z�z�24�	25r c��SUlg�NT)r#r6s r1�force_close�ResponseHandler.force_closeVs26��!��r c��SUlURnUb/UR5 SUlSUlUR	5 ggr:)r@�	transport�closer$�
_drop_timeout�r0rIs  r1rJ�ResponseHandler.closeY�A������N�N�	�� ��O�O��!�D�N� �D�M���� �	!r c��SUlURnUb/UR5 SUlSUlUR	5 ggr:)r@rI�abortr$rKrLs  r1rP�ResponseHandler.abortbrNr c�j�URSL=(a URR5(+$r:)rI�27is_closingr6s r1�is_connected�ResponseHandler.is_connectedks&���~�~�T�)�M�$�.�.�2K�2K�2M�.M�Mr �excc��>�SUlUR5 UnUnUSLnURbGU(a[URS5 O)Uce[	UR[SU<35U5 URb2[[5 URR5 SSS5 SnURbURR5nUR5(dc[U[5(a[!UR"6nU(a[%U5nU(a[&OUnUceUceUR	X85 SUlSUl28SUlSUlSUl[,T	U]]U5 g!,(df   N�=f![aNnURb6SU<3nU(d	U<SU<3n[	UR[U5U5 SnAGNSnAff=f)NTzConnection lost: z#Response payload is not completed: z. F)r/rKr.rrr29r&r�	Exception�feed_eofr*r$rr?�30isinstance�OSErrorr�argsr
rr#�_reading_paused�super�connection_lost)31r0rV�original_connection_error�reraised_exc�connection_closed_cleanly�uncompleted�underlying_exc�client_payload_exc_msg�underlying_non_eof_exc�	__class__s32         �r1r_�ResponseHandler.connection_lostns����'+��$�����$'�!�0��$=��$E�!��<�<�#�)��4�<�<��.�0�<�<�<���L�L�)�+�,E�+I�J��.�����+��)�$��$�$�-�-�/�%����<�<�#�
�"�l�l�3�3�5��"�{�{�}�}��3�W�=�=�,�.G�.L�.L�M��(�6�{�C��33-��.�
#�34*�5�5�5��+�+�+����|�D�!��������
�#���$���
����-�[%�$���
��=�=�,�=�n�=P�Q�+�5�5�9��8�<�>�/�"��
�
�*�+A�B�&����
�s%�F	�F�	35F�36G2�$AG-�-G2c�$�UR5 gr:)rKr6s r1�eof_received�ResponseHandler.eof_received�s�����r c�B>�[TU]5 UR5 gr:)r^�
pause_readingrK�r0rgs �r1rm�ResponseHandler.pause_reading�s���
�������r c�B>�[TU]5 UR5 gr:)r^�resume_reading�_reschedule_timeoutrns �r1rq�ResponseHandler.resume_reading�s���
��� �� � �"r �	exc_causec�R>�SUlUR5 [TU]
X5 grE)r#rKr^r)r0rVrtrgs   �r1r�ResponseHandler.set_exception�s&���37"�������
���c�-r �parser�payloadc��X lXlUR5 UR(a%URSso0lUR	U5 gg)Nr )r$r&rKr(�
data_received)r0rwrx�datas    r1�38set_parser�ResponseHandler.set_parser�sE�� �
�%�������:�:�#�z�z�3��D�*����t�$�r FTir!i��)39�timer�skip_payload�read_until_eof�auto_decompress�read_timeout�read_bufsize�timeout_ceil_threshold�
max_line_size�max_field_size�max_headersrr�r�r�r�r�r�r�r�r�c40���X lXPlXpl[UURUU[41U(+UUUU	U42S9UlUR(a%URSso�lURU5 gg)N)r�payload_exception�response_with_bodyr�r�r�r�r�r )	r%r+r-rr4rr*r(rz)r0rr�r�r�r�r�r�r�r�r�r{s            r1�set_response_params�#ResponseHandler.set_response_params�sv��*��)��'=�$�)���J�J���0�#/�/�)�+�'�)�#�43����:�:�#�z�z�3��D�*����t�$�r c�b�URb"URR5 SUlggr:)r,�cancelr6s r1rK�ResponseHandler._drop_timeouts-���$�$�0��%�%�,�,�.�(,�D�%�1r c���URnURbURR5 U(a+URR	XR445UlgSUlgr:)r+r,r�r4�45call_later�_on_read_timeout)r0�timeouts  r1rr�#ResponseHandler._reschedule_timeoutsX���$�$���$�$�0��%�%�,�,�.��(,�46�47�(=�(=��.�.�)�D�%�)-�D�%r c�$�UR5 gr:)rrr6s r1�
start_timeout�ResponseHandler.start_timeouts��� � �"r c��UR$r:�r+r6s r1r��ResponseHandler.read_timeouts���!�!�!r c��Xlgr:r�)r0r�s  r1r�r�s��)�r c��[S5nURU5 URb[URU5 gg)Nz#Timeout on reading data from socket)rrr$)r0rVs  r1r�� ResponseHandler._on_read_timeouts8�� �!F�G�����3���=�=�$��$�-�-��-�%r r{c�r�UR5 U(dgURbKURRU5up#U(a&SUlSUlU(aUR	U5 gUR48(d
URcU=RU-
slgURRU5upEnXPlSnUHuup�U	R"(aSUlX�lUR&(dU	R[(;aURU	[*4S5 MbURX�4S5 Mw Ub5U[*LaUR-UR.5 OUR/5 U(aU(aUR	U5 ggg![a�nURbURR5 [U[5(a*[URURURS9nO49[5nUR!Xv5 SnAgSnAff=f)N)�code�message�headersTr)rrr&�	feed_datar$rzr)r*r(�
BaseExceptionrIrJrZrr�r�r�rrBr#r%rr�on_eofrK)50r0r{�eof�tail�messagesr;rdrVrxr�s51          r1rz�ResponseHandler.data_received%s���� � �"������+��,�,�6�6�t�<�I�C�� $��
�'+��$���&�&�t�,���>�>�T�\�\�1��J�J�$��J��	�'+�|�|�'=�'=�d�'C�$�H��&"��*.�� (��G��#�#�%)��"�#�M��!�!�W�\�\�5L�%L������7��;�����1�1�5�!)���52�m�+����t�1�1�2��"�"�$������t�$��8��U�	��~�~�)����$�$�&��.�*=�>�>�)�'�,�,�*�2�2�*�2�2���*�+�����s�3���!	�s�&F!�!53H6�+BH1�1H6)r.r/r@r*r$r&r+r,r]r#r%r(r-r'r)rI)rN)+�__name__�54__module__�__qualname__�__firstlineno__�__doc__�asyncio�AbstractEventLoopr"�propertyr�Futurer7r>r;rBrFrJrPrTrr�r_rjrmrqrrrr|r�float�intr�rKrrr�r��setterr��bytesrz�__static_attributes__�
__classcell__)rgs@r1rrs)���B�-�W�6�6�-�4�-�0���d�G�N�N�4�$8�8�9����"��$�����	55�d�	56��	57�"�!�!�N�d�N�I.�8�M�#:�I.�t�I.�V��#�$1�.�
�.�!�.�58�	.�.�
%��
%�s�
%�t�
%�$-1�"�$� $�(,�!�()�!�"��$%��(�)�$%��	$%�59�$%��
$%��u�o�$%��$%�!&�$%��$%��$%��$%�60�$%�L-�61 62-�#��"�h�u�o�"��"����*��%��*�T�*��*�.�D%�%�D%�D�D%�D%r r) r��63contextlibr�typingrrrr�
base_protocolr	�client_exceptionsr64rrr
r�helpersrrrrr�httprr�http_exceptionsr�streamsrrrr�r r1�<module>r�sV����.�.�'�����9�0�;�;�P%�l�I�e�4F��4T�.U�$V�P%r 
codekingpro/portable-devtools · Team Ai