6hXSSKJr SSKrSSKrSSKrSSKrSSKrSSKJr SSK J r J r SSK J r JrJrJrJrJr SSKJrJr SSKJrJrJr \R4rSqSqSqSqSr S r!S r"S r#"S S 5r$Sr%Sr&Sr'"SS5r(g)) annotationsN)_)binhex)errorpycompatrevlogsshpeerutilwireprotov1peer)hashutilprocutil) constants contentstore metadatastorec[[R"U5R55n[R R XSSUSSU5$)Nrr sha1digestospathjoin)reponamefileidpathhashs F/usr/lib/python3/dist-packages/hgext/remotefilelog/fileserverclient.py getcachekeyr 0sA8==&--/0H 77<<2A, b AAc[[R"U5R55n[R R X!5$Nr)rrrs r getlocalkeyr$5s18==&--/0H 77<< %%r!c:"SSUR5nX!lg)Nc^\rSrSr\R S5r\R S5rSrU4Sjr U4Sjr Sr U=r $)!peersetup..remotefilepeer;cz^^URS5(d[R"S5eUU4SjnTTS.U4$)N x_rfl_getfiles5configured remotefile server does not support getfilec>URSS5up[U5(a[R"TTU5eU$)Nr)splitintr LookupError)dcodedatarnodes rdecode?peersetup..remotefilepeer.x_rfl_getfile..decodeCs8WWUA. t99++D$== r!sfilesnodecapablerAbort)selfrr3r4s `` r x_rfl_getfile/peersetup..remotefilepeer.x_rfl_getfile<s><< 011kkL  "D169 9r!clURS5(d[R"S5eSnSU0U4$)Nsx_rfl_getflogheadss:configured remotefile server does not support getflogheadsc6U(aURS5$/$)N )r-)r0s rr4Dpeersetup..remotefilepeer.x_rfl_getflogheads..decodeSs)*qwwu~22r!spathr7)r:rr4s rx_rfl_getflogheads4peersetup..remotefilepeer.x_rfl_getflogheadsKs><< 566kk,  3T?F* *r!cUS:wag[RUR5;ag[US5(dg[RUR R ;agURS5nU(aU/nO/nUR[R5 UR R(a;SRUR R5nSU-nURU5 UR R(a;SRUR R5nSU-nURU5 SRU5US'g)Ns getbundle _localrepos bundlecapsr,sincludepattern=sexcludepattern=,) rNETWORK_CAP_LEGACY_SSH_GETFILES capabilitieshasattrSHALLOWREPO_REQUIREMENTrD requirementsgetappendBUNDLE2_CAPABLITYincludepatternrexcludepattern)r:commandopts bundlecapspatterns includecap excludecaps r_updatecallstreamopts7peersetup..remotefilepeer._updatecallstreamoptsXs,&99((*+4..11334-0J(\     i99 :-- ::doo&D&DE/(: !!*--- ::doo&D&DE/(: !!*-"&))J"7D r!cH>URX5 [TU]"X40UD6$r#)rVsuper _sendrequest)r:rPargsrQ __class__s rrZ.peersetup..remotefilepeer._sendrequests&  & &w 57'>> >r!c>[5n[US5(d&URU[R"U55 [TU]"U40UD6$)NrZ)rYrHrVr byteskwargs _callstream)r:rPrQ supertyper\s rr`-peersetup..remotefilepeer._callstreamsGI9n55**7H4H4H4NO7&w7$7 7r!) __name__ __module__ __qualname____firstlineno__r batchabler;rArVrZr`__static_attributes__ __classcell__r\s@rremotefilepeerr';sJ  " " : # :  " " + # +& 8P ? 8 8r!rlrk)uipeerrls r peersetupro:sM8M8^$Nr!c:\rSrSrSrSrSrSrS SjrSr Sr g ) cacheconnectionzThe connection for communicating with the remote cache. Performs gets and sets by communicating with an external process that has the cache-specific implementation. cJS=Ul=UlUlSUlSUlg)NF)pipeopipeipipee subprocess connectedr:s r__init__cacheconnection.__init__s%/33 3TZ$*r!cUR(a[R"[S55e[R "U5uUlUlUlUlSUl g)Nscache connection already openT) rtrr9rrpopen4rurvrwrx)r: cachecommands rconnectcacheconnection.connectsI ::++a @AB B>Foo ? ; DJ DOr!cSnUR(aURRS5 U"UR5 SUlU"UR5 SUlU"UR 5 SUlUR R5 SUlSUlg![a Nf=f![a N+f=f)NcFUR5 g![a gf=fr#)close Exception)pipes rtryclose'cacheconnection.close..trycloses"    s   sexit F)rxruwriterrtrvrw communicate)r:rs rrcacheconnection.closes  >>    + TZZ DJ TZZ DJ TZZ DJ ++-#DO!    s#B&=B6& B32B36 CCcUR(a?URRU5 U(aURR5 ggg![a UR 5 gf=fr#)rxrurflushOSErrorr)r:requestrs rrcacheconnection.requestsW >>    )JJ$$&     s L N & " ! !s BB44 CcURS5 SnURnURnU[U5:aUn [ [U5X-5n U nX9U H#n U SSn XKn SX4-nUR U5 M% UR 5 X9U Hn U SSn XKn U"XU 5 U"5 M U[U5:aMUR S5 UR 5 g)Nx_rfl_getfilesrr%s%s r?)r`_pipeo_pipeirminrr)rrrrrsteprrtrustartend missingid versionidr sshrequests r_getfiles_optimisticrs () A MME MME c&k/#f+u|, c*I!#$I#D"i%66J KK # +   c*I!#$I#D 5 2 N + c&k/* KK KKMr!cj^^^ URS5 URm URnUUU 4Sjn[R"US9nSUlUR 5 THn U SSn TU n U"XkU 5 U"5 M UR5 T RS5 T R5 g)Nrcz>TH$nUSSnTUnSX4-nTRU5 M& TR5 g)Nrr)rr)rrrrrrrts rwriter"_getfiles_threaded..writersFI!#$I#D"i%66J KK #   r!)targetTrr?) r`rr threadingThreaddaemonrrrr) rrrrrrrur writerthreadrrrrts `` @r_getfiles_threadedrs () MME MME##62LL cdO YuI.   KK KKMr!cZ\rSrSrSrSrSrSrSrSr Sr S r SS jr S r S rS rg)fileserverclienti0z:A client for requesting files from the remote file server.cHURnXlX lURSS5UlUR(a%[R "UR5UlUR SS5UlUR SS5Ul[5Ul g)N remotefilelogs cacheprocessscacheprocess.includepathsdebug) rmrepoconfig cacheprocessr expandpath configboolcacheprocesspasspath debugoutputrq remotecache)r:rrms rrzfileserverclient.__init__3s WW II&6H    $0A0A BD %'MM 9% !==)98D*,r!c4XlX lX0lX@lgr#) datastore historystore writedata writehistory)r:rrrrs rsetstorefileserverclient.setstoreEs"("(r!ctURRRURR5$r#)rconnectionpoolrK fallbackpathrys r_connectfileserverclient._connectKs'yy''++DII,B,BCCr!c * URR(dUR5 URnURnURn[ U5nSU-n0nUR nUH4up[XU 5n UR(aXiS-- nXkS-- nXU 'M6 URU5 URR[S5US9n U RS5 /n UR5nU(dQ[U 5nUHnX;dM U R!U5 M URR#[S55 O`US:XaOYUR%S 5(a0UR'S 5nU R)[+US 55 MU R!U5 M[,[ U 5- qU[ U 5- nU RUUS9 URR/S S UUUUS9 [0R2"S 5nU (Ga'URR4nSURlUR75nUR8nUR;[<R>5(a[AU[B5(d[DRF"S5eURRIS S5nURRKS S5nUS:Xa[LnO[NnU"UURPU R(U UU5 OUR;S5(aUR;S5(aSnOSnURRIS SU5nURRSS[ U 5-5 [UUURPU R(U UU5 O[DRF"S5eSSS5 URR/SSU RVU- UU- S9 UURlS [ U 5SR[U 54-nURU5 U R]5 UR_URR`5 [0R2"U5 g!,(df  N=f![Xa. URR/SSU RVU- UU- S9 ef=f!UURlf=f![0R2"U5 f=f)!zTakes a list of filename/node pairs and fetches them from the server. Files are stored in the local cache. A list of nodes that the server couldn't find is returned. If the connection fails, an exception is raised. sget %d r,r?s downloading)totalrs@warning: cache connection closed early - falling back to server 0s_hits__rrs"remote cache hit rate is %r of %r )hitrFs"remotefilelog requires ssh serverss getfilessteps getfilestypesthreadedr*sbatchd s batchsizes1requesting %d files from remotefilelog server... s>configured remotefilelog server does not support remotefilelogNsremotefilefetchlogsSuccess ) fetched_filestotal_to_fetchsFail s set %d %s )1rrxrrrrnamer rrrm makeprogressrupdatersetrLwarn startswithr- incrementr. fetchmisseslogrumaskverboserrnr8rrF isinstance _sshv1peerrr9 configintrrrrdebugrposrrcompletemarkrepor)r:fileidscacherrrrrrrrfullidprogressrr missedsetparts fromcacheoldumaskrconnrr getfilestype _getfiles batchdefaultrs rrfileserverclient.requestNs )) LLN  NN yyG &99HD 4F((%<' ~ %G &M    g77''.(9'G))+IK !&I$1 i0"' 6 D ##I..!-""3uQx=1 MM) $-2 s6{" CK'  /   2    88E?W ''//"'E.D!%!>>%EE$.fj#A#A&+kk$I'"!"$(77#4#4 0/$D,077>> 0/,L ,{:,> ,@ % & $ 3 3 ( 2 2 & % $ $^^,<==%~~h77/2 /1 (,(9(9 0, )I!GGMM!=?B6{!K+ & $ 3 3 ( 2 2 & % ) #(++!C#a)jGGKK-$&.llY&>',y'8  '.DGGO*c&k5::f;M-NN g&       tyy~~ . HHX ])v!GGKK-!&.llY&>',y'8   '.DGGO HHX sJ/S: R)E9R4R) A6S: R&"R))8S!!S$$S77S::TcUR5SSnU(d)[R"[S5[S55e[ U5nUR U5n[ U5U:wa7[R"[S5[S5[ U5U4-5eURRU[U5[R"U55 g)Nrs error downloading file contents:sconnection closed earlysonly received %s of %s bytes) rr ResponseErrorrr.readrraddremotefilelognoderzlib decompress)r:rfilenamer3linesizer2s rrfileserverclient.receivemissings}}s#%%56,- 4yyy t9 %%5612c$i5FF  ++ c$i!6 r!cUR(aASURURR4-nURR U5 g"SS5nU"5Ulg)Ns%s %sc0\rSrSrSrSrSSjrSrSrg) -fileserverclient.connect..simplecacheic /UlSUlg)NT) missingidsrxrys rrz6fileserverclient.connect..simplecache.__init__s&(DO%)DNr!cgr#rcrys rr3fileserverclient.connect..simplecache.close sr!cURS5nUSS:wagUSSUlURRS5 g)Nr?rsgetrrr)r-rrL)r:valuerliness rr5fileserverclient.connect..simplecache.requests>!KK.EQx6)&+AbkDOOO**40r!cl[UR5S:aURRS5$g)Nr)rrpoprys rr9fileserverclient.connect..simplecache.receivelines+4??+a/#22155r!)rxrNr) rdrerfrgrzrrrrircr!r simplecachers*1 r!r)rr_pathrr)r:cmdrs rrfileserverclient.connectsT   d//1E1EFFC    $ $S )   ( +}D r!c [(aS[[[[[[- 5[[5- S-[4-nUR (aUR RU5 UR RSURSS5[[[[S-S9 URR(aURR5 gg)NsN%d files fetched over %d fetches - (%d misses, %0.2f%% hit ratio) over %0.2fs gY@sremotefilelog.prefetch%s%%i)remotefilelogfetchedremotefilelogfetchesremotefilelogfetchmissesremotefilelogfetchtime) fetchesfetchedrfloat fetchcostrrmrrreplacerrxr)r:msgs rrfileserverclient.closes 7Bg +,uW~=E  C S! GGKK) D%(%,%,)4'04'7      % %    " " $ &r!cURn/nUHNupxUS:Xd%[U5S:XdURU5(dM2URU[ U545 MP UR n UR n U(a:[R"UR6n [R"UR6n [5n U(a U RU RU55 U(a U RU RU55 [U V Vs/sH"upXRR :XdM SPM$ snn 5n U (aOU VVs/sH#upXRR :wdM X4PM% n nnUR"R%SU -SS9 U (Ga=[&S- q[&S:ae[&S :a[[&S:XaAUR"R)S S 5nU(aUR"R+US -5 UR-5 [/U 5VVs/sHupxU[1U54PM n nn[2[U 5- q[4R4"5nUR7U 5n U (a+[8R:"[=S 5[U 5-5e[>[4R4"5U- - qURAU5 ggs snn fs snnfs snnf)z.downloads the given file versions to the caches.hgtags*NsDremotefilelog not fetching %d null revs - this is likely hiding bugssremotefilelog-ext)rrrs fetchwarningr?sunable to download %d files)!rr shallowmatchrLrrrrunioncontentstoreshareddatastoresrunionmetadatastoresharedhistorystoresrr getmissingnullidrm develwarnr(rr logstacktracesortedrr)timerrr9rr+ _lfsprefetch)r:rforce fetchdata fetchhistoryr idstocheckrrrrrunusednullidsf fetchwarningrs rprefetchfileserverclient.prefetch7syy HD  "r7b=((..   tSWo . NN (( $668M8MNI(;;))LU    i22:> ?    l55jA B$. IJjf" 8H8H2HTJ I  %/%/EA29I9I3IZ  GG  57>?,    qLG"}2b=#'77>>(/$L$ \E%9:""$:@:LM:Lhd4R/:LJM s: &GIIKEj1Jkk45JG u, ,I   g &/  J0NsK+ K+ K1>K13K7cH^ [(a%[URRS5(dg[RR UR5(dg/nURRR m UHup4[U5nURRU5nURU5[R-(dMTURU5n[RRU5nUR5n T R!U 5(aMUR#U5 M [%U5S:aMURRR&R)UT 5 [+U 4SjU55(degg)Nlfslocalblobstorerc3b># UH$nTRUR55v M& g7fr#)hasoid).0pstores r 0fileserverclient._lfsprefetch..s#<8auyy))8s,/)_lfsmodrHrsvfswrapper candownloadrJrrflagsr REVIDX_EXTSTOREDrawdatapointer deserializerMrLrLrlfsremoteblobstore readbatchall) r:rpointersrrr3rlogtextrOrMrPs @rr>fileserverclient._lfsprefetchs#wgdiinn6IJJ **49955  00HDr7D99>>$'Dzz$&"9"999||D)OO//5eegyy~~OOA&  x=1  IINN - - 7 7% H<8<<< << r!c SSKnURRSSSRSUR 5555 g)Nrrs"excess remotefilelog fetching: %s r!c3N# UHn[R"U5v M g7fr#)rsysbytes)rNss rrQ1fileserverclient.logstacktrace..s L3KaX&&q))3Ks#%) tracebackrmrr format_stack)r:rhs rr;fileserverclient.logstacktraces6   3 HHL93I3I3KL L r!) rrrrrrrrmrrN)FTF)rdrerfrgrrzrrrrrrrGr>r;rircr!rrr0sCD-$) D[z &->%6BGI'V=( r!r)) __future__rrrrr=r mercurial.i18nrmercurial.noderr mercurialrrr r r r mercurial.utilsr rrrr sshv1peerrr+r(r)rrSr r$rorqrrrrrcr!rrrs#  #         B & P$fBBJ>@>m m r!