.8 s=@ddlZddlZddlmZmZmZddlmZmZm Z m Z m Z ddl m Z e jZdZGddej ZGd d ej$eZy) N)binhexnullrev)ancestorcontexterrorphasesutil) shallowutilg?ceZdZ dfd ZdZedZddZdZedZ dZ dZ d Z d Z d Zd Zdd ZdZdZddZdZfdZdZxZS) remotefilectxc|tk(r |j}|rt|dk(r t|}tt |||||||||_y)N()rnullidlenrsuperr__init__ _ancestormap) selfrepopathchangeidfileidfilelog changectx ancestormap __class__s Eusr/lib/python3.12/site-packages/hgext/remotefilelog/remotefilectx.pyrzremotefilectx.__init__sS W [[F c&kR'[F mT+ $&'9 (cL|jj|jSN)_filelogsize _filenoders rr$zremotefilectx.size-s}}!!$..11r cd|jvr |jSd|jvr|jjSd|jvro|j |j |j |j|j}|jjjj|S|jS)N _changeid _changectx_descendantrev) __dict__r(r)rev_adjustlinknode_pathr#r%r*_repo unfiltered changeloglinkrev)rlinknodes rr(zremotefilectx._changeid0s $-- '>> ! T]] *??&&( (  .++ DMM4>>4;N;NH::((*4488B B<<> !r c^t|j|j||j|S)zMopens an arbitrary revision of the file without opening a new filelog)rrr)rr/r.r#)rrrs rfilectxzremotefilectx.filectx@s, JJ JJMM   r c|jSr")_linkrevr&s rr2zremotefilectx.linkrevKs }}r c|j|jjk(rtS|j }||j\}}}}|jj j j|}||S|j}|j}|jjj } |jj} tt| dz ddD]X}| j|} | j| } || dvs-|| | djj!|k(sV|cSy)Nr r)r%r/rrrr1indexget_revr.r0 manifestlograngernodereadreadfastget) rrp1p2r3copyfromr,rrclmflr?datas rr7zremotefilectx._linkrevNs >>TZZ.. .N&&( %0%@"B(jj""((00: ?Jzz ZZ " " $ . .jj$$R1a,C773>J-r cJ|j}t|}d|vxsd|v }|s|j|k(r|S|j|j|j |j |jd}|jjj|S)areturn the rev of the changeset which introduced this file revision This method is different from linkrev because it take into account the changeset the filectx was created from. It ensures the returned revision is one of its ancestors. This prevents bugs from 'linkrev-shadowing' when a file revision is used by multiple changesets. r(r)T inclusive) r2varsr,r-r.r#r%r/r1)rlkrattrsnoctxr3s rintrorevzremotefilectx.introrevnsllnT  E)C]e-CD DHHJ#%J'' JJ MM NN HHJ ( zz##''11r cx|j}||j\}}}}|sy||f}|j|jk(r|S|j }|j}|j j D]} || j|k(ry|S#tj$rY3wxYw)a#check if file was actually renamed in this changeset revision If rename logged in file revision, we report copy for changeset only if file revisions linkrev points back to the changeset in question or both changeset parents contain different file revisions. N) rr%r,r2rr)parentsfilenoder LookupError) rrrCrDr3rErenamednamefnodeps rrUzremotefilectx.renameds&&( %0%@"B(R. 88: 'Nyy{((*A AJJt,,-+ $$  s B##B98B9c4|j}|xr|dS)Nr)rU)rcopys r copysourcezremotefilectx.copysources||~Qr c|js.|jj|j|_|jSr")rrrr%r&s rrzremotefilectx.ancestormaps4  $  : :4>> JD    r c|j}|j}||j\}}}}g}||jk7rW|xs |j}|j |} t |||| |} |j| _|j| ||jk7rS|j}|j |} t |||| |} |j| _|j| |S)N)rrr) r/rr%rr.filerr,r*append) rrrrCrDr3rEresultsrflogp1ctxp2ctxs rrRzremotefilectx.parentsszz&&( %0%@"B(  )tzzD99T?D!d2tE$(88:E NN5 !  ::D99T?D!d2tE$(88:E NN5 !r c|j|}|d|d}}||vr6|||jj|k(r|j|Sy)zBreturns the node for in if content matches rr:N)r@rArBr?) rancrevrFrGrrWancctx manifestnodefiless r_nodefromancrevzremotefilectx._nodefromancrevsZ$Qie  5=Uc,&7&@&@&B&F&Ft&LL776? "r c |j}|jj}|j}|j } | |d} |;|jdj D cgc]} | j } } d}n|g} |j| | r| Sdj| D cgc]} t|j| c} t||tj|jtj|jd}|jjdi||j }d}|j#| |}|D]a}|j%|||||}||cS|r!|j'||t(j*k(sE|j-|||| |}|r|cSd}c| Scc} wcc} w) areturn the first ancestor of introducing If the linkrev of the file revision does not point to an ancestor of srcrev, we'll walk down the ancestors until we find one introducing this file revision. :repo: a localrepository object (used to access changelog and manifest) :path: the file path :fnode: the nodeid of the file revision :filelog: the filelog of this path :srcrev: the changeset revision we search ancestors from :inclusive: if true, the src revision will also be checked Note: This is based on adjustlinkrev in core, but it's quite different. adjustlinkrev depends on the fact that the linkrev is the bottom most node, and uses that as a stopping point for the ancestor traversal. We can't do that here because the linknode is not guaranteed to be the bottom most one. In our code here, we actually know what a bunch of potential ancestor linknodes are, so instead of stopping the cheap-ancestor-traversal when we get to a linkrev, we stop when we see any of the known linknodes. NT )revsrWfilepathuserreponameFrJ) linkrevfixupsadjusting linknode )r/r0r1r=rrRr,_verifylinknodejoinrr?r getusernameui getreponamelog _phasecache ancestorsriphaser public_forceprefetch)rrrrWsrcrevrKrrFrGrr3rXrmr,commonlogkwargspc seenpubliciterancrelnodes rr-zremotefilectx._adjustlinknodes2zz __  ( (&&( u%a( >%)ZZ%5%=%=%?@%?AEEG%?D@I8D   h /OIIDADSs2773<0DABZ++DGG4#//8    PP    ,,ty,9F((S$FE  "((4"8FMM"I++$t_ L! %(SABs ,G.!G cd}tj} |jj|t|fgdd|_|j |d}|j ||rAd}|tj|z } |jjd|dzfd| d zi|Sd } tj|z } |jjd|dzfd| d zi|y#t$rL} d | z}Yd} ~ tj|z } |jjd|dzfd| d zi|yd} ~ wwxYw#tj|z } |jjd|dzfd| d zi|wxYw) Nr T)forcerks#remotefilelog prefetching succeededrq elapsedis#remotefilelog prefetching not founds%remotefilelog prefetching failed (%s)) time fileserviceprefetchrrrrrrurw Exception) rrrrWrmr~logmsgstartr3res rr|zremotefilectx._forceprefetchsT      % %c%j'9&:$ % G !%D '')%03H##D(3?iikE)G DGGKK  $ "  z0remotefilectx._verifylinknode..ps%IDqr}}Xrwwqz:Ds+.)r/r0r1anyrrT)rrmr3rFs `@rrrzremotefilectx._verifylinknode_sS &&(22BIDII I      s8AAAc#Kg}tj|f}t}|r|j}|j |vr%|j |j |j ||j}d}|D]}|s|s|j |d}|r|jdt|dd}|D]} | yw)NTFrc"|jSr")r2)xs rz)remotefilectx.ancestors..s !))+r )reversekey) collectionsdequesetpoprSaddr_rRsorted) r followfirstryqueueseencurrentrRfirstrXrs rryzremotefilectx.ancestorsxs !!4'*uiikG!T) HHW%%' (   W %oo'GE LLO  a9d8MN !HN"s B*C-,Cc |j|jk(r%|j|vr||jS|j|vr%|j|vr||jS|j|vr%|j|vr||jS|j |j fd}|j|jf}|j|jf}tj|||}|r |\}}t |j || } | Sy)Nc|\}}j|xsj|}|sgS|dxs||df||dfgS)Nr:rr )rB)rfnrXamapbmaps rrRz'remotefilectx.ancestor..parentssRDAq *txx{A qTYQ!%1Q4y1 1r )rr)rrrSrgenericancestorrr/) rfc2actxrRabresultrrrrrs @@rrzremotefilectx.ancestors 88: $)< $ $ 99;$ 388:T#9 $ $ 88: $))+T"9 # #!  2YY[$--/ * XXZ ())!Q8 DAqdjj!A4HAHr c|}|jdd}|rf|j}|j|k7rCt|j|j ||j |j|j}g}t}tj|f}|j|j|r|j} | j|jk7r8|j| j!t#| jf|r| |vrr| j%D]E} | j|vs|j| j|j| G|r|jj&j)dt+|z|r%|jj,j/|t1t|f|i|S)N prefetchskip)rrrrs1remotefilelog: prefetching %d files for annotate )rrPr,rr/r.r%r#rrrrrr?rSr_rrrRrudebugrrrrannotate) rargskwargsintroctxrrPfetchrrrparentrs rrzremotefilectx.annotateszz.$7 }}HxxzX%(JJJJ%>> MM $ 1 1 u!!8+. !iikG!T]]_4 gllnc'2B2B2D.EFG< 7!//+;;=,HHV[[]+LL(,   #E  +   JJ " " + +E 2]D2DCFCCr cgSr"r&s rchildrenzremotefilectx.childrens r )NNNNNr")F)__name__ __module__ __qualname__rr$ propertycacher(r5r2r7rPrUr[rrRrir-r|rrryrrr __classcell__rs@rrrs (&2 " "  >2.6 ! 4JXCJ2: D)DXr rc,eZdZdfd ZdZdZxZS)remoteworkingfilectxc@d|_tt|||||yr")rrrr)rrrr workingctxrs rrzremoteworkingfilectx.__init__s$  "D2 $ r c,tj|Sr")rrRr&s rrRzremoteworkingfilectx.parentss$$T**r c|js|j}|jj}|j }|r|}n5||dj j ||jjf}||jjf}t|dkDr5||dj j ||jjf}i}|d|jjk7rT|jj|d|d}|j|jj|d|d|jjk7rT|jj|d|d}|j|jj|dd} |r|d} |d|d|jj| f|d<||_|jS)Nrr )rr )rr.r)_parentsrU _manifestrBr/rrr5updaterr) rrpclrUrCrDmrbrcrEs rrz remoteworkingfilectx.ancestormaps  ::D//**CllnGCF,,00tzz7H7HIJ ))*B3x!|CF,,00tzz7H7HIJA!u ))) **2a5A*?44RU;<!u ))) **2a5A*?44RU;<H"1:!ubeTZZ%6%6AAdG !D    r )NN)rrrrrRrrrs@rrrs +!r r)rrmercurial.noderrr mercurialrrrr r r rFASTLOG_TIMEOUT_IN_SECSr5rworkingfilectxrrr rrsZ ,,"" KGOOK\(!711=(!r