mò óRÅDc@sLdkTdkTdklZdkTeeƒdƒdefd„ƒYZdS((t*(sgettextshg os re stat utilt sshrepositorycBs’tZdd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Z d „Z d „Z d „Z d „Z d„Zd„Zd„ZRS(Nic CsÖ||_||_tid|ƒ}|ptit dƒ|ƒ‚n|i dƒ|_ |i dƒ|_ |i dƒ|_ |i dƒpd|_|i od|i |i fp|i }|i od ||i fp|}|iid d d ƒ}|iid d d ƒ}|o y|i||||ƒdSWntij onXd} | ||||if} |id| ƒti| ƒ}|djotit dƒƒ‚q¼n|i||||ƒdS(Ns*ssh://(([^@]+)@)?([^:/]+)(:(\d+))?(/(.*))?scouldn't parse location %siiiit.s%s@%ss%s -p %stuitssht remotecmdthgs%s %s "%s init %s"s running %s iscould not create remote repo(tpathtselfturlRtretmatchtmRt RepoErrort_tgrouptuserthosttporttargstconfigtsshcmdRtcreatet validate_repotcmdtnotetostsystemtres( RRRRRRRRR R((t5/usr/lib/python2.4/site-packages/mercurial/sshrepo.pyt__init__s4  *$ c Cs—d}|||||if}|id|ƒti |dƒ\|_ |_ |_ |i dƒ|i ddddd dd fƒ} d d g}d }x|d o||ou| iƒ}|iƒ|d djo|djoPn|o|itdƒ|ƒn|i|ƒ|d8}qWtitdƒƒ‚f|_|iƒxC|D];}|idƒo%|d idƒdiƒ|_PqTqTWdS(Ns%s %s "%s -R %s serve --stdio"s running %s tbthellotbetweentpairss%s-%st0i(ttdummyiôiÿÿÿÿs1 s sremote: isno response from remote hgs capabilities:t:(RRRRRRRRRtpopen3tpipeotpipeitpipeetdo_cmdtrtlinest max_noisetreadlinetltreaderrtdebugRtappendRR t capabilitiestreverset startswithtsplit( RRRRRR.RR-R0R,((RR3s4$ '       cCsgx`ti|iƒi}|djoPn|iiƒ}|pPn|ii t dƒ|ƒqWdS(Niisremote: ( tutiltfstatRR*tst_sizetsizeR/R0RtstatusR(RR0R;((RR1Rs cCsfyX|iiƒ|iiƒx*|iD]}|iitdƒ|ƒq'W|iiƒWnnXdS(Nsremote: ( RR(tcloseR)R*R0RR<R(RR0((Rt__del__Zs   cKs|iitdƒ|ƒ|iid|ƒxJ|iƒD]<\}}|iid|t |ƒfƒ|ii|ƒq;W|ii ƒ|i S(Nssending %s command s%s s%s %d (RRR2RRR(twriteRtitemstktvtlentflushR)(RRRRARB((RR+es   cKsh|i||}|iƒ}|iƒyt|ƒ}Wn t i t dƒ|ƒ‚nX|i |ƒS(Nsunexpected response '%s'( RR+RRR,R/R0R1tintRR Rtread(RRRR0R,((Rtcallos  cCs|idƒt|ƒS(Ntlock(RRGt remotelock(R((RRHys cCs|idƒdS(Ntunlock(RRG(R((RRJ}scCs\|idƒ}ytt|d idƒƒSWn(titdƒ|d dƒ‚nXdS(Ntheadsiÿÿÿÿt sunexpected response '%s'is...( RRGtdtmaptbinR7RR R(RRM((RRK€s cCs£ditt|ƒƒ}|idd|ƒ}yGg}|i ƒD]%}|t tt |i dƒƒƒqA~}|SWn(titdƒ|d dƒ‚nXdS(NRLtbranchestnodessunexpected response '%s'is...(tjoinRNthexRQtnRRGRMt_[1]t splitlinesRttupleROR7tbrRR R(RRQRRMRTRURX((RRP‡s?cCsÏdig}|D]}|ditt|ƒƒq~ƒ}|idd|ƒ}yOg}|i ƒD]-}||ott |i dƒƒpgqe~}|SWn(titdƒ|d dƒ‚nXdS( Ns t-R!R"RLsunexpected response '%s'is...(RRRUR"tpRNRSRTRRGRMRVR0ROR7RR R(RR"RMR0RTRURZ((RR!s<GcCs+ditt|ƒƒ}|idd|ƒS(NRLt changegrouptroots(RRRNRSRQRTRR+(RRQtkindRT((RR[™scCs3|iddditt|ƒƒƒ}|otit dƒ|ƒ‚nxZ|i dƒ}|pPn|i i tt|ƒƒdƒ|i i |ƒ|iƒqNW|i i dƒ|i iƒ|iƒ|iiƒ}|djodSnt|iiƒƒ}|ii |ƒ}|pdSnt|ƒS( NtunbundleRKRLspush refused: %siis s0 (RRGRRRNRSRKRMRR RtcgRFR(R?tstrRCR1RDR)R/RER0R,(RR_RKtsourceRMR0R,((RR^s,'    cCsÇ|idƒ}|otitdƒ|ƒ‚nx:|idƒ}|pPn|ii |ƒ|i ƒq6W|ii ƒ|i ƒt |i iƒƒ}|i i|ƒ}|pdSnt |ƒS(Ntaddchangegroupspush refused: %sii(RRGRMRR RR_RFR(R?R1RDRER)R/R0R,(RR_RaRMR0R,((RRb·s"  cCs |idƒS(Nt stream_out(RR+(R((RRcÊs(t__name__t __module__RRR1R>R+RGRHRJRKRPR!R[R^RbRc(((RRs $        N( tnodet remoterepoti18ntgettextRt demandloadtglobalstremoterepositoryR(RR((Rt?s