�
�Xc@@s�dd
lm
Z

ddlZddlZddlmZ
ddlmZmZm	Z	m
Z

ddlmZ
e	j
Z
e	jZdZdZdZdZd�Zd	�Zd
�Zd�Zd�Zd
�Zd�Zejd�
Zd�ZdS(i(
tabsolute_importN(
t
_(terrorthttppeertutilt	wireprotoi
(
tlfutilsa
This repository uses the largefiles extension.

Please enable it in your Mercurial config file.
cC@s
|
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(scServer command for putting 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: %s
i
N(tredirectRt	storepathRtmakedirstostpathtdirnametatomictempfiletstoreRtgetfilet_fptseekthexsha1tIOErrorR
tclosetlinktousercachetuitwarntstrerrorRtpushrestdiscard(trepotprototshaRttmpfpt
e((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pytputlfile#s$














c@s~tj
||�}|s4tjtd
�
|�
�
nt|d��tj�j��
d�
��
fd�}t	j
|��
S(s\Server command for retrieving a largefile from the repository-local
    cache or user cache.s+requested largefile %s not present in cachetrbic
3@s,d
�
V
xtj
��
D]}|V
qWdS(Ns%d
(Rt
filechunkiter(
tchunk(t
ftlength(s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyt	generatorKs
	

(RtfindfileRtAbortR
topenRtfstattfilenoRt	streamres(RRRtfilenameR'((R%R&s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pytgetlfile<s





cC@s tj
||�}|sd
SdS(s;
Server command for checking if a largefile is present - returns '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
(RR((RRRR.((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyt	statlfileQs


cC@s&d
|
jf
d��Y}||
_dS(NtlfileswirerepositorycB@s,eZ
d�Zd
�Zejd��
ZRS(c
S@s\
t|j
tj�r�|jd
d|d|
di
dd6�
}yY|jdd�\}}x0|jt�
D]}|jjt	d	�
|�
qhWt
|�
SWqX
tk
r�


|jjt	d
�
|�

dSXn�yS|jd
|d|
�
\}}|dkr
t
jt	d�
|��
nt
|�
SWn:tk
r/



dStk
rW



t
jt	d
�
|��
n
XdS(NR!tdataRtheaderssapplication/mercurial-0.1scontent-types

i
sremote: s!unexpected putlfile response: %r
tsputlfile failed:s&putlfile failed (unexpected response):(t
issubclasst	__class__Rt_calltsplitt
splitlinestTrueRRR
tintt
ValueErrort	_callpushRt
ResponseErrorR(tselfRtfdtrest
dtoutputt
ltret((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyR!_s,






















cs@s�|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 shaR/Rsunexpected response:tlimiti
N(t_callstreamtreadlineR;R<t_abortRR>R
RR#R5R6Rtread(R?RtstreamR&R$((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyR/~s







	



cs@s\tj
�}i
|
d
6}||fV
yt|j�
V
Wnttjfk
rW


dV
n
XdS(NRi(RtfutureR;tvalueR<turlerrt	httperror(R?RR%tresult((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyR0�s





(t__name__t
__module__R!R/Rt	batchableR0(((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyR1^s
		(
R6(RRR1((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyt
wirereposetup]s
CcC@st||
�d
S(s;Wrap server command to announce largefile server capabilitys largefiles=serve(
tcapabilitiesorig(RR((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pytcapabilities�scC@s,tj
|�
rtjt�
Stj||
�S(
sTWrap server command - largefile capable clients will know to call
    lheads instead(RtislfilesrepoRtooberrortLARGEFILES_REQUIRED_MSGtheads(RR((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyRZ�s


cK@sl|
d
kr$|jd�
r$d}
n|
dkr\|jd�
r\|dj
dd�|d<nt||
|�S(NRZt
largefilestlheadstbatchtcmdssheads slheads (tcapabletreplacetssholdcallstream(R?tcmdtargs((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pytsshrepocallstream�s


	


s(^|;)heads\bcK@sl|
d
kr$|jd�
r$d}
n|
dkr\|jd�
r\t
jd|d�|d<nt||
|�S(NRZR[R\R]R^(R_theadsretsubthttpoldcallstream(R?RbRc((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pythttprepocallstream�s


	


(t
__future__RRtretmercurial.i18nR
t	mercurialRRRRR4RRNturlreqRYtNoneRURaRgR!R/R0RTRVRZRdtcompileReRh(((s:/usr/lib/python2.7/dist-packages/hgext/largefiles/proto.pyt<module>s(
"	
	

				G