6h4SSKJr SSKrSSKrSSKJrJrJrJrJ r SSK J r SSK J r JrJrJr SSKJrJrJrJr SSKJr SS KJr S rS rS rS rSrSr /SQr!Sr"SSjr#SSjr$"SS\RJ\RL5r\ "S5r'Sr(SSjr)g)) annotationsN)Callable CollectionListOptionalUnion)_)CallbackCategoryTHgPathT TransactionTVfsKeyT)encodingerrorpycompatutil) stringutil) transactionsalls prefinalizes postfinalizec^U4SjnU$)Nch>URS:Xa[R"S5eT"U/UQ70UD6$)Nrs;cannot use transaction when it is already committed/aborted)_countrProgrammingError)selfargskwdsfuncs 7/usr/lib/python3/dist-packages/mercurial/transaction.py_activeactive.._active3s< ;;! ((N D(4(4(()rrs` ractiver#2s) Nr!%s.backupfiles))stores %s.narrowspec)plains%s.narrowspec.dirstate)r&s %s.branch)r&s %s.bookmarks)r%s %s.phaseroots)r&s %s.dirstate)r&s%s.desc)r%s%sc^[RRURS55$)z4Return True if the repo has an abandoned transactionsjournal)ospathexistssjoin)repos rhas_abandoned_transactionr-Os 77>>$**Z0 11r!ch[U-n/n/nUSnU"U5n[X5nSSS5 UH+uppX;dM U (dMURXU 45 M- URXc45 [HupURXX-45 M UHupURU5 M g!,(df  N=f![aenUR[R:wa<[ S5n XR U5[R"U54-n U"U 5 SnAGNSnAff=f![amnUR[R:waC[ S5n XR U5[R"U54-n U"U 5 SnAGM SnAGMSnAff=f)zremove "undo" files used by the rollback logic This is useful to prevent rollback running in situation were it does not make sense. For example after a strip. r%Nscould not read %s: %s serror removing %s: %s ) UNDO_BACKUPread_backup_filesOSErrorerrnoENOENTr joinr forcebytestrappendUNDO_FILES_MAY_NEED_CLEANUPunlink)reportvfsmap undo_prefixbackup_listingbackup_entries undo_filessvfsfemsglocation backup_pathc undo_pathundovfsundofiles rcleanup_undo_filesrITs !;.NNJ ( D . !Q.v9N"(6#[  ++   v/= >(6t,-:6+Y-DEF ;'  NN8 $(" !  77ell "./C IIn-z/F/Fq/IJ JC 3K   ww%,,&23 X. 0G0G0JKKs ' sMC B7C!D:7 CCC D7AD22D7: F1AF,,F1c^^/mUU4Sjn0n UHNn U uppX;nURS5URS5:HnU(dM8U (dMAU (dMJXU 'MP [5n[[U5R 55HunnU R U5nUb/UuppSnU(aX4U;nU"X,U U5 UR U5 U(dU(dU=(a US4U;nU"USUS9nUR5U:a3[R"[S5UUUR54-5eURU5 UR5 MURU5 M UHzn U U;aM U unnnnUU;aU(a T"S UU4-5 UUnU=(a UU4U;nU(aU(a U"UUUU5 M]U=(d UnURU5 M| S U-nUR!U5(aURU5 URU5 TH/unnUR!U5(dMURU5 M1 g![a T"[S5U-5 ef=f![a GMf=f![a GM5f=f![[R4a U(deGM_f=f![[R4a gf=f) zurollback a transaction : - truncate files that have been appended to - restore file backups - delete temporary files c>URU5nURU5n[R"XTUS9 TRX45 g![a1n[ R "U5nT "[S5X4-5 eSnAff=f)N checkambigsfailed to recover %s (%s) )r4rcopyfiler6r1rr5r ) vfsr@brMfilepath backuppathexce_msg backupfilesr9s rrestore_one_backup%_playback..restore_one_backupsx88A;XXa[   MM*: F   x ( ++C0E 134zA B  s'A B,BBr!NFarLsBattempted 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$)r4setsorteddictitemsgetaddtellrAbortr truncatecloser1r8FileNotFoundErrorr*)journalr9openerr:entries backupentriesr8checkambigfilesrV store_backupentryrC file_pathrDcacherOis_store copy_doner@o bck_entryrMfplrPrEtargetrRrUs ` @r _playbackrtysK L27/[88C=FKK$44 8 kk&+ #  ItG}**,-1!$$Q'  6? 3HJ'2oE v+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 %  $)  %   U[[ !   sm6A0I2)J2)J9 J9)J'<K#K#2 J J$#J$' J61J95J66J99"K K #L?Lc\rSrSrS)SjrSrSr\S*Sj5r\ S+Sj5r \ S+Sj5r \ S,S j5r S r \ S-S.S jj5rS r\ S/S0Sjj5r\ S1S2Sjj5r\ S3Sj5rS \4Sjr\ S4Sj5r\ S5Sj5r\ S,Sj5r\ S6S7Sjj5rS+SjrS*SjrS8Sjr\ S*Sj5r\ S9Sj5r\ S8Sj5r\ S8Sj5r\ S:Sj5r \ S8Sj5r!\ S8Sj5r"\ S+S j5r#\ S+S!j5r$\ S;S"j5r%S#r&S$r'S%r(S&r)S'r*S(r+g)UR;URUS -5 UR;UR0US -5 0Ul0UlS Ul 0Ul!0Ul"UbXRDS '0Ul#0Ul$g) aBegin 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. r r!NcgNr")trsuccesss r&transaction.__init__.. sDr!sw+r$w%d iFs 001-userhooks)%r_usages_report_openercopy_vfsmap_after _offsetmaprY _newfiles_journal_journal_files _undoname_queue _releasefn_checkambigfilesupdate_nameschangeshookargsopen_file_backupentries _backupmap_backupjournal _backupsfilewriteversion _tmp_fileschmod_filegenerators_pendingcallback _anypending_finalizecallback_validatecallback_postclosecallback_abortcallback) rr9rer: journalnameundonameafter createmode validator releasefnrhnames r__init__transaction.__init__s6    s   #  !  0I# #   ! ! ( ( 9f   [[6 !/$--?"KK(;(;TB ' 12%  ! LL U(: ; LL,,j5.@ A " " !#"$  7@ " "#3 4"$ r!cSRUR5nS[R"U5URUR 4-$)N/z*)r4rr strfromlocalrrrrs r__repr__transaction.__repr__UsByy%;  ! !$ ' KK LL?   r!cHUR(aUR5 ggry)r_abortrs r__del__transaction.__del__]s == KKM r!cURSL$ryrrs r finalizedtransaction.finalizedas%%--r!c:URR/5 g)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)rr6rs r startgrouptransaction.startgroupes 2r!cpURR5nUHup#URX#5 M g)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)rpop _addentry)rqr@ros rendgrouptransaction.endgroupms, KKOO DA NN1 r!cXR;d-XR;dXR;dXR;agUR(a URSR X45 gUR X5 g)z5record the state of an append-only file before updateN)rrrrrr6rrfileoffsets rr^transaction.addws] NN "&&&  ;; KKO " "D> 2  t$r!cRXR;d-XR;dXR;dXR;agU(aX RU'OURR U5 UR R SX4-5 UR R5 g)z3add a append-only entry to memory and on-disk stateN%s%d )rrrrr^rrflushrs rrtransaction._addentrysy NN "&&&  $*OOD ! NN  t $ ~56 r!r!cUR(aSn[R"U5eXR;dXR;agXR ;aU(dgU(a-XR ;aSnXSU4-n[R"U5eUR UnURU5upxSURU4-n URXy5n URU5(avURU5n URU 5n [RRU 5n [R "XR"SS9 [R$"XUS9 OSn UR'X1U S 45 g) 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 notindexedhardlinkr!F)rrrrrrrsplitrreljoinr*r4r(r)dirnamermakedirsrrN_addbackupentry)rrrrC for_offsetrBrOrfilenamebackupfilename backupfilerQrRfinal_dir_names r addbackuptransaction.addbackups3& ;;DC((- - >> !T__%<  __ $Z  D72  d# #C((- -ll8$IIdO, x/HH[[9 ::d  xx~H*-J WW__Z8N MM.~~$ O MM( BJ hj%@Ar!cURRU5 [UR5S- URUS'URR SU-5 URR 5 g)z0register a new backup entry and write it to diskr %s%s%s%d N)rr6lenrrrr)rrjs rrtransaction._addbackupentrysd ""5)$'(;(;$XR;aURU gg)z=reverse of addfilegenerator, remove a file generator functionNr)rrs rremovefilegeneratortransaction.removefilegenerators# (( ($$U+ )r!c SnU[:XaS=pEOU[:HnU[:Hn[URR 55HupgSnUuppn U(a U (aMU(a U (dM-UR U n /nU HWnX- nU(aURXS9 SnOURXS9 X4UR;nURU "USSUS95 MY U "U6 UHnUR5 M USS2 UHnUR5 M M U$!UHnUR5 M f=f)NFT)rCr~) atomictemprM) GEN_GROUP_ALLGEN_GROUP_POST_FINALIZEGEN_GROUP_PRE_FINALIZErZrr\rrrrr6rbdiscard)rsuffixgroupany skip_postskip_preidrjrrrrCrrOfilesrrMr@s r_generatefilestransaction._generatefiles sF M !#( (I 77H!77I 4 4 : : <=IBCAF >Eg]-,,x(CE %DND(((A%* t?&*%59N9N%N LLD$4JO&AGGI!HAIIK=>@ AIIKs BD$$D?cXXR;agURRU5$Nr)rrr])rrs r findoffsettransaction.findoffset8s$ >> !""4((r!cURRS5 /nURR5H2nURS5up4UR U[ U545 M4 U$)Nr)rseek readlinesrr6int)rrfrrrtroffsets r readjournaltransaction.readjournal>sY %%'AWWU^ND NND#h-0 1(r!cXR;a2U(dgURRU5 X RU'OYXR;a?U(d)URU URRU5 OX RU'O [ U5eUR R SX4-5 UR R5 g)zV replace can only replace already committed entries that are not pending in the queue Nr)rremoverr^KeyErrorrrrrs rreplacetransaction.replaceGs >> ! NN ! !$ '$*OOD ! __ $OOD)""4((.%4.  ~56 r!cU=RS- slU=RS- slURRU5 U$Nr )rrrr6rs rnesttransaction.nest]s5 q    4  r!cURS:aU=RS-slUR(aURR5 URS:a"URS:XaUR 5 ggg)Nrr )rrrrrrs rreleasetransaction.releasedsV ;;? LLA L ;; KKOO  ;;?t||q0 KKM 1?r!c URS:$r)rrs rrunningtransaction.runningms{{Qr!c X RU'g)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 addpendingtransaction.addpendingps+3h'r!c[UR5nUH>nURRU5"U5nUR=(d UUlM@ U=RUR SS9-slUR$)zhwrite pending file to temporary version This is used to allow hooks to view a transaction before commits.pending)r)rZrrrr)r categoriescatrs r writependingtransaction.writepending~sy D112 C''++C06C#//63D  D//{/CCr!cXR;$)z0check is a callback already exist for a categoryrrrs r hasfinalizetransaction.hasfinalizes1111r!c X RU'g)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 addfinalizetransaction.addfinalizes,4x(r!c X RU'g)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 addpostclosetransaction.addpostcloses-5)r!c:URRUS5$)z1return a postclose callback added before, or NoneN)rr]r)s r getpostclosetransaction.getpostcloses &&**8T::r!c X RU'g)zadd 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 raddaborttransaction.addaborts)1H%r!c X RU'g)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 addvalidatortransaction.addvalidators,4x(r!cdURS:Xa[UR5HnURU"U5 M SUlUR[S9 UR (aDUR n0Ul[U5nUH nX$"U5 M UR (aMDSUlUR[ S9 U=RS-slURS:wagURR5 URR5 URH~upVpxXPR;aU(aURSXu4-5 M3URUn U(aMKU(dMTU RU5(dMlU RU5 M 0Ul[)5UlUR-5 UR.(aUR/5 SUlUR0R3UR45(a%UR0RUR45 UR0R3UR65(a%UR0RUR65 URHuup[pxXPR;aU(aURSXu4-5 M3URUn U(dMKU RU5(dMcU RU5 Mw /Ul SUlUR9US5 SUl[UR:5nUHnUR:U"U5 M SUlg![[ R"4a9n U(deURSU R%U5U 4-5 Sn A GMSn A ff=f![[ R"4a9n U(deURSU R%U5U 4-5 Sn A GMSn A ff=f) zcommit the transactionr N)rrs.couldn't remove %s: unknown cache location %s scouldn't remove %s: %s -couldn't remove %s: unknown cache location%s T)rrZrrrrrrrbrrrrr*r8r1rr`r4rrYr _writeundorrisfilerrrr) rr callbacksr$r%rrr@rPrErOinst_fs rrbtransaction.closesR ;;! "4#9#9:&&x06;%)D "   &<  =(( 22 )+&#I. %CN4(& (((&*D "   &=  > q ;;!    !--JA! $ F!O,,q/C1szz!}}JJqM."  ;; KKMDK <<  t22 3 3 LL   3 3 4 <<  t}} - - LL   ...KA1 $  f%,,q/CqSZZ]]JJqM/$!  d#D334 C  # #C ( .#'] -LL3sxx{D6II 8 -LL3sxx{D6II s0NOO -OOP/6-P**P/c$UR5 g)zabort the transaction (generally called on error, or when the transaction is not explicitly committed before going out of scope)N)rrs raborttransaction.abort$s r!c<URRX45 gry)rr6)rvfs_idr)s r add_journaltransaction.add_journal+s ""F>2r!c<^TRcg[TRTRTRS9 S U4SjjnSTR-nTRR US5nUR S[-5 TRHupEpgU(dMU(dSnOyUTR;aU(aTRSXd4-5 MGTRUn U"U5n[R"U RU5U RU5S S 9 UR S XEX4-5 M UR5 TRH0upU"U 5n U RU 5 U RX5 M2 g![ a MBf=f) z4write transaction data for possible future undo callN)r;c>[RRU5upURTR5(deUR TRTR S5n[RRX5$r)r(r)r startswithrrrr4)fnbasernew_namers rr(transaction._writeundo..undoname9s]r*JD??4==11 11||DMM4>>1EH77<</ /r!r$r~rr!r<Trr)rMbytesreturnrQ)rrIrrrrrrrrrNr4rbr tryunlinkrenamerc) rrundo_backup_pathundobackupfilerrr@rPrEurOsrcdests ` rr=transaction._writeundo/sg >> !  LL LL  0 -t~~=**+;TBWw./--JA!DLL(QLL #$&)ll1oQK chhqk388A;F  !4a|!C D. ++HCC=D MM$   3%,%  s7F  FFc\UR5nSUlSUlURR 5 UR R 5 UR U5nU(dUR[S55 [UR5HnURU"U5 M SUl U(aURU5 OURU5 SUl URUS5 SUlg!SUl URUS5 SUlf=f)Nrstransaction abort! F)r rrrrbr_can_quick_abortrr rZr_do_quick_abort_do_full_abortrr)rrfquickr%s rrtransaction._abort^s""$    !%%g. # Q678d112##C(.3#'D $$W-##G, DM OOD% ("DO!DM OOD% ("DOs %BD "D+cRU(agURHnUS(dM g g)zyFalse if any semantic content have been written on disk True if nothing, except temporary files has been writen on disk.Fr T)r)rrfrAs rr\transaction._can_quick_abortvs+ $$Att%r!cURU5(deURVs/sHo"S(aMUPM nnUH'upEpgURUnURU5 M) UR (a%UR RUR 5 UR(a&UR RUR5 ggs snf![a Mf=f)z4(Silently) do a quick cleanup (see _can_quick_abort)r N)r\rrr8rcrrr) rrfrA tmp_filesrGold_pathtmp_pathxxxrOs rr]transaction._do_quick_aborts$$W---- $ 3 3@ 31Q4Q 3 @/8 +Fh,,v&C  8$09    LL   3 3 4 == LL   . A %  s CCC  C.-C.c [URURURURUUR SUR S9 UR[S55 g![aUnUR[S55 UR[S5[R"U5-5 SnAgSnAff=f)z?(Noisily) rollback all the change introduced by the transactionT)r8rhsrollback completed s(rollback failed - please run hg recover s(failure reason: %s) N) rtrrrrrrr BaseExceptionrr5)rrfrSs rr^transaction._do_full_aborts      ## $ 5 5  LL23 4  LLGH I LL+,z/F/Fs/KK   sA&A)) C3A CC)rrrrrrrrrrrrrrrrrrrrrrrrrrrrrr)NNNNNN )rRbool)rRNone)rr rr rRrn)Tr!F) rr rrmrCrrzUnion[bool, int]rRrn)r!)rr rCrrRrn)rr!F)rrQrzCollection[HgPathT]rrrr rCrrrmrRrn)rrQrRrn)rr rRz Optional[int])rRzList[itxn.JournalEntryT])rl)rrQrRr )rr r zCallable[[TransactionT], None]rRrn)rr rRrm)rr rRz(Optional[Callable[[TransactionT], None]])rGrr)r rRrn),__name__ __module__ __qualname____firstlineno__rrrpropertyrr#rrr^rrrrrrrrrr rrrrr!r&r*r-r0r3r6r9rbrDrHr=rr\r]r^__static_attributes__r"r!rrrsV `!D ..   ! !  %  %" ', 2B2B2B 2B % 2B  2B 2Bh" > > #%,%,'%, %,  %,  %,%, %, %,N , , %(}*X ) )     *    3# 31 3  3       2 2  4# 41 4  4  4  5# 51 5  5  5 ;#; 2; ;  1# 11 1  1  1  4# 41 4  4  4 O' O'b    3 3-^#0  /r!rs8journal was created by a different version of Mercurial c UR5n/nU(anUSSSnUS[-:waU"[5 U$USSHBnU(dM USSnURS5upgpUR XgU[ U 545 MD U$)aBparse 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%dr r)r rBAD_VERSION_MSGrr6rm) r9rqlinesrgverlinerrr@rPrEs rr0r0s LLNEM Ahsm 57? # ? #  ab 49D!%E!2JA!!((!47);< " r!c ^/n/nURU5nUR5n SSS5 W H3n U RS5upURU [ U 545 M5 SU-n URU 5(a%URU 5n[X85nSSS5 Tb&U4SjnUVs/sHo"U5(dMUPM nn[UUUUUUUS9 g!,(df  N=f![ a, U"[ S5[R"U 5-5 Mf=f!,(df  N=fs snf)a_Rolls 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! r$c6>TRUS5(+$r)match)xskip_journal_patterns rr|rollback..s177!==r!)rh) rr rr6r  ValueErrorr rbytestrr*r0rt)rer:rr9rhr~rfrgrqrwrrr@ro backupjournalkeepr}s ` rrollbackrs .GM T b    775>DA NNAs1v; '&,M }}]## [[ '2-f9M('=$1=MqT!WM =  ''     67(:J:J1:MM  ( '>s4C"/C3 D,6D= D=" C032D)(D), D:)sundo)TN)NN)* __future__rr2r(typingrrrrri18nr interfaces.typesr r r rrrrrutilsr interfacesritxnrrrrr#r/r7r-rIrt transactional ITransactionrvr0rr"r!rrs#   +  ')   2 "X v rp $$$d&7&7p f@ > 5r!