�
Hq�Qc@s�dd
lZdd
l
Z
ddlmZmZmZmZ
ddlmZm	Z	
ddl
mZ
dd
lZdZ
d
Zd
Zd
Zd�Zd�Zd�Zd	�Zd
�Zd�Zd�Zd
�Zd
S(i����N(terrorthttppeertutilt	wireproto(t	batchabletfuture(
t
_sa
This repository uses the largefiles extension.

Please enable it in your Mercurial config file.
cCs
|
j�
t
j||�}tjtjj|�
�

tj|d
|j	j
�

}z�yk|
j|�

|jj
d�

|t
j|j�
kr�tdtd�
��
n|j�
t
j||�
Wn@tk
r

}
|jjtd�
||jf�

tjd�
SXWd|j�
Xtjd�
S(sLPut a largefile into a repository's local store and into the
    user cache.t
createmodeis$largefile contents do not match hashs+largefiles: failed to put %s into store: %si
N(tredirecttlfutilt	storepathRtmakedirstostpathtdirnametatomictempfiletstoreRtgetfilet_fptseekthexsha1tIOErrorRtclosetlinktousercachetuitwarntstrerrorRtpushrestdiscard(trepotprototshaR
ttmpfpt
e((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pytputlfiles$















cs~tj
||�}|s4tjtd
�
|�
�
nt|d��tj�j��
d�
��
fd�}t	j
|��
S(sIRetrieve a largefile from the repository-local cache or system
    cache.s+requested largefile %s not present in cachetrbic
3s,d
�
V
xtj
��
D]}|V
qWdS(Ns%d
(Rt
filechunkiter(
tchunk(t
ftlength(s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyt	generator@s
	

(R	tfindfileRtAbortRtopenRtfstattfilenoRt	streamres(RRRtfilenameR(((R&R's</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pytgetlfile2s



cCs tj
||�}|sd
SdS(s
Return '2
' if the largefile is missing, '0
' if it seems to be in
    good condition.

    The value 1 is reserved for mismatched checksum, but that is too expensive
    to be verified on every stat and must be caught be running 'hg verify'
    server side.s2
s0
(R	R)(RRRR/((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyt	statlfileFs


cCs&d
|
jf
d��Y}||
_dS(NtlfileswirerepositorycBs)eZ
d�Zd
�Zed��
ZRS(c
Ssn
t|j
tj�r�d}y�|jd
d|d|
di
dd6�
}|jdd�\}}x3|jt�
D]"}|jj	t
d	�
|d�
qnWt|�
SWqj
tt
jfk
r�


|jj	t
d
�
|�

dSXn�yS|jd
|d|
�
\}}|dkr"
tjt
d�
|��
nt|�
SWn:tk
rA



dStk
ri



tjt
d
�
|��
n
XdS(NR"tdataRtheaderssapplication/mercurial-0.1scontent-types

i
sremote: s unexpected putlfile response: %stsputlfile failed:s&putlfile failed (unexpected response):(t
issubclasst	__class__R
tNonet_calltsplitt
splitlinestTrueRRRtintt
ValueErrorturllib2t	HTTPErrort	_callpushRt
ResponseErrorR(tselfRtfdtrest
dtoutputt
ltret((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyR"Ts.






 















css�|jd
d|
�

}|j
�}yt|�
}Wn0tk
rc


|jtjtd�
|��

n
Xx"tj	|d|�D]}|V
qzWt
|jtj�r�|j
d�
}|r�|jtjtd�
|��

q�ndS(	s<returns an iterable with the chunks of the file with sha shaR0Rsunexpected response:i�ii
Ni(t_callstreamtreadlineR=R>t_abortRRBRRR$R6R7R
tread(RCRtstreamR'R%((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyR0ts







	



cssYt�}i
|
d
6}||fV
yt
|j�
V
Wnttjfk
rT


dV
n
XdS(NRi(RR=tvalueR>R?R@(RCRR&tresult((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyR1�s	





(t__name__t
__module__R"R0RR1(((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyR2Ss
	 	(
R7(RRR2((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyt
wirereposetupRs
DcCst||
�d
S(Ns largefiles=serve(
tcapabilitiesorig(RR((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pytcapabilities�s
cCs,tj
|�
rtjt�
Stj||
�S(
N(R	tislfilesrepoRtooberrortLARGEFILES_REQUIRED_MSGtheads(RR((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyRY�s



cKsl|
d
kr$|jd�
r$d}
n|
dkr\|jd�
r\|dj
dd�|d<nt||
|�S(NRYt
largefilestlheadstbatchtcmdssheads slheads (tcapabletreplacetssholdcallstream(RCtcmdtargs((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pytsshrepocallstream�s


	


cKsl|
d
kr$|jd�
r$d}
n|
dkr\|jd�
r\|dj
dd�|d<nt||
|�S(NRYRZR[R\R]sheads slheads (R^R_thttpoldcallstream(RCRaRb((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pythttprepocallstream�s


	


(RR?t	mercurialRR
RRtmercurial.wireprotoRRtmercurial.i18nRR	RXR8RTR`RdR"R0R1RSRURYRcRe(((s</usr/lib64/python2.7/site-packages/hgext/largefiles/proto.pyt<module>s"
"



				H