�
�c@s^ddkZddkZddklZddklZdefd��YZed�Z dS(i�N(t_(tstoretStreamExceptioncBseZd�Zd�ZRS(cCsti|�||_dS(N(t Exceptiont__init__tcode(tselfR((s(/sys/lib/python/mercurial/streamclone.pyRs
cCsd|iS(Ns%i
(R(R((s(/sys/lib/python/mercurial/streamclone.pyt__str__s(t__name__t
__module__RR(((s(/sys/lib/python/mercurial/streamclone.pyR
s c
cs�|iiddd|�ptd��ng}d}y�|i�}zc|iitd��xF|ii�D]5\}}}|iti |�|f�||7}qpWWd|i
�XWn"tij
otd��nXd V|iitd
�t
|�|f�dt
|�|fVxq|D]i\}}|iitd�||f�d
||fVx+ti|i|�d|�D]}|VqWq%WdS(swstream out all metadata files in repository.
writes to file-like object, must support write() and optional flush().tservertuncompressedt untrustediis scanning
Nis0
s%d files, %d bytes to transfer
s%d %d
ssending %s (%d bytes)
s%s%d
tlimit(tuit
configboolRtlocktdebugRRtwalktappendt encodedirtreleaseterrort LockErrortlentutilt
filechunkitertsopener( trepoRtentriesttotal_bytesRtnametenametsizetchunk((s(/sys/lib/python/mercurial/streamclone.pyt
stream_out$s4 (
RRti18nRt mercurialRRRtFalseR#(((s(/sys/lib/python/mercurial/streamclone.pys<module>s
|