łň ř$•Jc@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 cCs d|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"t i j otdƒ‚nXd V|iitd ƒt |ƒ|fƒd t |ƒ|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().tservert uncompressedt 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( trepoR tentriest total_bytesRtnametenametsizetchunk((s(/sys/lib/python/mercurial/streamclone.pyt stream_out$s4   ( RRti18nRt mercurialRRRtFalseR#(((s(/sys/lib/python/mercurial/streamclone.pyss