F)StddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z'm(Z(m)Z)m*Z*m+Z,m-Z.ddl/m0Z1ddl2m3Z3m4Z4m5Z5ejlZ6d Z7d2d Z8d Z9Gd d Z:ee(e:dZ;eee$e%dZgZ?d4dZ@ d5dZ0 d6dZAdZBdZC d7dZDdZEdZFd4dZGd4dZHdZI d8dZJdZK d9dZLd2d ZMd4d!ZNd:d"ZOeOZPd;d#ZQeQZRejejejejhZWd:d$ZX dz1addbranchrevs..primary..fsD(C1A(CsTF)rAbortrdirstatebranchextendreversed)r7 branchmaplreporevss r3primaryzaddbranchrevs..primary`s^ T>kk!$E"FGG^^**,F Y  KKD61B(CD Dsunknown branch '%s') r" safehasattrr+listcapablerr5rappendcommandexecutor callcommandresultRepoLookupError) r;otherbranchesr<r,r+ hashbranchxyer=r7r:s ` ` @r3 addbranchrevsrMDsF v&zz|z4#J h LD QA!t A!t  Dz << % ++a EFG G JT!W}   1MM,3::<   v''*@(AF(JK Kz" KK # a=) s 8!D::Ec tj|}tj|jS#t$r=}t j |}tjtd||fzd}~wt$rYywxYw)Nsinvalid path %s: %sF) osstatS_ISREGst_mode ValueErrorr' forcebytestrrr5rOSError)pathstrLmsgs r3_isfilerYtsw ( WWT]||BJJ'' C%%a(kk!23tSkABB s6 B8A77 BBc:eZdZdZededefdZedZy) LocalFactoryz:thin wrapper to dispatch between localrepo and bundle reporVreturncjtjtj|}t | Sr0)r" expandpathr( urllocalpathrYrVs r3islocalzLocalFactory.islocals(w33D9:4=  r>ctjtj|}t |rt }nt }|j||g|i|Sr0)r"r^r(r_rYr rinstance)rrVargskwargsclss r3rczLocalFactory.instancesIw33D9: 4=CCs||B6t6v66r>N) __name__ __module__ __qualname____doc__ staticmethodbytesboolrarcr>r3r[r[s9D!e!!!77r>r[)bundlesunionfile)shttpshttpssshs static-httpct|trtj|}|jxsd}|t vrt |}|j n$|tvrt|}|jnt}tj|dr|j|Sy|jjdd|jS)z7return true if repo (or path pointing to repo) is localrpraFs'use obj.local() instead of islocal(obj)s6.4) isinstancerlr(r!scheme peer_schemes make_peer repo_schemesrcr[r"r?rar deprecwarnlocal)repourtrfs r3raras$ KK $W \ !v&C MM | #v&C LLC   C +;;t$ $GGA6J ::<r>ctj|dd}|jr$tj|j dStj |||S)z0open path with open if local, url.open if remoteF) parsequery parsefragmentsrb) sendaccept)r(r!rar" posixfile localpathopen)rrVrpathurls r3openpathrsKkk$5FG~~g//1599xxDZ88r>cDt|d|}|xsgD] }||| |jddtjd5}t j|D]f\}}|jdd|t|dd}|s)tjd|5}|||dddd} |jd| |h ddd|jdd |j st D] }||| yy#1swYcxYw#1swYNxYw) Nrs extensions- executing reposetup hooks z all reposetups - running reposetup for %s reposetupz reposetup %rs > reposetup for %s took %s s> all reposetup took %s )rlogr"timedcmrrywirepeersetupfuncs) robj presetupfuncsfallreposetupstatsnamemodulehookstatsrXs r3_setup_repo_or_peerrs dB B  b  "c !FF<9: o &*;&11"5LD& FFDD D ( D D DDc>tj|j}|d}tj |}|/|t vr!t jtd|zt}|j|||||}t||||jdS)z1return a repository object for the specified pathrpsrepository '%s' is not localintents createopts)rsvisible) r(r!rtrwgetrurr5rr[rcrfiltered) rrVcreaterrrrtrfrzs r3r%r%s[[  % %F ~   6 "C { \ !++a ?@4GH H <<    DD > == $$r>ct|d|}t||}tj|dr|} nt j |d|d} | j j} | tvr.t| } | j|| ||||} t|| | S| j} | s | j} t|| |||}|j| |} | S) z/return a repository peer for the specified pathrr!NF)rawloc validate_path)rrr,r)rVr,)rremoteuir"r?r(rVr!rtrurvrlocrr%r+)uiorrepooptsrVrrrr,rrui peer_pathrtrfr+ repo_pathrzs r3r+r+s 4 *B 8T "C e$ LLT$eL ]] ! !F 6"}}   !%   C& KMM !((I   !  yyilyC Kr>ctj|j}|sytjj tjj |S)a9return default destination of clone if none is given >>> defaultdest(b'foo') 'foo' >>> defaultdest(b'/foo/bar') 'bar' >>> defaultdest(b'/') '' >>> defaultdest(b'') '' >>> defaultdest(b'http://example.org/') '' >>> defaultdest(b'http://example.org/foo/') 'foo' r>)r(r!rVrObasenamenormpath)sourcerVs r3 defaultdestr"sB ;;v  # #D  77  BGG,,T2 33r>cP|j|jk(rytj|dr|jr |jS|j j |jd}tj|\}}t|j|}||_|S)z}Returns repository object for source repository of a shared repo. If repo is not a shared repository, returns None. Nsrcrepor) sharedpathrVr"r?rr$splitr(parseurlr%r)rzrsrcurlrHrs r3sharedreposourcer8s  $))# i(T\\||XX^^DOO ,Q /F''/FH&)GDL Nr>c td}tj|dr%|j5t j |t |st j ||s t|}n tj||j}t|trLtj||}t||j} |jgf} t| | | d\} } n|j} d} t!} |r| j#t$t||d| || d}t'| ||t||}t)||| |S) zcreate a shared repositorys!can only share local repositoriesryNT)s sharedrepossharedrelatives shareditemsrr) defaultpath)checkout)rr"r?ryrr5rarr(get_clone_path_objrrsrlr%r7rMsetaddsharedbookmarks postshare_postshareupdate)rrdestupdater rrelative not_local_msg source_pathrrHrevr shareditemsr2s r3sharerKs7:;M ( <<> !++m, , V_kk-(( 6"))"d377&% 00V< R1&&+%gw$G X,,.%K(  "'' Agqk22tAQ2 Hr>ctj|j}tj|j}|j dsyd}|j dr|j d}|dd5}|j d}|j d|j ||j d|j |dddy#1swYyxYw)zcopies the source repo config and prepend it in current repo .hg/hgrc on unshare. This is only done if the share was perfomed using share safe method where we share config of source in shareshgrcNr>swbs## Config copied from shared source  )vfsmodr$rrVexistsreadwrite)rzsrcvfsdstvfs currentconfigfp sourceconfigs r3_prependsourcehgrcrsZZ (F ZZ "F == !M }}W G,  2{{7+  89     s >ACC&cJ|j5t|||j}|xstj5t j |j vr t||jjd}tj||dz|j jt j|j jt jtj|ddddddt!|j"|j$d}|d}|j&}t)|D]!}|j+|j-#t/j0||S#1swYxYw#1swYxYw)aconvert a shared repository to a normal one Copy the store data to the repo and remove the sharedpath data. Returns a new repository object representing the unshared repository. The passed repository object is not usable after this function is called. s sharedpaths.oldNF)rr.)r copystorerVr"nullcontextmanagerrSHARESAFE_REQUIREMENTrr$joinrenamediscardSHARED_REQUIREMENTRELATIVE_SHARED_REQUIREMENTrwritereporequirementsr%baseuirootsubstatesortedsubunsharerpoisonrepository)rrzdestlock sharefilenewrepocsubsss r3rrs8  Rtyy1  2002 211T5F5FF#4( m4I KK 9w#6 7    % %l&E&E F    % %l&N&N O  ) )$ /3 .dii>G  A ::D D\ at$ N93 2 s$0FCF F F FF"c|xs|jjdd}|r4d}|jjdt j ||zt j|j vrb|j5|j5|jd5tj|dddddddddyy#1swYxYw#1swYxYw#1swYyxYw)aACalled after a new shared repo is created. The new repo only has a requirements file and pointer to the source. This function configures additional shared data. Extensions can wrap this function and write additional entries to destrepo/.hg/shared to indicate additional pieces of data to be shared. pathsdefaults[paths] default = %s rs narrow-shareN) rconfigr$rr" tonativeeolrNARROW_REQUIREMENTwlockr transactionrcopytoworkingcopy) sourcerepodestrepordefaulttemplates r3rrsGZ]]11(JGG- 7D$4$4X5G$HI&&**A*AA ^^ x}}0D0D 1   ( ( 21   B1 1   s<C.C"&C<C"C.C C""C+ 'C..C7c|sy|jjtd|dur|}|ddfD]}| |j|}nt |y#tj $rY=wxYw)zMaybe perform a working directory update after a shared repo is created. ``update`` can be a boolean or a revision to update to. Nsupdating working directory Trtip)rstatusrlookuprrF_update)rzrrtestuprevs r3rrs GGNN1456 T:v. <  KK%E  / D%$$   sAA10A1cd} d}|r tdn td}|j|td5}d}|j}tj|j } tj|} |j jD]} |r| jdrtjj| } | r"| j| s| j| | j| sl| jdr6tjj| d } tj| | }t!j"| j| | j| ||\}}||z }|r|j%d |zn|j%d |zddd|S#1swY|SxYw#t'|xYw) zGcopy files from store of srcrepo in destpath returns destlock Nslinkingscopyingsfiles)unitr phaserootssdataslockslinked %d files scopied %d files )r makeprogress publishingrr$rstorecopylistendswithrOrVdirnamermkdirrrr" copyfilesdebugrelease)rrdestpathrhardlinktopicprogressnum srcpublishingrrrdstbaselockfilens r3rrs H!)* q} __U8_ 5C#..0MZZ 2 23FZZ)F]]++- QZZ %>''//!,6==#9LL)==#zz'*#%77<<#A#'99VX#>"&.. A A(#KHa1HC. -34-34162362 s06GC GB2G9 GG G GGc dd} |r|jdstjtdg} |D]L} |j 5} | j | j dd| ijdddN| } tjj|} tj|dtj|}tjj!|}t#j"|d|z5tjj%|r|j'td|zn0|j'td|zt)||||d |d| dddt+|r)tj,t/j0|}n|}t3|| }t5|||dd| }t7j8||| t;|||t=|||fS#1swYxYw#t$rYcwxYw#1swYxYw)aPerform a clone using a shared repo. The store for the repository will be located at /.hg. The specified revisions will be cloned or pulled from "source". A shared repo will be created at "dest" and a working copy will be created if "update" is True. NlookupXsrc repository does not support revision lookup and so doesn't support clone by revisionkeyFs%s.locks-(sharing from existing pooled repository %s) s((sharing from new pooled repository %s) T)rpullr<rstreamr`)rrr r)heads)rArr5rrCrBrDrErOrVrr"makedirFileExistsErrorrr$rrrrcloneraabspathr(r_r%rrrrr+)rpeeropts sharepathrsrcpeerrrrrrr< remoterevsr2rLpooldirpoolvfsrr sharerepors r3clonewithsharer"s& D y)++1  A((*a!!MM!"A fh +*ggooi(G  We$jj!Gww *H 7J1 2 77>>) $ IICDxO  II>?(J    30vll7#7#7#?@  2I.I   H MM(G40Xv& DXt, ,,O+*"    3 2s+ 2H )H A.H& H  H#"H#&H/cN|jj|}tjj||}tjj |rKtjj |stj |t j||yy)z8copy a cache from srcrepo to destcachedir (if it exists)N)cachevfsrrOrVrrr"copyfile)r dstcachedirfnamesrcfnamedstfnames r3 _copycacher*sk$$U+Hww||K/H ww~~hww~~k* HH[ ! h) r>c t|trjtj||} | t ||d}dx}}d|xsgf}n{t ||| }| j }| j |xsgf}| j}nCtj|dr|j }n|}d|xsgf}|jx}}dx}x}x}}d} t||||\}}|+t|}|rE|jtd|zn'tj||}| |j }nd}tj|}tj|}|st!j"tdt%j&|d}|j)rb|j+s!t!j"td|z|j-r!t!j"td |zi}d }| t/j0| d}| t/j0| d}|r | r| sd h} d|d <| rd|d <|j3drPd|d<dt5j6vr|jtdn|jtd| xsi} | j9d}| j9d}|rt;|rd}|dk(r |j=5}|j?dddijA}dddtBjDk7r*tFjHjK|tM|}n|jtdnq|dk(rKtFjHjK|tMtQjR|jU}n!t!jVtd|z|r|jtdd}|rptY|||||||||| t[||||t]j^|d||ja|r"|jc|jaSSS|jc} |}!t;|r(tjdtj|}!t;|ratFjHjg|r@tFjHjitFjHjK|d}"|"}n|}d }#| r8| jkr(t;|rtmjn| s| xr| }#|rd }#|#r | jqd }|#rL| jud dd!"tj|}$twjx||| }%twjz||$|%#twj|||$}&|&j}|&jq}d$d%l@mA}'|'j| |&t | ||}tj||jc_Etj||jc_F|&j|jc_G| jud&d!| jj'n* t | xs|||d|(}|r|j3dst!jVtd)g}(|D]L})|j=5}|(j|j?dd|)ijAdddN|(}|d*}nd}|jc}*|*r|rs|*j5|*jq5|*jd+5|*j| | t/j|*dddddddddtj|!}+t|+},|*jjd,d-|,d!|s|rd }nd}d.di}-|*jj|-d!5tj|*|||| | | /dddnr| rR|rt!jVtd0tj| ||| jj1nt!jVtd2d}|jc}&|&rtjd3}.tj|!}+d|+_Yt|+},|&j&jd4tj|.|,z|&jjd,d-|,d!|jd5d6rtj|&||r|dur;|j=5}|j?dd|ijA}dddd}/d}0|ft|d7k(r||&vr|}/nQtj|&|r%tj|&|j}/n|dur |&j|}/|/} |&jr(|&j|&j}/|&j}n|&jd8}/d8}|&|/j }1|1d-k(rtd9|z}0ntd:||1fz}0|0s!|&|/j }1td<|1z}0|&jj|0t|&|/||&jvrtj|&|| t[|| t[||&jq5|&jtj=dddt[||||t]j^|d||ja|r |jc|ja||fS#1swYxYw#t jN$r|jtdY^wxYw#t jr$rd }#YwxYw#t$r$d}t!jVtd|zwxYw#1swYxYw#1swYxYw#1swYxYw#1swYxYw#1swYxYw#1swYxYw#t jN$rYwxYw#t$rA |&jd-}/n*#t jN$r|&jd;}/YnwxYwY\wxYw#1swYxYw#t[||||t]j^|d||ja|r"|jc|jawwwxYw)>aMake a copy of an existing repository. Create a copy of an existing repository in a new directory. The source and destination are URLs, as passed to the repository function. Returns a pair of repository peers, the source and newly created destination. The location of the source is added to the new repository's .hg/hgrc file, as the default to be used for future pulls and pushes. If an exception is raised, the partly cloned/updated destination repository will be deleted. Arguments: source: repository object or URL dest: URL of destination repository to create (defaults to base name of source repository) pull: always pull from source repository, even in local case or if the server prefers streaming stream: stream raw data uncompressed from repository (fast over LAN, slow over WAN) revs: revision to clone up to (implies pull=True) update: update working directory after clone completes, if destination is local repository (True means update to default rev, anything else is treated as a revision) branch: branches to clone shareopts: dict of options to control auto sharing behavior. The "pool" key activates auto sharing mode and defines the directory for stores. The "mode" key determines how to construct the directory name of the shared repository. "identity" means the name is derived from the node of the first changeset in the repository. "remote" means the name is derived from the remote's path/URL. Defaults to "identity." storeincludepats and storeexcludepats: sets of file patterns to include and exclude in the repository copy, respectively. If not defined, all files will be included (a "full" clone). Otherwise a "narrow" clone containing only the requested files will be performed. If ``storeincludepats`` is not defined but ``storeexcludepats`` is, ``storeincludepats`` is assumed to be ``path:.``. If both are empty sets, no files will be cloned. Nr>r+sdestination directory: %s s#empty destination path is not validT)r^sdestination '%s' already existssdestination '%s' is not emptyFspath:.s narrowfilessshallowfilestores lfs-serveslfsse(remote is using large file support (lfs), but it is explicitly disabled in the local configuration) sT(remote is using large file support (lfs); lfs will be enabled for this repository) spoolsmodesidentityrr0s7(not using pooled storage: remote appears to be empty) sA(not using pooled storage: unable to resolve identity of remote) sremotesunknown share naming mode: %ss1(pooled storage not supported for narrow clones) )rrrrs.hg)waits preoutgoingsclone)throwr)rr) streamcloneoutgoing)rnoderrrs narrow-clonerr)uisquietbookmarkmove)rstreamclonerequested includepats excludepatsdepths2narrow clone not available for remote destinations)r<r s)clone from remote to remote not supportedsclonedrs experimentals remotenames@supdating to bookmark %s s%updating to bookmark %s on branch %s rsupdating to branch %s )caches)nrsrlr(rr+rr7rr"r?r!rMrrrr_r InputErrorrr$lexistsisdirlistdirrvalidatepatternsrArdisabledrrarCrDrErnullidrOrVrrrFr&sha1digestr5r"rshutilrmtreecloseryrrrealpathcancopyr hassecretr LockErrorrrclone_requirementscreaterepositorymakelocalrepositoryrr/ local_copyweakrefref_lockref _wlockrefr6 nodeconstantsnullhexrrBr setnarrowpatsrr setconfigconfigoverriderrpush _bookmarkskeysuimod samplehgrcspasswdrr configboolrpullremotenameslenr isrevsymbol revsymbolr1r_activebookmarkKeyError branchtiprr activate updatecaches repositorymodCACHES_POST_CLONE)2rrrrrr<rrr7 shareoptsstoreincludepatsstoreexcludepatsr6src_pathr origsourcerHsrclockr destwlockcleandirdestpeerr dest_pathdestvfsrnarrow sharepool sharenamemoderrLrootnoderrhgdircopy destrootpath dest_reqsrr/rrryr{ defaulturl overridesrrrbns2 r3rrs B&% --b&9  2x-G"% %Jfl+H2x2G!J 26H\\F   FF +kkmGG&,B'%kkm+ V044G4h4XHH&w4Hh <v&D !:;dBC222t   '  ' '(8 9F  '  ' '(8 9F (8$-; )-J~ & .2J* + ??< ("&Jv ,,.. M =O MM'* ! g. I +  002a#$==% &$ !&( !3 #4#;#;;$&GGLLCM$J  !A)+GGLLs8==#8#?#?#AB kk67-G  KL! %!! B 9-   MM(D )   MMO (0 NN 18s--/ : ll7#7#7 #CDG 4=ww~~d#((dF)CD  ! $$W-8(DD D   ",,E,2  LLtHL E"//5L!44RWMI  & &&  !44RFH (I}}H %  " "7H 5GXt4H)0 H(=HNN  %)0Y)?HNN  &)1(9(9HNN  % LLH73H3H3P3P   PMr) y1++9 C 002a"))MM )$*C!" %fh 32 "7NN$E e6G6G'7++,<>NO"44U; 7  KK("1X ""8ZXN!&!%:DA XX,,YAMM"-3$4$4#BA++3 %00557 kkBC>># ((3H G$AAHqJ LL  w(8(8J9N(O P KK ! !(J H M}}_n=++Hg>% 002a#$==% &$ !&( !3' 8}*x8/C ( ,,Xx@ ' 1 1(H E J J L!-%(0(?=<#33$,OOH4L4L$ME%-%=%=F$,$7$7$=E%)F%e_335+%&'Cf'L%MF!""K L!' &-F!%//1B9:R?F ""6*%(X000&&x8#!$! %%]-L-L%M! 9-   MM(D )   MMO (0 NN  H c 32",,IIGN??  b# Pkk!$F"G$"NOO P"32"77  BA`32.$)#8#8% $%"$<<$,$6$6z$BE$44<$,OOF$;E<<(! 9-   MM(D )   MMO (0 NN 18s H"u ,p<#pAp>B&u C3u 4qEu q.*Au 22r$9u s.r8(r+(r80s8A/u 'sEu #sA"u #s,4u 7Act|jjddtj||d|ddg|S)zUpdate the working directory to node. When overwrite is set, changes are clobbered, merged else returns stats (see pydoc mercurial.merge.applyupdates)sBprefer merge.update() or merge.clean_update() over hg.updaterepo()s5.7Fs working copys destination) branchmergeforcelabels updatecheck)rrxmergemodr)rzr1 overwriters r3 updatereporsH  GGM     0  r>ctj|||}t||||jr$|jj t d|jdkDS)z$update the working directory to noders1use 'hg resolve' to retry unresolved file merges r)rrrrrrr)rzr1rrrs r3rrsR OODJK @EtUJ'  qNOP  1 $$r>cttj||}|jdk(sJ|r t|||y)zAforcibly switch the working directory to node, clobbering changesrF)r clean_updaterr)rzr1 show_statsrrs r3cleanrs<  ! !$t* -E  A %% %4 + r>c*|*|jdd}|tvrtj}|tvrt d|dtd|j 5d}d}|t j||}|\}}}d }|r t||} nH|tjk(r'tj|d tj}t||| } | s|r||d jk(rnrtj ||g|d jr;|j#|j$d } |j't)d| zn|j#|j$d} |j't)d| ztj*|n||j,vrU||j$k7r/|j#|d } |j't)d| ztj.||n\|rZ|j$r9|j#|j$d} |j't)d| ztj*||rt j0||ddd| S#1swY SxYw)aUpdate the working directory with extra care for non-file components This takes care of non-file components below: :bookmark: might be advanced or (in)activated This takes arguments below: :checkout: to which revision the working directory is updated :brev: a name, which might be a bookmark to be activated after updating :clean: whether changes in the working directory can be discarded :updatecheck: how to deal with a dirty working directory Valid values for updatecheck are the UPDATECHECK_* constants defined in the merge module. Passing `None` will result in using the configured default. * ABORT: abort if the working directory is dirty * NONE: don't check (merge working directory changes into destination) * LINEAR: check that update is linear before merging working directory changes into destination * NO_CONFLICT: check that the update does not result in file merges This returns whether conflict is detected at updating or not. Nscommandss update.checkzInvalid updatecheck value z (can accept )F)rT)rrr.sbookmarks.activesupdating bookmark %s r)s(leaving bookmark %s) s(activating bookmark %s) )r_VALID_UPDATECHECKSrUPDATECHECK_LINEARrSrr destupdate_cleanUPDATECHECK_ABORTr bailifchangedUPDATECHECK_NONErr1r rlabelrcrr deactivaterYrfstatusotherdests) rrzrbrevrr movemarkfromwarndestupdataretbs r3 updatetotallyrsA4ii _= 1 1"55K--/ 1      ((U;F+1 (HlDH x(Ch888%%d%8&77 $kBC|tDz00!!$T 8IJHHT113FG !56:;HHT11<@ !67!;<$$T* T__ $t+++HHT#67 !9:Q>?   tT * ##HHT11<@ !67!;<   &   % %b$ /O R JS R Js H#JJc6|j}tj|||}t|||jr%|j j tdn&|r$|j j td|jdkDS)zWBranch merge with node, resolving changes. Return true if any unresolved conflicts.)rrsRuse 'hg resolve' to retry unresolved file merges or 'hg merge --abort' to abandon s'(branch merge, don't forget to commit) r)rzrrrrrrr)ctxrremindrrzrs r3rrs} 88:D NN3eF ;EtU   6   qDEF  1 $$r>c|tjj|}|jr|jj }n|dj }|j jtd|ddztj||}|jdk(sJt||y)Nr.s(aborting the merge, updating back to %s r) mergestatemodrractivelocalctxrrrrrrrr)rrzmsr1rs r3 abortmergers  ! ! & &t ,B yy{{{ Dz~~GGNN1ABT#2YNO  ! !$t* -E  A %% %tUr>c <tj|||g}t|}t|dk7r.t d} | t|z} t j | |d} || } | j} ntj|}|jrt|x} } ntj| j} | jrtjj}ntj}|d| j|fz| _ t| x} } t!||| }|j"} |j%t dtj&| z| j(|j+dgf}t-||||j+d\}}|r|Dcgc]}|j/|}}t1j2|||||j+d|j+d \}}}|s(|j%t d ||S|j5d t7j8|||| }|||||j#||ycc}w#|wxYw) z Helper for incoming / gincoming. displaychlist gets called with (remoterepo, incomingchangesetlist, displayer) parameters, and is supposed to contain only code that can't be unified. rs<for now, incoming supports only a single source, %d providedr%s/%scomparing with %s branchrevroforcesno changes found sincomingbuffered)r(get_pull_pathsr@r`rrr5rr!isabsrlrarOrVr posixpathr+rEr hidepasswordr7rrMrr getremotechangespagerrchangesetdisplayer) displaychlistsubreporecurserrzrrrsubpathsrcsrXrVrr!prrG cleanupfnrHr<rrchlist displayers r3 _incomingr-s?  ! !$VH 5D :D 4yA~OP s4ykk# 7D hh++g& ==?#Gn ,I DHH%Ayy{77++$--h!&&')::;AF#Ah &I tY 'E I !*+g.B.B3.GGHKK)R!89&tUHdhhv>NOh 156#ELL%D6#-#>#> eT488I#68J$  vy IIa-. /!#   11 th  eVY/  #7  s'A4J:J A J:AJ J Jc Jfd}fd}t|||S)Nc d}jdrMd}t|jD]0}|j|}t ||j }2|SNrssubrepos)rrrrminincoming)rrrrrrzrrs r3rz incoming..subreporecursers^ 88K t*C!#,,/ggg&#s||B=>0 r>ctj}jdr|jd}|D]|}|||k\ry|jj |Dcgc]}| j k7s|}}jdrt|dk(rd|dz }|j||~ycc}w)N newest_firstr no_mergesr) rgetlimitrreverse changelogparentsr@r`show) rGrrlimitcountrrrrrzs r3displayzincoming..display{s##D) 88O $ NN A Ue^ ??22155adkk9I5 xx %#g,!*; QJE NN58 $s %B<:B<r)r)rrzrrrrrs```` r3rrqs+% T64 r>c t}g}tj|||D]}|j}|tj|}|j r t |}nwtj|} | jrtjj} ntj} | d| j|fz| _ t | }|j|jdxsgf} |jtdtj |zt#||| |jd\} } | r4t%j&|| Dcgc]}||j)} }t+|||} t-j.||| |jd}|j0}|j3||s+t5j6|j8||j:|j=|tA|}|jB}|jE|jF||fScc}w#|j?xYw)Nrrrrr)r)key)$rr(get_push_pathsrr!rrlrarOrVrrr7rrrrrMrrevranger1r+r findcommonoutgoingmissingrrnochangesfoundrexcludedrBrEr@rsortr)rrzdestsrroutothersrVrrrrHr<rrrGoutgoingo outgoing_revscls r3 _outgoingrs %C F&&tR7xx  kk'*G}}W~KK%99;!ww//H(11H!(affg->">?Qx;; 3 9r9 !*+g.B.B4.HHI&tT8TXXf=MNh 0:0C0CD$0OP0ODINN$0ODPT4&  33eT();H  A JJqM&&twwh6G6GH MM% =8FIM B266" &  'Q  KKM s)IBII(c d}|jdrM|d}t|jD]0}|j|}t ||j |||}2|Sr)rrrrrr)rrzrrrrrrs r3_outgoing_recursers] C xx 4jcll+G'''"Cc3<<E489C, Jr>c#Ktj|}|jd}|jdr|j||s |D]}|yd}|j}|D]S}|||k\ry|j |D cgc]} | |j k7s| } } |rt| dk(rK|dz }|Uycc} ww)z5apply revision filtering/ordering option for outgoingrrNrrr)rrrrrrr@r`) rzr<rr no_mergesr2rrrrrs r3_outgoing_filterrs    %E&I xx   }YAG E B   %  jjm@mqDKK/?1m@ W*   AsBC CC"$Cc |jdrtjg|t|||||\}}d} |rd}|jdritj|||}|j dtj |||d} tj|||| tjn^|j dtj |||} t|||D]} | j|| | j|D]3} tj||| ||t|t!||||}5||D]} | jS#|D]} | jwxYw)Nsgraphrrrr0Tr)rrcheckunsupportedgraphflagsr graphrevsrr displaygraphr asciiedgesrrrEr outgoinghooksrr) rrzrrrrrrrevdagrroths r3rrs_ xx--b$7"dE4AIAv C Cxx!#--dAt<%&99dT ''fi1D1D%&99"dDI )$48ANN47+9!C  ! !"dCq 9c,RudCDCC IIK6C IIKs DE++Fc tj||}|jdtj|j |j d}|rh|jjtd|D]?}||} |jD](} |j|djxs|}*A|S#tj$r*}|jjd||fzYd}~gd}~wwxYw#t$rA|jjtd t!|j#zYwxYw) z&verify the consistency of a repository)levels filelog(%s)s .hgsubstateschecking subrepo links F) allowcreates%d: %s Ns&.hgsubstate is corrupt in revision %s ) verifymodr#r<r"pathtorgetcwdrrrrrr RepoErrorwarn Exceptionrr1)rzrrr<rrrrLs r3r#r#s   4u -C 99 DIIt{{}nM D  q456Cs)C "||G=GGGG?FFHOC , J!??= [C8%;<<=  @ACHHJ'( s=D%C=DD C;6D;DDAE  E cTtj|dr'|jj}|j}n|j}dD]>}|j |xs|j d|}|s+|jd||d@|j dd}|r|jdd|ddD]/}|j|D]\}}|j|||d1|j dd }|r'|jdd tj|d|S) z*build a remote ui from ui or repo and optsr)rqs remotecmdr2scopiedros mainreporoot)sauthshostfingerprintss hostsecuritys http_proxyswebscacerts) r"r?rrzrrrrV configitemsr^) srcrdstrvr2sectrvals r3rr s X&jjooffhhj" HHQK /3::eQ/ MM%Ay 1" 9o.A i!Y?O-HC MM$S) 4.O 6:&A fj$//!*))spaths 00changelog.i)r r)r sobsstore)spathr)c(eZdZdZdZdZdZdZy)cachedlocalrepoz6Holds a localrepository that can be cached and reused.ct|tjsJ||_|j \|_|_|j|_y)zCreate a new cached repo from an existing repo. We assume the passed in repo was recently created. If the repo has changed between when it was created and when it was turned into a cache, it may not refresh properly. N) rsrlocalrepository_repo _repostate_statemtime filtername _filtername)selfrzs r3__init__zcachedlocalrepo.__init__LsB$ 9 9::: "&//"3 TZ??r>c|j\}}||jk(r|jdfSt|jj|jj }|j r!|j|j |_n|j|_||_||_ |jdfS)aRefresh (if necessary) and return a repository. If the cached instance is out of date, it will be recreated automatically and returned. Returns a tuple of the repo and a boolean indicating whether a new repo instance was created. FT) rrrr%rr!rr unfilteredr)rstaterrzs r3fetchzcachedlocalrepo.fetchXs( u DKK ::u$ $$**++TZZ^^-=>   t'7'78DJ*DJ  zz4r>cg}d}tD]\}}t|j|}tjj ||} tj |}|j|t j|jft||t j}t||fS#t$rtj |}YzwxYw)N) foirrrOrVrrPrUrBST_MTIMEst_sizemaxtuple)rrmaxmtimeattrr'prefixrrWs r3rzcachedlocalrepo._repostatetsKD%TZZ.F VU+A %WWQZ LL"T]]+RZZ8 98R %67HU|X%%  %WWV_ %sB77CCc8t|jj|jj}|jr|j |j}n|j }t|}|j|_|j|_ |S)zObtain a copy of this class instance. A new localrepository instance is obtained. The new instance should be completely independent of the original. ) r%rrorigrootrrrr rr)rrzrs r3rzzcachedlocalrepo.copysr $**++TZZ-@-@A   ==!1!12D??$D D !;;**r>N)rgrhrirjrrrrzrnr>r3r r Is@ + 8 &r>r )F)Tr0)r>FNNN)FNNF)NTTNF)FNTF) NFNTFNNNNN)FN)TF)FTN)crOrrCrPrOi18nrr1rrrpycompatrrMr r r r r rrrrrrrrrrrrrrrrrrrrr[r r!r"r#rr$r interfacesr%rhutilsr&r'r(rrrMrYr[rwrurarrrr+rrrrrrrrr"r*rrrrrrrrrrUPDATECHECK_NO_CONFLICTrrrrrrrrrrrr rnr>r3r-s!   <4 ,,-` ( 77&   "  (9,   %@  *Z4,,   3 l ,-`3(,%^   h-X*      _D"(%      $$ Md    %. , A H>)!X.BDBHHr>