q&fddlZddlZddlmZddlmZmZmZmZddl m Z dZ dZ dZ d Zd Zd Zgd Zd ZddZ ddZGddej*ZedZdZ ddZy)N)_)encodingerrorpycompatutil) stringutilsalls prefinalizes postfinalizecfd}|S)Ncd|jdk(rtjd|g|i|S)Nrs;cannot use transaction when it is already committed/aborted)_countrProgrammingError)selfargskwdsfuncs 7/usr/lib/python3/dist-packages/mercurial/transaction.py_activezactive.._active"s< ;;! ((N D(4(4(()rrs` ractiver!s) Nr%s.backupfiles))stores %s.narrowspec)plains%s.narrowspec.dirstate)rs %s.branch)rs %s.bookmarks)rs %s.phaseroots)rs %s.dirstate)rs%s.desc)rs%sc^tjj|jdS)z4Return True if the repo has an abandoned transactionsjournal)ospathexistssjoin)repos rhas_abandoned_transactionr!>s 77>>$**Z0 11rc8t|z}g}g}|d} ||5}t||}ddd|D]%\} }} } | |vs | s|j|| | f'|j||ftD]\} } |j|| | |zf |D]\}} |j|y#1swYxYw#t$rc}|jtjk7r?t^,-:G)6(+Y-DEFG'  NN8 $ : :  77ell "./C DIIn-z/F/Fq/IJ JC 3K   ww%,,&23 X. 0G0G0JKKs  sGB> B2B>D-2B;7B>> D*AD%%D*- F6AFFcTgfd}i} |D]?} | \} } } }|| }|jd|jdk(}|s5| s8| s;| | | <At}tt|j D]\}}| j |}|-|\} } } }d}|r| | f|v}||| | ||j ||s|s}|xr|df|v} ||d|}|j|kr2tjtd|||jfz|j||j |j||D]Y} | |vr| \}}}}||vr|r d ||fz||} |xr||f|v}|r|r |||||n|xs|} |j|[d |z}|j#|r|j||j| D](\}}|j#|s|j|*y#t$rtd|zwxYw#t$rYwxYw#t$rYwxYw#tt tjf$r|sY(wxYw#tt tjf$rYywxYw) zrollback a transaction : - truncate files that have been appended to - restore file backups - delete temporary files c|j|}|j|} tj|||j||fy#t$r1}t j |} td||fzd}~wwxYw)N checkambigsfailed to recover %s (%s) )r(rcopyfiler*IOErrorr r)r) vfsr4brAfilepath backuppathexce_msg backupfilesr-s rrestore_one_backupz%_playback..restore_one_backupys~88A;XXa[   MM*h: F   Qx ( ++C0E 1345zA B  s+A B ,BB rNFar@sBattempted to truncate %s to %d bytes, but it was already %d bytes sfailed to truncate %s s.couldn't handle %s: unknown cache location %s r)r(setsorteddictitemsgetaddtellrAbortrtruncatecloserCr,FileNotFoundErrorr%r)journalr-openerr.entries backupentriesr,checkambigfilesrK store_backupentryr7 file_pathr8cacherDis_store copy_doner4o bck_entryrAfplrEr9targetrGrJs ` @r _playbackrhhs K L,27/)[%X88C=FKK$44  k&+L # , ItG}**,-"1!$$Q'  6? 3HieJ'2oE vy+z J MM) $ F(HaX-HJ At ;779q=++2a+ , A   a A"H I   1a F?q EAN OQi (FaV-FJQ"31j9a JJv&@#W,J }}Z  j! MM' ! FCzz!} 1  _ q34q89 %  $)  %++.   Wekk *   sgA1HH? I#I/J JH<? I  I  IIII!JJJ'&J'ceZdZ d'dZdZdZedZedZ edZ edZ d Z ed(d Z d Zed)d Ze d*dZedZd efdZedZedZedZed+dZdZdZdZedZedZedZedZedZedZ edZ!edZ"ed Z#ed!Z$d"Z%d#Z&d$Z'd%Z(d&Z)y), transactionNc d|_d|_||_||_|j }||d<||_||_i|_t|_ ||_ g|_ ||_ g|_ | d} | |_t|_| r|jj!| | g|_i|_i|_|j)|jd|_g|_i|_d|jz|_|j)|j0d|_|j2j5dt6zt|_|>|j;|j|d z|j;|j0|d zi|_i|_d |_ i|_!i|_"|||jDd <i|_#i|_$y) a Begin a new transaction Begins a new transaction that allows rolling back writes in the event of an exception. * `after`: called after the transaction has been committed * `createmode`: the mode of the journal file that will be created * `releasefn`: called after releasing (with transaction and result) `checkambigfiles` is a set of (path, vfs-location) tuples, which determine whether file stat ambiguity should be avoided for corresponded files. rrNcyNr)trsuccesss rz&transaction.__init__..srsw+rw%d iFs 001-userhooks)%r _usages_report_openercopy_vfsmap_after _offsetmaprM _newfiles_journal_journal_files _undoname_queue _releasefn_checkambigfilesupdate_nameschangeshookargsopen_file_backupentries _backupmap_backupjournal _backupsfilewriteversion _tmp_fileschmod_filegenerators_pendingcallback _anypending_finalizecallback_validatecallback_postclosecallback_abortcallback) rr-rYr. journalnameundonameafter createmode validator releasefnr\names r__init__ztransaction.__init__s6    s   #  !  0I# #   ! ! ( ( 9f   [[6 !/$--?"KK(;(;TB ' 12%  ! LL U(: ; LL,,j5.@ A " " !#"$  7@D " "#3 4"$ rcdj|j}dtj||j|j fzS)N/z*)r(rr strfromlocalr rsrrs r__repr__ztransaction.__repr__DsByy%;  ! !$ ' KK LL?   rc>|jr|jyyrm)r{_abortrs r__del__ztransaction.__del__Ls == KKM rc|jduSrmrrs r finalizedztransaction.finalizedPs%%--rc:|jjgy)zdelay registration of file entry This is used by strip to delay vision of strip offset. The transaction sees either none or all of the strip actions to be done.N)r~r*rs r startgroupztransaction.startgroupTs 2rcp|jj}|D]\}}|j||y)zapply delayed registration of file entry. This is used by strip to delay vision of strip offset. The transaction sees either none or all of the strip actions to be done.N)r~pop _addentry)rqr4rcs rendgroupztransaction.endgroup\s5 KKOO  !DAq NN1a  !rc||jvs*||jvs||jvs||jvry|jr!|jdj ||fy|j ||y)z5record the state of an append-only file before updateN)rzryrrr~r*rrfileoffsets rrRztransaction.addfsi DNN "t&t&t&  ;; KKO " "D&> 2  tV$rcD||jvs*||jvs||jvs||jvry|r||j|<n|jj ||j j d||fz|j jy)z3add a append-only entry to memory and on-disk stateN%s%d )rzryrrrRrrflushrs rrztransaction._addentryvs DNN "t&t&t&  $*DOOD ! NN  t $ f~56 rrc|jrd}tj|||jvs||jvry||j vr|sy|r,||j vrd}|||fz}tj||j |}|j|\}}d|j|fz} |j|| } |j|r||j|} |j| } tjj| } tj | |j"dtj$| | |nd} |j'||| d fy) aAdds a backup of the file to the transaction Calling addbackup() creates a hardlink backup of the specified file that is used to recover the file in the event of the transaction aborting. * `file`: the file path, relative to .hg/store * `hardlink`: use a hardlink to quickly create the backup If `for_offset` is set, we expect a offset for this file to have been previously recorded s/cannot use transaction.addbackup inside "group"NzKcalling `addbackup` with `for_offmap=True`, but no offset recorded: [%r] %rs%s.backup.%s.bckT)mode notindexedhardlinkrF)r~rrrzrryrwsplitr{reljoinrr(rrdirnamermakedirsrrB_addbackupentry)rrrr7 for_offsetr6rDrfilenamebackupfilename backupfilerFrGfinal_dir_names r addbackupztransaction.addbackupsD ;;DC((- - 4>> !TT__%<  T__ $Z  D72  Hd# #C((- -ll8$IIdO, x/HH[[.9 ::d xx~H*-J WW__Z8N MM.s~~$ O MM(J BJ hj%@Arc|jj|t|jdz |j|d<|jj d|z|jj y)z0register a new backup entry and write it to diskr %s%s%s%d N)rr*lenrrrr)rr^s rrztransaction._addbackupentrysd ""5)$'(;(;$E9gx]-,,x(CE % DFND(((A%* th?&*H%59N9N%N LLD$4JO AGGI!H AIIK = @  AIIK s 2BDD)cV||jvry|jj|SNr)rzryrQ)rrs r findoffsetztransaction.findoffset!s& 4>> !""4((rc|jjdg}|jjD]2}|jd\}}|j |t |f4|S)Nr)rseek readlinesrr*int)rrZrfrtroffsets r readjournalztransaction.readjournal's` %%' 2AWWU^ND( NND#h-0 1 2rc||jvr.|sy|jj|||j|<nT||jvr;|s)|j|=|jj|n||j|<n t ||j j d||fz|j jy)zn replace can only replace already committed entries that are not pending in the queue Nr)rzremoveryrRKeyErrorrrrrs rreplaceztransaction.replace0s 4>> ! NN ! !$ '$*DOOD ! T__ $OOD)""4((.%4.  f~56 rc|xjdz c_|xjdz c_|jj||SNr)r rsrr*rs rnestztransaction.nestFs5 q    4  rc|jdkDr|xjdzc_|jr|jj|jdkDr!|jdk(r|j yyy)Nrr)r rsrrrrs rreleaseztransaction.releaseMsV ;;? LLA L ;; KKOO  ;;?t||q0 KKM 1?rc |jdkDSr)r rs rrunningztransaction.runningVs{{Qrc"||j|<y)zadd a callback to be called when the transaction is pending The transaction will be given as callback's first argument. Category is a unique identifier to allow overwriting an old callback with a newer callback. N)rrcategorycallbacks r addpendingztransaction.addpendingYs+3h'rct|j}|D]8}|jj||}|jxs||_:|xj|j dzc_|jS)zpwrite pending file to temporary version This is used to allow hooks to view a transaction before commits.pending)r)rNrrrr)r categoriescatrs r writependingztransaction.writependingcs D112  7C0$''++C06C#//63D  7 D//{/CCrc||jvS)z0check is a callback already exist for a categoryrrrs r hasfinalizeztransaction.hasfinalizeps41111rc"||j|<y)zadd a callback to be called when the transaction is closed The transaction will be given as callback's first argument. Category is a unique identifier to allow overwriting old callbacks with newer callbacks. Nrrs r addfinalizeztransaction.addfinalizeus,4x(rc"||j|<y)zadd or replace a callback to be called after the transaction closed The transaction will be given as callback's first argument. Category is a unique identifier to allow overwriting an old callback with a newer callback. N)rrs r addpostcloseztransaction.addpostcloses-5)rc:|jj|dS)z1return a postclose callback added before, or NoneN)rrQrs r getpostcloseztransaction.getpostcloses&&**8T::rc"||j|<y)aadd a callback to be called when the transaction is aborted. The transaction will be given as the first argument to the callback. Category is a unique identifier to allow overwriting an old callback with a newer callback. N)rrs raddabortztransaction.addaborts)1H%rc"||j|<y)zadds a callback to be called when validating the transaction. The transaction will be given as the first argument to the callback. callback should raise exception if to abort transactionN)rrs r addvalidatorztransaction.addvalidators,4x(rc|jdk(rt|jD]}|j||d|_|jt|j r=|j }i|_t|}|D] }||||j r=d|_|jt |xjdzc_|jdk7ry|jj|jj|jD]g\}}}}||jvr|r|jd||fz/|j|} |rA|sD| j|sV | j|ii|_t+|_|j/|j0r|j1d|_|j2j5|j6r%|j2j|j6|j2j5|j8r%|j2j|j8|jD]d\}} }}||jvr|r|jd||fz/|j|} |sA| j|sS | j|fg|_ d|_|j;|dd|_t|j<}|D]}|j<||d|_y#tt t"j$f$r3} |s|jd| j'|| fzYd} ~ fd} ~ wwxYw#tt t"j$f$r3} |s|jd| j'|| fzYd} ~ gd} ~ wwxYw) zcommit the transactionrN)rrs.couldn't remove %s: unknown cache location %s scouldn't remove %s: %s -couldn't remove %s: unknown cache location%s T)r rNrrrrrrrVrrrwrtrr,rCr%rrTr(ryrMrz _writeundorxruisfilerr{rr) rr callbacksrrrfr4rEr9rDinst_fs rrVztransaction.closest ;;! "4#9#9: 70&&x06 7%)D "   &<  =(( 22 )+&#I. %)C"IcN4() ((&*D "   &=  > q ;;!    !-- JAq!Q $ F!QO,,q/Cszz!}JJqM "  ;; KKMDK <<  t22 3 LL   3 3 4 <<  t}} - LL   ... KAr1a $  !f%,,q/CSZZ]JJqM $!  d#D334  /C (D # #C ( . /#'] %++6LL3sxx{D6II 8 %++6LL3sxx{D6II s0>MNN(N  NO&3(O!!O&c$|jy)zabort the transaction (generally called on error, or when the transaction is not explicitly committed before going out of scope)N)rrs rabortztransaction.aborts rc>|jj||fyrm)r|r*)rvfs_idrs r add_journalztransaction.add_journals ""FD>2rc4jytjjjdtdtffd }djz}j j |d}|jdtzjD]\}}}}|s |sd }nt|jvr|rjd ||fz7j|} ||}tj| j|| j|d |jd ||||fz|jjD]1\} } || } | j|  | j!| | 3y#t"$rY@wxYw)z4write transaction data for possible future undo callN)r/fnreturnctjj|\}}|jjsJ|j jj d}tjj||Sr)rrr startswithr{rr}r()rbasernew_namers rrz(transaction._writeundo..undoname s^r*JD$??4==1 11||DMM4>>1EH77<<h/ /rrrqrrrrTrr)r}r=rtrwbytesrurrrrrrBr(rVr| tryunlinkrenamerW) rrundo_backup_pathundobackupfilerfr4rEr9urDsrcdests ` rrztransaction._writeundos >> !  LL LL  0 05 0 -t~~=**+;TBWw./-- EJAq!QDLL(QLL #$a&)ll1oQK chhqk388A;F  !41a|!C D E ++ HCC=D MM$   3% %  s6F  FFcD|j}d|_d|_|jj |j j |j |} |s|jtdt|jD]}|j||d|_ |r|j|n|j|d|_ |j|dd|_y#d|_ |j|dd|_wxYw)Nrstransaction abort! F)rr rsrrVr_can_quick_abortrtrrNr_do_quick_abort_do_full_abortr{r)rrZquickrs rrztransaction._abort0s""$    !%%g. # Q678d112 /(##C(. /#'D $$W-##G, DM OOD% ("DO!DM OOD% ("DOs %A7C=="Dc:|ry|jD] }|ds yy)zFalse if any semantic content have been written on disk True if nothing, except temporary files has been writen on disk.FrT)r)rrZr5s rr.ztransaction._can_quick_abortHs. $$ At rc|j|sJ|jDcgc] }|dr | }}|D](\}}}}|j|} |j|*|j r%|j j|j |jr&|j j|jyycc}w#t$rYwxYw)z4(Silently) do a quick cleanup (see _can_quick_abort)rN)r.rrwr,rWrrur{) rrZr5 tmp_filesrold_pathtmp_pathxxxrDs rr/ztransaction._do_quick_abortSs$$W--- $ 3 3@11Q4Q@ @/8  +FHh,,v&C  8$     LL   3 3 4 == LL   . A %  s CC C  CCc  t|j|j|j|j||j d|j |jtdy#t$rT}|jtd|jtdtj|zYd}~yd}~wwxYw)z?(Noisily) rollback all the change introduced by the transactionT)r,r\srollback completed s(rollback failed - please run hg recover s(failure reason: %s) N) rhr{rtrurwrrr BaseExceptionr r))rrZrHs rr0ztransaction._do_full_abortbs      ## $ 5 5  LL23 4  LLGH I LL+,z/F/Fs/KK   sA)A,, C 5A CC )NNNNNN )TrF)r)rrF)r:)*__name__ __module__ __qualname__rrrpropertyrrrrrRrrrrrrrrrrrrrrrrrr r r rrrVrrrrr.r/r0rrrrjrjs4 `!D ..   ! !  %  %" ,B ,B\" > > %, %,N , , %(}*X ) )     *   3       2 2 4 4 5 5 ; ; 1 1 4 4 O' O'b    3 3-^#0  /rrjs8journal was created by a different version of Mercurial c |j}g}|rh|ddd}|dtzk7r|t|S|ddD]>}|s|dd}|jd\}}}} |j |||t | f@|S)aZparse an (already open) backup file an return contained backup entries entries are in the form: (location, file, backupfile, xxx) :location: the vfs identifier (vfsmap's key) :file: original file path (in the vfs) :backupfile: path of the backup (in the vfs) :cache: a boolean currently always set to False rNrs%drr)rrBAD_VERSION_MSGrr*bool) r-relinesr[verlinerfr4rEr9s rr$r$|s LLNEM Ahsm 57? # ? #  ab  =9D!%E!2JAq!Q!((!Q47);<  = rc Rg}g}|j|5}|j} ddd D]3} | jd\} } |j| t | f5d|z} |j| r&|j| 5}t||}dddfd}|Dcgc] }||s |}}t|||||||y#1swYxYw#t $r*|t dtj| zYwxYw#1swY}xYwcc}w)aRolls back the transaction contained in the given file Reads the entries in the specified file, and the corresponding '*.backupfiles' file, to recover from an incomplete transaction. * `file`: a file containing a list of entries, specifying where to truncate each file. The file should contain a list of fileoffset pairs, delimited by newlines. The corresponding '*.backupfiles' file should contain a list of filebackupfile pairs, delimited by . `checkambigfiles` is a set of (path, vfs-location) tuples, which determine whether file stat ambiguity should be avoided at restoring corresponded files. Nrs couldn't read journal entry %r! rc.j|d Sr)match)xskip_journal_patterns rrpzrollback..s177!==r)r\) rrrr*r ValueErrorrrbytestrrr$rh)rYr.rr-r\rIrZr[rerBrfr4rc backupjournalkeeprHs ` rrollbackrNs3.GM T b   775>DAq NNAs1v; '&,M }}]# [[ ' :2-fb9M :'=$1=qT!W= =  ''   67(:J:J1:MM   : :>s4C0C" D/ D$=D$C"0DDD!)sundo)TN)NN)r&ri18nrrrrrutilsr rrrrrr#r+r!r=rh transactionalrjr@r$rNrrrrSs    ')   2 "X v rS $$$S l@ > 5r