��c@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__(((sA/sys/lib/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(((sA/sys/lib/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((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyt__init__9s
	
	
cCs)|jj
|
�
|jt|
�7_dS(
N(RtappendR	tlen(R
tdata((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pytaddchunk>s

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

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

c


Cs|jS(
N(
R(
R
((sA/sys/lib/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|�}t|�|
ks�j
r�|�|
ks��|S(Nit(
R	RRRRR
RRtjointAssertionError(R
tamttblockstneedRtnbtresult((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pytreadOs"










	






3cCs�|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((sA/sys/lib/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((sA/sys/lib/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
((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyt_close�s
	

N(
R
RRRRRRRRRR#R%R&(((sA/sys/lib/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.
    cCsP|
r#|js#t
d
|
��ntjd|jt|
��
|j|
�
dS(Ns*tried to add data (%r) to a closed reader!s%s read an additional %d data(RRtloggertdebugtnameR
R(R
R((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR%�s






(R
RRR%(((sA/sys/lib/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
((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR&�s


(R
RRR*R&(((sA/sys/lib/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((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR�s



	


cCsTtj
||
�
|jt|
�7_|j|jkrPt|_tjd
�
ndS(Nscontent-length read complete(	R'R%R0R
R/R-RR(R)(R
R((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR%�s




	
(R
RRR*RR%(((sA/sys/lib/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((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR�s


	
	
cCs�|jst
d
��tjdt|
��
d}|jrstjd�
|j|
}
|j}d|_d|_nt|
�}x

||kr�|
j|j|�}|dkr�|
|_||_dSt	|
||!dd�
}|t|j�}||t|j�t|
�kr*
|
|_||_dS|dkrP
t
|_tjd	�
dS|j|
|||!�
||t|j�}q�WdS(
Ns%tried to add data to a closed reader!s"chunked read an additional %d datais8chunked reader trying to finish block from leftover dataRi�tbaseis/closing chunked reader due to chunk of length 0(RRR(R)R
R5R4R R3tintR-R(R
RtpositiontdatalentsplitRtblock_start((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR%�s8



	



	
	





	
	


#
	
	


	




(R
RRRR%(((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyR2�s

	(Rthttplibt	itertoolstloggingt	getLoggerR
R(t	ExceptionRt
HTTPExceptionRtobjectRR'R+R.R2(((sA/sys/lib/python2.7/site-packages/mercurial/httpclient/_readers.pyt<module>!s

a