�
Hq�Qc@s�dZd
dl
Z
d
dlZd
dlZeje�
Zdef
d��YZde
j	f
d��YZ
def
d��YZd	ef
d
��YZ
de
f
d��YZd
e
f
d��YZdef
d��YZdS(s�Reader objects to abstract out different body response types.

This module is package-private. It is not expected that these will
have any clients outside of httpplus.
i����NtReadNotReadyc
BseZ
dZRS(
s>Raised when read() is attempted but not enough data is loaded.(t__name__t
__module__t__doc__(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR*s
tHTTPRemoteClosedErrorc
BseZ
dZRS(
s@The server closed the remote socket in the middle of a response.(R
RR(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR.s
tAbstractReadercBsbeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd
d�
Z
d�Zd	�ZRS(s�Abstract base class for response readers.

    Subclasses must implement _load, and should implement _close if
    it's not an error for the server to close their socket without
    some termination condition being detected during _load.
    c

Cst|_
g|_d
|_dS(Ni(tFalset	_finishedt_done_chunkstavailable_data(
tself((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyt__init__9s
	
	
cCs)|jj
|
�

|jt|
�
7_dS(
N(RtappendR	tlen(R
tdata((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pytaddchunk>s

cCs,|jj
d
|
�
|jt|
�
7_dS(Ni(RtinsertR	R
(R
R((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyt	pushchunkBs

c
Cs+|jj
d
�
}
|jt|
�
8_|
S(Ni(RtpopR	R
(R
t
b((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pytpopchunkFs

c


Cs|jS(
N(
R(
R
((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pytdoneLs
cCs�|j|
kr%|j
r%t��
ng}|
}x||jr�|j�}t|�
|kr|| }|j||�

|}n|j|�

|t|�
8}|d
kr4Pq4q4Wdj|�
}|S(Nit(	R	RRRRR
RRtjoin(R
tamttblockstneedRtnbtresult((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pytreadOs 










	





cCs�|d
krg}nx�|j
r�|j�}|j|
�
t|
�
}|r�|t|�
krr|j||�

n|j|| �

Pq|j|�

qW|S(sd
return available data chunks up to the first one in which delimstr
        occurs. No data will be returned after delimstr -- the chunk in which
        it occurs will be split and the remainder pushed back onto the available
        data queue. If blocks is supplied chunks will be added to blocks, otherwise
        a new list will be allocated.
        N(tNoneRRtfindR
RR(R
tdelimstrRRt
i((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pytreadtocs
	






c
Cs
t�
d
S(s5
Subclasses must implement this.

        As data is available to be read out of this object, it should
        be placed into the _done_chunks list. Subclasses should not
        rely on data remaining in _done_chunks forever, as it may be
        reaped if the client is parsing data as it comes in.
        N(
tNotImplementedError(R
R((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyt_loadzsc

Cs|jst
d
�
�
ndS(s�
Default implementation of close.

        The default implementation assumes that the reader will mark
        the response as finished on the _finished attribute once the
        entire response body has been read. In the event that this is
        not true, the subclass should override the implementation of
        close (for example, close-is-end responses have to set
        self._finished in the close handler.)
        s5server appears to have closed the socket mid-responseN(RR(
R
((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyt_close�s
	

N(
R
RRRRRRRRRR"R$R%(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR2s
							
tAbstractSimpleReaderc
BseZ
dZd
�ZRS(s�Abstract base class for simple readers that require no response decoding.

    Examples of such responses are Connection: Close (close-is-end)
    and responses that specify a content length.
    cCs6|
r	ntj
d
|jt|
�
�
|j|
�

dS(Ns%s read an additional %d data(tloggertdebugtnameR
R(R
R((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR$�s


(R
RRR$(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR&�s
tCloseIsEndReaderc
BseZ
dZd
Zd�ZRS(s?Reader for responses that specify Connection: Close for length.sclose-is-endc

Cstj
d
�

t|_dS(Ns&Marking close-is-end reader as closed.(R'tinfotTrueR(
R
((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR%�s


(R
RRR)R%(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR*�s

tContentLengthReaderc
Bs&eZ
dZd
Zd�Zd�ZRS(s:Reader for responses that specify an exact content length.scontent-lengthcCs;tj
|�

|
|_|
d
kr.t|_nd
|_dS(Ni(RRt_amountR,Rt_amount_seen(R
tamount((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR�s



	


cCsTtj
||
�
|jt|
�
7_|j|jkrPt|_tjd
�

ndS(Nscontent-length read complete(	R&R$R/R
R.R,RR'R((R
R((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR$�s




	
(R
RRR)RR$(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR-�s

	t
ChunkedReaderc
Bs eZ
dZd
�Zd�ZRS(s/Reader for chunked transfer encoding responses.cCs,tj
|�

|
|_d
|_d|_dS(NiR(RRt_eolt_leftover_skip_amtt_leftover_data(R
teol((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR�s


	
	
cCsq
tj
d
t|
�
�
d}|jr]tj
d�

|j|
}
|j}d|_d|_nt|
�
}x

||krl
|
j|j|�}|dkr�|
|_||_dSt|
||!dd�

}|t|j�
}||t|j�
t|
�
kr
|
|_||_dS|dkr:
t|_	tj
d�

dS|j
|
|||!�

||t|j�
}qlWdS(	Ns"chunked read an additional %d datais8chunked reader trying to finish block from leftover dataRi����tbaseis/closing chunked reader due to chunk of length 0(R'R(R
R4R3RR2tintR,RR(R
RtpositiontdatalentsplitRtblock_start((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR$�s6

	



	
	





	
	


#
	
	


	




(R
RRRR$(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyR1�s

	(Rthttplibt	itertoolstloggingt	getLoggerR
R't	ExceptionRt
HTTPExceptionRtobjectRR&R*R-R1(((sC/usr/lib64/python2.7/site-packages/mercurial/httpclient/_readers.pyt<module>!s

a