^cY dZddlZddlZddlZddlmZddlmZmZddl m Z m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZmZd d lmZmZejZe j Ze d d d deddfdddedfgeddddZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)d.d Z*d/d!Z+d"Z, d0d#Z-e d$d%d&ged'fge j.zed(d1d*Z/e d+ge j.zed,d-Z0dS)2z=High-level command function for lfconvert, plus the cmdtable.N)_)binhex) cmdutilcontexterror exthelperhglock logcmdutilmatchpycompatscmutilutil)hashutil)convcmdfilemap)lfutil storefactorys lfconvertssizes9minimum size (MB) for files to be converted as largefilessSIZEs to-normalFs/convert from a largefiles repo to a normal repos#hg lfconvert SOURCE DEST [FILE ...]T)norepo inferrepoc  tj|}|drd}n-d}tj|d|dd}t j|s$tjtd|zt j|s$tjtd|zt j ||| td|zt j ||d }d}dx} } fd j dd D} j|ji} |rB|} |} t%} t%}|s |tjd }|r)t+jjd t1|}nd}i}|tdtdd5}| D]@}||t9||| | |||| A dddn #1swxYwY|jtjr$|j tj|!D]y}|j"|r|j#| |j$|j%|j#tL$rYvwxYw| r.|j'(dtSj*|nGfddtVj,GfddtZj.t_|\}}|d kr!tjtdtZj.}tZ_. t[j0|||dd|tZ_.n#|tZ_.wxYwd}|r)|j12tg| | |stij |jdSdS#|r)|j12tg| | |stij |jwwxYw)aMconvert a normal repository to a largefiles repository Convert repository SOURCE to a new repository DEST, identical to SOURCE except that certain files will be converted as largefiles: specifically, any file that matches any PATTERN *or* whose size is above the minimum size threshold is converted as a largefile. The size used to determine whether or not to track a file as a largefile is the size of the first version of the file. The minimum size can be specified either with --size or in configuration as ``largefiles.size``. After running this command you will need to make sure that largefiles is enabled anywhere you intend to push the new repository. Use --to-normal to convert largefiles back to normal files; after this, the DEST repository can be used without largefiles at all.s to_normalFTrN)defaults %s is not a local Mercurial reposinitializing destination %s )createc3(K|] }|V dSN).0ctxrsrcs =/usr/lib/python3/dist-packages/hgext/largefiles/lfcommands.py zlfconvert..qs;   I      rrspatternsrsconverting revisionss revisionsstipunittotals largefilesc0eZdZfdZfdZxZS)lfconvert..lfsourcect|||dd|jjtj<dS)N.)super__init__ filemapperrenamer shortname)selfuisource __class__lfsources r&r0z$lfconvert..lfsource.__init__s=(D))222vtDDD?CDO*6+;<<.lfsource.getfiles(+%Hgh--55dC@@A%//0EFF!Q4< Q4::<.convertercn ||}t||||||dSr!)r/r0) r4r5r6dest revmapfileoptssrcr7 converterr8s r&r0z%lfconvert..converter.__init__sK"(2v..C)T**33Cz4r)rHrIrJr0rK)r7rSr8s@r&rSrMsCrrSs&all largefiles must be present locallyshg) source_type dest_type)5r byteskwargsr getminsizegetr islocalrr?r repositorystatus changelog nodesbetweenheadsnullidwlockr set configlistlongnamematchmodr rootlist makeprogressrBupdate_lfconvert_addchangesetwvfsexistsr3rmtreekeysisfileunlink removedirsdirnameOSError requirementsaddrwritereporequirementsrfilemap_sourcerrSdownloadlfilesconvertdirstateclearreleaseshutil)r5rRrOpatsrQtolfilesizerdstsuccessdstwlockdstlockctxsrevmaplfiles normalfilesmatcher lfiletohashprogressr$rEfoundmissingorigrSr8r%s @@@r& lfconvertr2sP   % %D LL T488G+<+>>>D  4!%%m444-d333 5 5 5 5 5 5 5 571 5 5 54        G-   ,B55NE7!||k!$M"N"NOOO$D )G  )Tu%)!!D!((((  ' M   ! ! ! GX & & & % M$) $ $ $ $ $ % %  ' M   ! ! ! GX & & & % M$) $ $ $ $ %sqD/R6AJ R6JR6J BR662M)(R6) M63R65M66B|}|r(||vr$tjtd| ztjd}|| t%|}| vs | |kr|| | | d| v}tj|||||| <w| | fd}t-|| | |dS)NFls+renamed/copied largefile %s becomes symlinkslargefile %s becomes symlinkrxc tj|}| |}n#tj$rYdSwxYw|}|rtj|}tj||||dzd| vd| v|St||S)N rr) r splitstandinfilectxr LookupError copysourcestandinr memfilectxflags_getnormalcontext) repomemctxrEsrcfnamefctxrenamedr$rrs r& getfilectxz+_lfconvert_addchangeset..getfilectx#s&q))   {{8,,$   tt oo''G 2!.11%H%- $ $ %T36:: :s/AA)_convertparents_getchangedfiles_islfilemanifestrrrrr?rrtrrappendrsha1rhdatardigestwwrite writestandin_commitcontext)r%rr$rrrrrrparentsfilesdstfilesrEislfilerr renamedlfilefstandinmrF executablers `` ` r&ririsc6**G S' * *EH 22 F??q 33q#w55GCLLNN""{{1~~//++?$G&<7f+< <'4::<<''##kLMM $G # 1 """ ;;~a((H OOH % % %CLLNN""{{1~~4::<<''"oo//G7f#4#4#k=>>B M#&&Q'''188::K'';q>T+A+AKK3q6;;==#a&,,..AAA!%Q!7J'hjIII%)KN OOA    ;;;;;;;84#xVDDDDDrc tj||||||||}||}tj||| ||j || <dSr!) rr descriptionuserdateextra commitctxrcopyalltostore setparentsr\tipnode)rrr$rrrmctxrets r&rrBs >         D ..  C $$$$OOC++--F388::rcRt|}|j|vrj|}|D]A}||D]}||B|Sr!)rarrr_rrdiffrt)r$rrmcpctxfns r&rrTs   E xxzz'' \\^^KKMM  Dmmoo**2..   "   Lrc6g}|D]/}|||0t|dkr?||jt|dk?|S)Nr)rrrlenrr_)r$rrps r&rr_sG [[]]))vaffhh'(((( g,,  sxxzz())) g,,   Nrc h ||}n#tj$rYdSwxYw|}|}|dkrt |j||}tj||||d| vd| v|S)N.hgtagsrr) rrrrr _converttagsr5rrr)rr$rErrrrs r&rris{{1~~  ttooG 99;;DJDGVT22   c1dDDJJLL0$$**,,2F  s ++c\g}|D]} |dd\}}n5#t$r(|t d|zYOwxYw t |}n:#t j$r(|t d|zYwxYw |dt|||fz#t$r(|t d|zYwxYwd |S)N rs&skipping incorrectly formatted tag %s s%skipping incorrectly formatted id %s s%s %s sno mapping for id %s r) splitlinessplit ValueErrorwarnrrbinasciiErrorrrKeyErrorjoin)r5rrnewdatalineidrAnewids r&rrysVG!! zz$**HB    GGA@AADH I I I H  GGEE~    GGA?@@2E F F F H   NN:VE]););T(BB C C C C    GGA/0025 6 6 6 H  88G  s35/A'&A'+A;;4B21B26-C$$/DDc|dks |dks|dkrdS|r ||rdS |||dzdzkS#tj$rYdSwxYw)zlReturn true if file should be considered a largefile, i.e. matcher matches it or it is larger than size.rs .hgignores.hgsigsFTi)rrrr)filer$rrs r&rrs zT\11TZ5G5Gu774==t{{4  %%''4$;+===  uus0AA)(A)c |sdStj||d}d}|dt|z|| fd|D}|dt|z|t dt d t| 5}|D]m}||tj ||}|s$tj t d |z| |||d z }n ddddS#1swxYwYdS) z&upload largefiles to the central storeNT)putrs,sending statlfile command for %d largefiles c$g|] }| | Sr"r")r#hretvals r& z uploadlfiles..s" / / /1VAY /Q / / /rs"%d largefiles need to be uploaded suploading largefilessfilesr(s6largefile %s missing from store (needs to be uploaded)r) r openstoredebugrrkrgrrhrr>rr?r) r5r%rrstoreatrrFr6rs @r& uploadlfilesrs   "44 8 8 8E BHH =E JKKK \\% F / / / / / / /EHH 3c%jj @AAA  !""8CJJ      D OOB   _T400F k3  IIfd # # # !GBB s A1E  EEc|r|d}ndg}tj|}|||S)a)Verify that every largefile revision in the current changeset exists in the central store. With --contents, also verify that the contents of each local largefile file revision are correct (SHA-1 hash matches the revision ID). With --all, check every changeset in this repository.sall()r.)contents)revsrrverify)r5rallrrrs r& verifylfilesrsL  yy""v  "4 ( (E <<x< 0 00rctj||}|rt|t|z}g}||}|D]l} tj|tj|}n#t $rYrrrrX) r5rrfilelistrtogetr$lfile expectedhashrrs r& cachelfilesrs tT * *F-Vs8}}, E t*C00 !/FN54I4I0JKKLL     H t\22 0 LL%. / / / &t,,ii 8Os,A33 B?Bc|jj}d}d}|ddtjzD]C}t ||||\}}|t |z }|t |z }D|td|z|dkr%|td|z||fS)Nrsfile(%s)spath:s %d additional largefiles cached s!%d largefiles failed to download ) r\rrrr3rrr[r)r5rtonode totalsuccess totalmissingrBrrs r&rwrws ^ FLLyyh1A&ABB%%&r4==G $ G $ IIa455 DEEEa !9::\IJJJ  %%rc N tj|||}|5tj||}t tj|t |z}t fd|D}|5i}t d\} } |j} |d} |D]} tj tj ||| |j }tj| }tj tj ||||j }| |r | |re| | rPt!j| | | || |tj| |}|dkrn| | vrL|j|jr| | dn| || ddd||| <| | r6|j| | vr| | | d z }  dddn #1swxYwY|||rfd |D}D]H}|jtj||j|I|t?d tA||d||5|D] } d }|!| }|r1tj"||| s3|| dd d }tj| }| |rz| #|j$dz}| #| }|j$}||dzkr8|dz}|r||dz dztJj&zz}| '| |d }| |z } tj(||| | dddn #1swxYwY|||r|t?d| | fzddddS#1swxYwYdS)zUpdate largefiles according to standins in the working directory If ``printmessage`` is other than ``None``, it means "print (or ignore, for false) message forcibly". Ncg|]}|v| Sr"r")r#rErs r&rz updatelfiles..s999A1==a===r)rr)startrT) ignoremissing) p1_tracked wc_trackedpossibly_dirtyrcg|]}|v| Sr"r")r#rEdroppeds r&rz updatelfiles..<s#<<rAskDC                           %$$$$$ #""""""" ,Y    AJ K K       A@ A A  A,-- ' *[%[%+*[%|ZEZEZEz...$    *   B 1 1 1 1: & & &>Cxxxxv  FB@AABC A677  !8!8!8  !8HM2 22AAgJJ??  @?   r