File: //lib/python3.6/site-packages/S3/__pycache__/Custom_httplib27.cpython-36.opt-1.pyc
3
�9pe� � @ s d dl mZmZ d dlZd dlZd dlmZmZmZmZm Z m
Z
m Z m Z m
Z
mZ yd dlmZ W n ek
r� d dlmZ Y nX ddlmZ ddd gZd
d � Zd d
� Zdd� Zddd�ZdZddd�ZG dd� de�Zdd� Z eej _ eej _ eej _!eej _"eej _#e ej _$dS )� )�absolute_import�print_functionN)
� _CS_REQ_SENT�_CS_REQ_STARTED�CONTINUE�UnknownProtocol�CannotSendHeader�
NO_CONTENT� NOT_MODIFIED�EXPECTATION_FAILED� HTTPMessage�
HTTPException)�StringIO� )� encode_to_s3ZPATCHZPOSTZPUTc C s� | j dk rdS | j� \}}}|| _|j� | _|dkr<d| _n*|jd�rNd| _n|dkr^d| _nt|��| jdkr�d| _d| _ d | _
t t � �| _ dS t | j
d�| _ | jdkr�x | j jD ]}td
|d d � q�W d| j _
| j jd
�}|r�|j� dkr�d | _ d| _nd| _ | j� | _
| j jd�}|�rh| j �rhyt|�| _W n tk
�rR d| _Y nX | jdk �rnd| _nd| _|tk�s�|tk�s�d| k�o�dk n �s�| jdk�r�d| _| j
�r�| j �r�| jdk�r�d | _
dS )z� Re-implemented httplib begin function
to not loop over "100 CONTINUE" status replies
but to report it to higher level so it can be processed.
NzHTTP/1.0�
zHTTP/1.� zHTTP/0.9� r r zheader:� )�endztransfer-encoding�chunkedzcontent-length�d �� ZHEAD)�msgZ _read_status�status�strip�reason�version�
startswithr �lengthr Z
will_closer r �fp�
debuglevel�headers�printZ getheader�lowerZ
chunk_leftZ _check_close�int�
ValueErrorr r
�_method)�selfr r r �hdrZtr_encr � r* �&/usr/lib/python3.6/Custom_httplib27.py�httpresponse_patched_begin s\
r, c C s� d }|d kr |j � tkr d}nv|d k r�ytt|��}W n\ ttfk
r� yttj|j� �j �}W n* tt
fk
r� | j dkr�t d� Y nX Y nX |d k r�| j
d|� d S )N�0r z
Cannot stat!!zContent-Length)�upper�_METHODS_EXPECTING_BODY�str�len� TypeError�AttributeError�os�fstat�fileno�st_size�OSErrorr! r# � putheader)r( �body�methodZthelenr* r* r+ �)httpconnection_patched_set_content_lengthg s
r< c C s, t jdd� |D ��}i }d|kr(d|d< d|kr8d|d< d}x0|j� D ]$\}} d |j� krFd
| j� krFd }qFW t|�}| j||f|� d |kr�| j||� x(|j� D ] \}} | jt|�t| �� q�W |s�| j|� nT|s�t d
��| j� | j
� }
|
j � t | _
|
jtk�rt� �n|
jtk�r(| j|� d S )Nc S s g | ] }|j � �qS r* )r$ )�.0�kr* r* r+ �
<listcomp>� s z7httpconnection_patched_send_request.<locals>.<listcomp>�hostr Z skip_hostzaccept-encodingZskip_accept_encodingF�expectz 100-continueTzcontent-lengthz.A body is required when expecting 100-continue)�dict�fromkeysZ iteritemsr$ r Z
putrequest�_set_content_lengthr9 �
endheadersr
Z getresponse�readr �_HTTPConnection__stater r �ExpectationFailedr �send) r( r; Zurlr: r" Z header_namesZskipsZexpect_continuer) �valueZrespr* r* r+ �#httpconnection_patched_send_request s8 rK c C s& | j tkrt| _ nt� �| j|� dS )ao Indicate that the last header line has been sent to the server.
This method sends the request to the server. The optional
message_body argument can be used to pass a message body
associated with the request. The message body will be sent in
the same packet as the message headers if it is string, otherwise it is
sent as a separate packet.
N)rG r r r � _send_output)r( � message_bodyr* r* r+ �!httpconnection_patched_endheaders� s
rN i @ c C sn | j jd� dj| j �}| j dd�= t|�}t|t�rNt|�tk rN||7 }d}| j|� |dk rj| j|� dS )z�Send the currently buffered request and clear the buffer.
Appends an extra \r\n to the buffer.
A message_body may be specified, to be appended to the request.
� s
N)rO rO ) Z_buffer�extend�joinr �
isinstancer0 r1 �mssrI )r( rM r r* r* r+ �"httpconnection_patched_send_output� s
rT c @ s e Zd ZdS )rH N)�__name__�
__module__� __qualname__r* r* r* r+ rH � s rH c C s | j |� d S )N)rI )r( rM r* r* r+ �(httpconnection_patched_wrapper_send_body� s rX )N)N)%Z
__future__r r r4 Zhttplibr r r r r r r
r r r
Z cStringIOr � ImportErrorZ BaseUtilsr r/ r, r< rK rN rS rT rH rX Z HTTPResponseZbeginZHTTPConnectionrE rL rD Z
_send_requestZwrapper_send_bodyr* r* r* r+ �<module> s. 0
N(