ó
ÛXc@@s
dZd
dl
mZ
yd
dlZej
Wn ek
rO


d
dljZn
Xd
dlZej	e
ƒ
Zdef
d„ƒYZ
dejf
d„ƒYZdef
d	„ƒYZd
ef
d„ƒYZdef
d
„ƒYZdef
d„ƒYZdef
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(
tabsolute_importNtReadNotReadyc
B@seZ
dZRS(
s>Raised when read() is attempted but not enough data is loaded.(t__name__t
__module__t__doc__(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR
/s
tHTTPRemoteClosedErrorc
B@seZ
dZRS(
s@The server closed the remote socket in the middle of a response.(RRR(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR3s
tAbstractReadercB@sbeZ
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

C@st|_
g|_d
|_dS(Ni(tFalset	_finishedt_done_chunkstavailable_data(
tself((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt__init__>s
	
	
cC@s)|jj
|
ƒ

|jt|
ƒ
7_dS(
N(R	tappendR
tlen(Rtdata((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt	_addchunkCs

cC@s,|jj
d
|
ƒ
|jt|
ƒ
7_dS(Ni(R	tinsertR
R(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt
_pushchunkGs

c
C@s+|jj
d
ƒ
}
|jt|
ƒ
8_|
S(Ni(R	tpopR
R(Rt
b((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt	_popchunkKs

c


C@s|jS(
s3Returns true if the response body is entirely read.(
R(
R((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytdoneQscC@sö|j|
kr%|j
r%tƒ‚
ng}|
}x||jr¯|jƒ}t|ƒ
|kr|| }|j||ƒ

|}n|j|ƒ

|t|ƒ
8}|d
kr4Pq4q4Wdj|ƒ
}t|ƒ
|
ksò|j
rìt|ƒ
|
ksòt	‚
|S(s&Read amt bytes from the response body.it(
R
RR
R	RRRR
tjointAssertionError(RtamttblockstneedRtnbtresult((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytreadUs"









	






3cC@sœ|d
krg}nx€|j
r—|jƒ}|j|
ƒ
t|
ƒ
}|r‡|t|ƒ
krr|j||ƒ

n|j|| ƒ

Pq|j|ƒ

qW|S(sl
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(tNoneR	RtfindRRR
(RtdelimstrRRt
i((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytreadtojs
	






c
C@s
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(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt_load‚sc

C@s|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/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt_closeŒs
	

N(
RRRRRRRRRR R$R&R'(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR7s
							
tAbstractSimpleReaderc
B@seZ
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.
    cC@sP|
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(RRtloggertdebugtnameRR(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&¡s




	

(RRRR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR(›s
tCloseIsEndReaderc
B@seZ
dZd
Zd„ZRS(s?Reader for responses that specify Connection: Close for length.sclose-is-endc

C@stj
d
ƒ

t|_dS(Ns&Marking close-is-end reader as closed.(R)tinfotTrueR(
R((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR'®s


(RRRR+R'(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR,ªs

tContentLengthReaderc
B@s&eZ
dZd
Zd„Zd„ZRS(s:Reader for responses that specify an exact content length.scontent-lengthcC@s;tj
|ƒ

|
|_|
d
kr.t|_nd
|_dS(Ni(R(Rt_amountR.Rt_amount_seen(Rtamount((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR·s



	


cC@sTtj
||
ƒ
|jt|
ƒ
7_|j|jkrPt|_tjd
ƒ

ndS(Nscontent-length read complete(	R(R&R1RR0R.RR)R*(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&¾s




	
(RRRR+RR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR/³s

	t
ChunkedReaderc
B@s eZ
dZd
„Zd„ZRS(s/Reader for chunked transfer encoding responses.cC@s,tj
|ƒ

|
|_d
|_d|_dS(NiR(RRt_eolt_leftover_skip_amtt_leftover_data(Rteol((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyRÈs


	
	
cC@s‡
|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*RR6R5R!R4tintR.R(RRtpositiontdatalentsplitRtblock_start((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&Îs:



	



	
	





	
	


#
	
	


	




(RRRRR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR3Æs

	(Rt
__future__Rthttplibt
HTTPExceptiontImportErrorthttp.clienttclienttloggingt	getLoggerRR)t	ExceptionR
RtobjectRR(R,R/R3(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt<module>!s





d