�
�c@s�dd
kZdd
k
Z
dd
kZdd
kZdd
kZyddklZ
Wn%ej
o

Z	
ddklZ
n
Xde
f
d��YZdeif
d��YZ
ddd��YZd	eif
d
��YZddklZlZlZlZlZlZlZ
dd
kZdd
kZdd
kZdd
kZdd
kZdeif
d
��YZdeif
d��YZd
a d�Z!d�Z"d�Z#d
S(i�N(
tStringIOt
RangeErrorc
BseZ
dZRS(
s6Error raised when an unsatisfiable range is requested.(t__name__t
__module__t__doc__(((s&/sys/lib/python/mercurial/byterange.pyR
!s

tHTTPRangeHandlerc
Bs eZ
dZd
�Zd�ZRS(s�Handler that enables HTTP Range headers.

    This was extremely simple. The Range header is a HTTP feature to
    begin with so all this class does is tell urllib2 that the
    "206 Partial Content" reponse from the HTTP server is what we
    expected.

    Example:
        import urllib2
        import byterange

        range_handler = range.HTTPRangeHandler()
        opener = urllib2.build_opener(range_handler)

        # install it
        urllib2.install_opener(opener)

        # create Request and set Range header
        req = urllib2.Request('http://www.python.org/')
        req.header['Range'] = 'bytes=30-50'
        f = urllib2.urlopen(req)
    cCs1ti
|||
i��}||_||_|S(
N(turllibt
addinfourltget_full_urltcodetmsg(tselftreqtfpR	R
thdrst
r((s&/sys/lib/python/mercurial/byterange.pythttp_error_206=s
	
	
cCstd
��dS(NsRequested Range Not Satisfiable(
R
(RRR
R	R
R((s&/sys/lib/python/mercurial/byterange.pythttp_error_416Ds(RRRRR(((s&/sys/lib/python/mercurial/byterange.pyR%s	tRangeableFileObjectcBsheZ
dZd
�Zd�Zd�Zdd�Zdd�Zdd�Zd	�Z	d
�Z
d�ZRS(sFile object wrapper to enable raw range handling.
    This was implemented primarilary for handling range
    specifications for file:// urls. This object effectively makes
    a file object look like it consists only of a range of bytes in
    the stream.

    Examples:
        # expose 10 bytes, starting at byte position 20, from
        # /etc/aliases.
        >>> fo = RangeableFileObject(file('/etc/passwd', 'r'), (20,30))
        # seek seeks within the range (to position 23 in this case)
        >>> fo.seek(3)
        # tell tells where your at _within the range_ (position 3 in
        # this case)
        >>> fo.tell()
        # read EOFs if an attempt is made to read past the last
        # byte in the range. the following will return only 7 bytes.
        >>> fo.read(30)
    cCs>|
|_t
|�\|_|_d
|_|i|i�
dS(s}
Create a RangeableFileObject.
        fo       -- a file like object. only the read() method need be
                    supported but supporting an optimized seek() is
                    preferable.
        rangetup -- a (firstbyte,lastbyte) tuple specifying the range
                    to work over.
        The file object provided is assumed to be at byte offset 0.
        iN(tfotrange_tuple_normalizet	firstbytetlastbytetrealpost_do_seek(RRtrangetup((s&/sys/lib/python/mercurial/byterange.pyt__init__]s		

	
cCs7t|i
|
�o
t|i
|
�Sn

t|
��d
S(s�This effectively allows us to wrap at the instance level.
        Any attribute not found in _this_ object will be searched for
        in self.fo.  This includes methods.N(thasattrRtgetattrtAttributeError(Rtname((s&/sys/lib/python/mercurial/byterange.pyt__getattr__ks

c

Cs|i|i
S(
s4
Return the position within the range.
        This is different from fo.seek in that position 0 is the
        first byte position of the range tuple. For example, if
        this object was created with a range tuple of (500,899),
        tell() will return 0 when at byte position 500 of the file.
        (RR(
R((s&/sys/lib/python/mercurial/byterange.pyttellssicCs�|djp
t�
|d
jo
|i
|
}n<
|djo
|i|
}n
|djo
td��n

|io
||ijo

|i}n

|i||i�
dS(seSeek within the byte range.
        Positioning is identical to that described under tell().
        ii
is$seek from end of file not supported.N(ii
i(tAssertionErrorRRtIOErrorRR(Rtoffsettwhencet
realoffset((s&/sys/lib/python/mercurial/byterange.pytseek|s









i�cCs:|i|
�}
|i
i|
�}|it|�7_|S(
s`Read within the range.
        This method will limit the size read based on the range.
        (t_calc_read_sizeRtreadRtlen(Rtsizetrslt((s&/sys/lib/python/mercurial/byterange.pyR(�s


cCs:|i|
�}
|i
i|
�}|it|�7_|S(
sfRead lines within the range.
        This method will limit the size read based on the range.
        (R'RtreadlineRR)(RR*R+((s&/sys/lib/python/mercurial/byterange.pyR,�s


cCs^|ioP
|
d
jo/
|i
|
|ijo
|i|i
}
qV
qZ
|i|i
}
n

|
S(sSHandles calculating the amount of data to read based on
        the range.
        i�(RR(RR*((s&/sys/lib/python/mercurial/byterange.pyR'�s





cCsb|
d
jp
t�
t
|id�p
|i|
�
n
|ii|i|
�
|i|
7_dS(s�Seek based on whether wrapped object supports seek().
        offset is relative to the current position (self.realpos).
        iR&N(R!RRt_poor_mans_seekR&R(RR#((s&/sys/lib/python/mercurial/byterange.pyR�s



cCs�d
}d}xp||
job
|||
jo
|
|}n

|ii
|�}t|�|jo
td��n

||7}q
WdS(s�Seek by calling the wrapped file objects read() method.
        This is used for file like objects that do not have native
        seek support. The wrapped objects read() method is called
        to manually seek to the desired position.
        offset -- read this number of bytes from the wrapped
                  file object.
        raise RangeError if we encounter EOF before reaching the
        specified offset.
        iisRequested Range Not SatisfiableN(RR(R)R
(RR#tpostbufsizetbuf((s&/sys/lib/python/mercurial/byterange.pyR-�s








(RRRRRR R&R(R,R'RR-(((s&/sys/lib/python/mercurial/byterange.pyRHs								tFileRangeHandlerc
BseZ
dZd
�ZRS(s~FileHandler subclass that adds Range support.
    This class handles Range headers exactly like an HTTP
    server would.
    cCs�d
dk}d
dk
}|
i�}|
i�}ti|�}ti|�}|ti}|i	i
|ti�}	|i|�d}
|oO
ti
|�\}}|p
ti|�|i�jo
tid��q�
n

t|d�}|
iidd�}
t|
�}
|
djp
t�
|
o}
|
\}}|djo

|}n

|djp
||jp

||jo
td��n

||}t|||f�}n

|id|
p
d	||	f�}ti||d
|�S(Ni�isfile not on local hosttrbtRangetsRequested Range Not Satisfiables6Content-Type: %s
Content-Length: %d
Last-Modified: %s
s
text/plainsfile:((t	mimetypestemailtget_hosttget_selectorRturl2pathnametoststattST_SIZEtUtilst
formatdatetST_MTIMEt
guess_typet	splitporttsockett
gethostbynamet	get_namesturllib2tURLErrortopentheaderstgettNonetrange_header_to_tupleR!R
Rtmessage_from_stringR(RRR5R6thosttfilet	localfiletstatsR*tmodifiedtmtypetportRtbrangetfbtlbRH((s&/sys/lib/python/mercurial/byterange.pytopen_local_file�s:












#











'







(RRRRW(((s&/sys/lib/python/mercurial/byterange.pyR1�s
(RAt	splitusertsplitpasswdt	splitattrtunquotetaddclosehookRtFTPRangeHandlerc
BseZ
d�Zd
�ZRS(cCs�|
i�}|p
t
d
d��n

t|�\}}|djo

ti}n

t|�\}}|o
t|�\}}n
d}t|�}t|p
d�}t|p
d�}yt	i
|�}Wn't	ij
o

}
ti
|��n
Xt|
i��\}}|id�}	tt|	�}	|	d |	d}	}
|	o
|	do
|	d}	n

y+|i|||||	�}|
o
dp
d	}xP|D]H}
t|
�\}
}|
i�d
jo
|djo
|i�}q�
q�Wd}t|
iidd��}|djp
t�
|o'
|\}}|djo

|}qJ
n

|i|
||�\}}|o�
|\}}|djo[
|djp

|djo
td��n

|}||}|djo
td��q�
||}t|d|f�}n

d}ti|
i��d}|o
|d|7}n

|dj	o
|djo
|d|7}n

ti |�}t!|||
i��SWn4ti"j
o%

}
t
d
|�t#i$�d�n
XdS(Ns	ftp errors
no host givenR4t
/i�ii
t
It
Dttypet
at
At
it
dR3s@Requested Range Not Satisfiable due to unobtainable file length.sRequested Range Not SatisfiablesContent-Type: %s
sContent-Length: %d
i(RbRcRdR_ReR`((%R7R"RARJtftplibtFTP_PORTRXRYR[RBRCterrorRERFRZR8tsplittmaptconnect_ftptlowertupperRKRHRIR!tretrfileR
RR5R@RR6RLRt
all_errorstsystexc_info(RRRMRStusertpasswdR
tpathtattrstdirsRNtfwRatattrtvaluetrestt	range_tupRURVR
tretrlenRHRR((s&/sys/lib/python/mercurial/byterange.pytftp_open

sz


























































cCst|
||||�}|S(
N(
t
ftpwrapper(RRrRsRMRSRvRw((s&/sys/lib/python/mercurial/byterange.pyRkM
s

(RRR}Rk(((s&/sys/lib/python/mercurial/byterange.pyR]
s
	LR~cBseZ
d
d�ZRS(c
Cs/|i�
|djo
d}d}n
d|}d}y|i
i|�
Wn0tij
o!



|i�
|i
i|�
n
Xd}|
o,

|o$

y|i
i|
�
Wn4tij
o%

}
t	d|�t
i�d�n
X|i
i|�
y#d	|
}|i
i||�}Wq�tij
o�

}
t
|�id
�o;
|i|
|�\}}	t||df�}||	fSq�
t
|�id�p 
t	d|�t
i�d�q�
q�
Xn

|pA
|i
id�
|
o
d
|
}n
d}|i
i|�}n

d|_t|did�|i�|dfS(NReR`sTYPE Ai
sTYPE is	ftp errorisRETR t501R4t550sLIST tLISTR2(ReR`(tendtransfertftptvoidcmdRfRotinitRJtnlstt
error_permR"RpRqtntransfercmdtstrt
startswithRnRtbusyR\tmakefile(
RRNRaRztcmdtisdirtconntreasonR
R|((s&/sys/lib/python/mercurial/byterange.pyRnV
sJ



















!








)



	
N(RRRJRn(((s&/sys/lib/python/mercurial/byterange.pyR~Q
sc
Cs�|djo
dSn

t
djo
d
dk}
|
id�a
n

t
i|�}|oN
t|idd��}|o'
|do
|d|ddf}n

|Sn

dS(s�Get a (firstbyte,lastbyte) tuple from a Range header value.

    Range headers have the form "bytes=<firstbyte>-<lastbyte>". This
    function pulls the firstbyte and lastbyte values and returns
    a (firstbyte,lastbyte) tuple. If lastbyte is not specified in
    the header value, it is returned as an empty string in the
    tuple.

    Return None if range_header is None
    Return () if range_header does not conform to the range spec
    pattern.

    i�Ns^bytes=(\d{1,})-(\d*)i
ii((RJt_rangeretretcompiletmatchRtgroup(trange_headerR�R�ttup((s&/sys/lib/python/mercurial/byterange.pyRK�s












c

Cs_|djo
dSn

t
|�}|o3
|d
o
|d|d
d
f}n

d|Sn

dS(s�Convert a range tuple to a Range header value.
    Return a string of the form "bytes=<firstbyte>-<lastbyte>" or None
    if no range is needed.
    i
isbytes=%s-%sN(RJR(
R{((s&/sys/lib/python/mercurial/byterange.pytrange_tuple_to_header�s






c
Cs�|djo
dSn

|d
}
|
djo

d
}
n

t
|
�}
y|d}Wntj
o




d}n6
X|djo

d}n
|djo
t
|�}n

|
|fdjo
dSn

||
jo
td|
|f��n

|
|fS(s6
Normalize a (first_byte,last_byte) range tuple.
    Return a tuple whose first element is guaranteed to be an int
    and whose second element will be '' (meaning: the last byte) or
    an int. Finally, return None if the normalized tuple == (0,'')
    as that is equivelant to retrieving the entire file.
    iR4i
sInvalid byte range: %s-%sN(NR4(iR4(RJtintt
IndexErrorR
(R{RURV((s&/sys/lib/python/mercurial/byterange.pyR�s&



















(($R:R;RREtemail.UtilsR6t	cStringIORtImportErrorR
R"R
tBaseHandlerRRtFileHandlerR1RARXRYRZR[R\RRfRBRpR5t
FTPHandlerR]R~RJR�RKR�R(((s&/sys/lib/python/mercurial/byterange.pys<module>s0






#�,4



Q: