Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
Filename :
response.cpython-310.pyc
back
Copy
o <&�aE � @ s� d dl Z d dlmZ d dlmZmZmZ d dlmZ d dlm Z d dl m Z d dl m Z d dlmZ d d lmZ e �e�ZG d d � d e�Zd d � ZdS )� N)�set_socket_timeout)�IncompleteReadError�ReadTimeoutError�ResponseStreamingError)r )� ProtocolError)�parsers)� ScalarTypes)� XMLParseError)�first_non_none_responsec @ sh e Zd ZdZdZdd� Zdd� Zddd �Zd d � Zd d � Z e Z ddd�Z efdd�Z dd� Z dd� ZdS )� StreamingBodyae Wrapper class for an http response body. This provides a few additional conveniences that do not exist in the urllib3 model: * Set the timeout on the socket (i.e read() timeouts) * Auto validation of content length, if the amount of bytes we read does not match the content length, an exception is raised. � c C s || _ || _d| _d S )Nr )� _raw_stream�_content_length� _amount_read)�self� raw_stream�content_length� r �3/usr/lib/python3/dist-packages/botocore/response.py�__init__0 s zStreamingBody.__init__c C s2 z t | j|� W dS ty tjddd� � w )z&Set the timeout seconds on the socket.zbCannot access the socket object of a streaming response. It's possible the interface has changed.T)�exc_infoN)r r �AttributeError�logger�error)r �timeoutr r r r 5 s ��z StreamingBody.set_socket_timeoutNc C s� z| j �|�}W n# ty } zt|j|d��d}~w ty+ } zt|d��d}~ww | jt|�7 _|du s?|sC|dkrC| � � |S )zhRead at most amt bytes from the stream. If the amt argument is omitted, read all data. )� endpoint_urlr N)r r ) r �read�URLLib3ReadTimeoutErrorr �url�URLLib3ProtocolErrorr r �len�_verify_content_length)r �amt�chunk�er r r r L s � ��zStreamingBody.readc C s | � | j�S )zCReturn an iterator to yield 1k chunks from the raw stream. )� iter_chunks�_DEFAULT_CHUNK_SIZE�r r r r �__iter__` s zStreamingBody.__iter__c C s | � | j�}|r |S t� �)z6Return the next 1k chunk from the raw stream. )r r& � StopIteration)r � current_chunkr r r �__next__e s zStreamingBody.__next__Fc c sj � d}| � |�D ] }|| �d�}|dd� D ] }|�|�d V q|d }q|r3|�|�d V dS dS )z�Return an iterator to yield lines from the raw stream. This is achieved by reading chunk of bytes (of size chunk_size) at a time from the raw stream, and then yielding lines from there. � TN���r )r% � splitlines)r � chunk_size�keepends�pendingr# �lines�liner r r � iter_lineso s � �zStreamingBody.iter_linesc c s" � | � |�}|dkr dS |V q)z\Return an iterator to yield chunks of chunk_size bytes from the raw stream. Tr, N)r )r r/ r* r r r r% ~ s � �zStreamingBody.iter_chunksc C s6 | j d ur| jt| j �krt| jt| j �d��d S d S )N)� actual_bytes�expected_bytes)r r �intr r' r r r r! � s ��z$StreamingBody._verify_content_lengthc C s | j �� dS )z*Close the underlying http response stream.N)r �closer' r r r r8 � s zStreamingBody.close)N)r F)�__name__� __module__� __qualname__�__doc__r& r r r r( r+ �nextr4 r% r! r8 r r r r r " s r c C sx | j d }|j|jd�}|d dkr|j|d< n| jr)t|j|d �d��|d< n|j|d< t� |�}||� || j �fS )N�protocol)�headers� status_coder@ i, �bodyr? zcontent-length) �metadatar? r@ �content�has_streaming_outputr �raw�getr � create_parser�parse� output_shape)�operation_model� http_responser> � response_dict�parserr r r � get_response� s � � �rN )�logging�botocore.compatr �botocore.exceptionsr r r �urllib3.exceptionsr r r �botocorer r r �botocore.hooksr � getLoggerr9 r �objectr rN r r r r �<module> s u