��c@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:/sys/lib/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:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pyt	generator@s
	

(R	tfindfileRtAbortRtopenRtfstattfilenoRt	streamres(RRRtfilenameR(((R&R's:/sys/lib/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:/sys/lib/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:/sys/lib/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:/sys/lib/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:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pyR1�s	





(t__name__t
__module__R"R0RR1(((s:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pyR2Ss
	 	(
R7(RRR2((s:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pyt
wirereposetupRs
DcCst||
�d
S(Ns largefiles=serve(
tcapabilitiesorig(RR((s:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pytcapabilities�s
cCs,tj
|�rtjt�Stj||
�S(
N(R	tislfilesrepoRtooberrortLARGEFILES_REQUIRED_MSGtheads(RR((s:/sys/lib/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:/sys/lib/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:/sys/lib/python2.7/site-packages/hgext/largefiles/proto.pythttprepocallstream�s


	


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



				H