ѐZfddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z m Z mZmZddlmZmZmZddlmZe j,sddlZd Zd Zd Zd.d Zd ZdZd/dZdZdZ dZ!dZ"dZ#dZ$ejJe&e&fejNe&e&fiZ(dZ)dZ*dZ+dZ,Gdde jZZ.dZ/d0dZ0dZ1dZ2d Z3d!Z4d.d"Z5d#Z6d$Z7d%Z8d&Z9d'Z:d(Z;d)Zd,Z?d-Z@y)1N)_)open)hex)errorpycompatrevlogutil)hashutil storageutil stringutil) constantsc:tj|jvS)z>returns whether the repository is remotefilelog enabled or not)rSHALLOWREPO_REQUIREMENT requirements)repos Cusr/lib/python3.12/site-packages/hgext/remotefilelog/shallowutil.py isenabledr"s  , ,0A0A AActtj|j}tj j ||dd|dd|S)Nrr sha1digestospathjoin)reponamefileidpathhashs r getcachekeyr"'sC8==&--/0H 77<<(2A, b AArcttj|j}tj j ||SNr)rr r!s r getlocalkeyr%,s38==&--/0H 77<<" %%rc|jdd}|s!|rytjtdt j |S)N remotefilelogs cachepaths4could not find config option remotefilelog.cachepath)configrAbortrr expandpath)ui allowempty cachepaths r getcachepathr.1sG *L9I  ++IJ  ??9 %%rct|j}|tjk7r,tj j ||jd|Stj j ||jdSNspacks)r.r+rFILEPACK_CATEGORYrrrname)rcategoryr-s rgetcachepackpathr4=sVTWW%I9...ww||Ityy(HEEww||Ityy(;;rcDtjj|d|Sr0)rrr)baser3s rgetlocalpackpathr7Es 77<<h 11rcti}|s|jdr"|r ||d<||d<tj||}|S)zRreturns a string that matches the revlog contents in a traditional revlog  scopyscopyrev) startswithr packmeta)textcopyfromcopyrevmetas rcreaterevlogtextr@IsD D4??7+ $DM&D ##D$/ Krctj|\}}|jdr|jdd}||dzd}|xsi|fS)z parse mercurial filelog metadatar9rN)r parsemetar:index)r<r?sizess rrBrBWsP&&t,JD$ w JJw "AEG} :2t rctjd}|D]'}|jD]\}}||xx|z cc<)|S)zAdds all the values of *dicts together into one dictionary. This assumes the values in *dicts are all summable. e.g. [{'a': 4', 'b': 2}, {'b': 3, 'c': 1}] -> {'a': 4, 'b': 5, 'c': 1} cyNrrIrrzsumdicts..fsQr) collections defaultdictitems)dictsresultdictkvs rsumdictsrS`sF  $ $Y /FJJLDAq 1INI! MrcJi}|jD] \}}||||z<|S)z;Returns ``dict`` with ``prefix`` prepended to all its keys.)rM)rPprefixrOrQrRs r prefixkeysrVms. F 1vz Mrc|Dcgc]}|j}}tt||dz}|j|dzdfit j |ycc}w)N_s _packsizes ) getmetricsrVrSlogr strkwargs)r+rUstoresrErNrPs rreportpackmetricsr^us[%+ ,VQ\\^VE , h& 6D BFF6M !5EH,>,>t,DE -sAci}d}t|}||z dk\rZ|||dz}|dz }tjd||d}|dz }||z|kDr td||||z}|||<||z }||z dk\rZ||k7r td|S)aparse datapack meta, bytes () -> dict The dict contains raw content - both keys and values are strings. Upper-level business may want to convert some of them to other types like integers, on their own. raise ValueError if the data is corrupted rr !Hrs%corrupted metadata: incomplete buffers"corrupted metadata: redundant data)lenstruct unpack_from ValueError)metabufmetadictoffsetbuflenkeymetalenvalues r_parsepackmetarm{sH F \F 6/Q fvz*! $$UGV?? OrcBd}t|xsijD]|\}}t|dk7rtjd|zt|dkDrt dt|z||z }|t jdt|z }||z }~|S)anreverse of _parsepackmeta, dict -> bytes () The dict contains raw content - both keys and values are strings. Upper-level business may want to serialize some of other types (like integers) to strings before calling this function. raise ProgrammingError when metadata key is illegal, or ValueError if length limit is exceeded rr spackmeta: illegal key: %sis)metadata value is too long: 0x%x > 0xfffera)sortedrMrbrProgrammingErrorrercpack)rgrfrQrRs r_buildpackmetarrsGB--/01 q6Q;(()E)IJ J q6F?d}t|D] }|dz}||z}|S)z=the reverse of int2bin, convert a binary buffer to an integerrr)r)rxbs rrrs. A s^ a Q HrceZdZdZy)BadRemotefilelogHeaderz@Exception raised when parsing a remotefilelog blob header fails.N)__name__ __module__ __qualname____doc__rIrrrrsJrrcftj}d} |jd}|d|}|j dr|j dr|j dD]}|j tjr&t|ttjd}H|j tjsht|ttjd}nt d|zt|}| t d|d z||fS#t$r t dwxYw) zgiven a remotefilelog blob, return (headersize, rawtextsize, flags) see remotefilelogserver.createfileblob for the format. raise RuntimeError if the content is illformed. Ns/unexpected remotefilelog header: illegal formatvsv1 rYs$unsupported remotefilelog header: %ss.unexpected remotefilelog header: no size foundr ) rREVIDX_DEFAULT_FLAGSrCrerr:splitr METAKEYSIZErxrbry)rawflagsrDrCheaderrEs rparsesizeflagsrs,  ' 'E D  %  %[F    W %\\%(<< 5 56qY%:%:!;!=>?D\\)"7"78#i&;&;"<"> ?@E ) )7&@  6{ |$ =   19dE !!1  $ >   s DD0c|tt|}|dk(r'dtj|tj|fz}|S|dk(r|rt j dd|z}|St j d|z)zreturn the header of a remotefilelog blob. see remotefilelogserver.createfileblob for the format. approximately the reverse of parsesizeflags. version could be 0 or 1, or None (auto decide). r s v1 %s%d %s%drs!fileblob v0 does not support flags%dsunknown fileblob version %d)rxboolrrryrrp)rDrversionrs rbuildfileblobheaderrsd5k"!|"  ! !   ! !  &   M A (()MN N M$$%Cg%MNNrct|\}}}||z}i}|t|krc|jd|dz}|||dz}||dz|dz}||dz|dz} ||dz|dz} ||dz|} || | | f||<|dz}|t|krc|S)NrP(<r )rrbrC) rrhrDrstartmappingdivider currentnodep1p2linknoder=s r ancestormapr.s(-FD% TMEG #c( ))E52:.%52:/ %"* - %"* - urz3 g. "B(; !  #c(  Nrct|d} |j}|s#tj|t d|z||j S#|j wxYw)Nsrbsempty file: %s)rreadrremoveIOErrorclose)rfrOs rreadfilerBsU T5A  IIdO+d23 3   s 6AA'ctjr$tj|tj tj |yr$)r iswindowsrchmodstatS_IWUSRunlink)filepaths r unlinkfilerQs) 4<<(IIhrcHtjr|tj|tj tj j|r9tj|tj tj|tj||yr$) rrrrrrrisfilerrename)source destinations r renamefilerXs[ & 77>>+ & HH[$,, / IIk "IIfk"rctjj|\}}tjj|s tj|t jd|z|\}}tj| tj|d}|j||j|rd}n-tjd} tj| | }t||tj||y#t $rYwxYw#t$r t!|#t"$rYwxYwwxYw)Ns.%s-)rUdirswbi$r)rrrexistsmakedirsFileExistsErrortempfilemkstemprr posixfilewriteumaskrr ExceptionrOSError) rcontentreadonlydirnamefilenamefdtemprmodeoldumasks r writefilerds d+GX 77>>' "  KK w'9wGHBHHRL NN4 '   Dxx{H HHX 9D4 t/   0   t      sCD B D& D#"D#& E 0 D<;E < EE EE ct|}i}i}g}|D]n}||Dcgc] }||vs| }}t|||<|D]+}|j|tj|-|r^|j|p|j g}|rl|j d}|j|||vrC||} | D]9} || } | j |t| dk(s(|jd| ;|rl|Scc}w)zUTopologically sorts the nodes, using the parentfunc to find the parents of nodes.r) set setdefaultaddappendsortpoprrbr) nodes parentfuncchildmap parentmaprootsrpparentsresultschildrenc childparentss r sortnodesrs JEHI E(m:mqEz1m:7| ! A   35 ) - -a 0 LLO  JJLG  IIaLq ={H(| ##A&|$)LLA&  N1;s DDc|j|}t||kr,tjt dt||fz|S)z=read n bytes from stream.read and abort if less was availables5stream ended unexpectedly (got %d bytes, expected %d))rrbrr)r)streamrrEs r readexactlyrsK AA 1vzkk F G1vqk    Hrclt|tj|}tj||Sr$)rrccalcsizeunpack)rfmtdatas r readunpackrs( vvs3 4D ==d ##rct|tj}tjtj |d}t||SrH)rr FILENAMESIZErcrFILENAMESTRUCT)rrawlenpathlens rreadpathrs< !7!7 8FmmI44f=a@G vw ''rc#Kt|tj}tjtj |d}t |D]}t|tj ywrH)rr NODECOUNTSIZErcrNODECOUNTSTRUCTrangeNODESIZE)rr nodecountis r readnodelistrsU !8!8 9F i77@CI 9 &)"4"455sA/A1c#Kt|tj}tjtj |d}t |D]}t|ywrH)rr PATHCOUNTSIZErcrPATHCOUNTSTRUCTrr)rr pathcountrs r readpathlistrsM !8!8 9F i77@CI 9 vsA A"c tjtj|j}|S#t $rYywxYwr$)grpgetgrnamrfsdecodegr_gidKeyError) groupnamegids rgetgidr s=ll8,,Y78?? s36 AAc|y tj|d|tj|dy#ttf$r'}|r|t d||fzYd}~yYd}~yd}~wwxYw)Ns unable to chown/chmod on %s: %s )rchownrrrr)rr warnexs rsetstickygroupdirrsg {G r3 v W G  78D":E F F Gs-3A)A$$A)cd}|jdd}|r*t|}||jtd|zd} t j |}|r9|jdzdk7s|j|k7rt|||jyt jd} |g}tjj|}|rqtjj|sR|j|tjj|}|r tjj|sRt|D]} t j ||D]}t|||j t j|y#t $rYMwxYw#t"$rYkwxYw#t j|wxYw)ziCreates the given directory (if it doesn't exist) and give it a particular group with setgid enabled.Nr's cachegroups!unable to resolve group name: %s rr)r(r rrrrrst_modest_gidrrrrrrreversedmkdirr)r+rr r str missingdirss rmkstickygroupdirrs C *M:IY ; GGA; dC 1xxHf wwt$277>>$/   t $77??4(D277>>$/[)D *  D dC 1  7    *#   sIF*BF9?F9F*# F9 F'&F'* F63F95F66F99Gch tj|jS#t$rYywxYw)Nunknown)r shortuserusernamer)r+s r getusernamer!s0##BKKM22 s "% 11cj|jdd}|rtjj|Sy)Nspathssdefaultr)r(rrbasename)r+rs r getreponamer$s-yy:.Hww)) r)F)NNr$)ArKrrrcrmercurial.i18nrmercurial.pycompatrmercurial.noder mercurialrrrr mercurial.utilsr r r rrrrr"r%r.r4r7r@rBrSrVr^rmrrryrxrrtr}rrzr StorageErrorrrrrrrrrrrrrrrr rrr!r$rIrrr,s6 #  B B & &<2  F 66C: C: #*  KU//K""J6(  #"J"J $ ( 6G)Xr