/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
Upload File
HOME
a �+�b�g � @ s� d dl mZ d dlZddlmZ ddlmZmZmZ ddl m Z dZ dZ d Z d Zd d � Zddd�ZG dd� dej�Zed�Zddd�ZdS )� )�absolute_importN� )�_)�error�pycompat�util)� stringutil� s alls prefinalizes postfinalizec s � fdd�}|S )Nc s* | j dkrt�d��� | g|�R i |��S )Nr s; cannot use transaction when it is already committed/aborted)�_countr �ProgrammingError)�self�args�kwds��func� �;/usr/lib64/python3.9/site-packages/mercurial/transaction.py�_active" s �zactive.<locals>._activer )r r r r r �active! s r Tc C s� t t|��� �D ]�\}} | s |s�|o.|df|v } zL||d| d�} | �� | k rht�td�|| | �� f ��| �| � | �� W q� t y� |td�| � � Y q�0 qz|� |� W q t t fy� } z| j t j krԂ W Y d } ~ qd } ~ 0 0 qg } |D �]J\}}}}||v�r"|�r"|d||f � || }z�|�r�|�r�|�|�}|�|�}|�o\||f|v } z tj||| d� | �|� W nD t �y� } z*t�|�}|td�||f � W Y d }~n d }~0 0 nT|�p�|}z|� |� W n: t t f�y } z | j t j k�r� W Y d } ~ n d } ~ 0 0 W q� t t tjf�y> |�s:� Y q�0 q�d| }|�|��r`|� |� |� | � z&| D ] }|�|��rp|� |� �qpW n t t tjf�y� Y n0 d S ) N� � a)� checkambigsB attempted to truncate %s to %d bytes, but it was already %d bytes s failed to truncate %s s. couldn't handle %s: unknown cache location %s s failed to recover %s (%s) � %s.backupfiles)�sorted�dict�items�tellr �Abortr �truncate�close�IOError�unlink�OSError�errno�ENOENT�joinr �copyfile�appendr � forcebytestr�exists)Zjournal�report�opener�vfsmap�entries� backupentriesr! �checkambigfiles�f�or �fp�instZ backupfiles�l�b�c�vfs�filepath� backuppath�excZe_msg�targetr r r � _playback, st � �� , r< c @ sp e Zd ZdGdd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z edd� �Z dd� Z edHdd��Z dd� ZedIdd��ZedJd d ��Zed d � �Zdefd!d"�Zed#d$� �Zed%d&� �Zed'd(� �ZedKd)d*��Zd+d,� Zd-d.� Zd/d0� Zed1d2� �Zed3d4� �Z ed5d6� �Z ed7d8� �Z ed9d:� �Z ed;d<� �Z ed=d>� �Z!ed?d@� �Z"edAdB� �Z#dCdD� Z$dEdF� Z%dS )L� transactionN� <unnamed>c C sN d| _ d| _|| _|| _|�� }||d< || _|| _i | _t� | _ || _ || _ g | _ | du rddd� } | | _ t� | _| r�| j�| � | g| _i | _i | _|�| j d�| _g | _i | _d| j | _|�| jd�| _| j�d t � |du�r |�| j |d @ � |�| j|d @ � i | _ i | _ d | _ i | _ i | _ |du�r>|| j d < i | _!i | _"dS ) 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. r r Nc S s d S �Nr )�tr�successr r r �<lambda>� r z&transaction.__init__.<locals>.<lambda>s w+r � w� %d i� Fs 001-userhooks)#r �_usages�_report�_opener�copy�_vfsmap�_after� _offsetmap�set� _newfiles�_journal� _undoname�_queue� _releasefn�_checkambigfiles�update�_namesZchangesZhookargs�open�_file�_backupentries� _backupmap�_backupjournal� _backupsfile�write�version�chmod�_filegenerators�_pendingcallback� _anypending�_finalizecallback�_validatecallback�_postclosecallback�_abortcallback) r r* r+ r, Z journalnameZundonameZafterZ createmodeZ validatorZ releasefnr/ �namer r r �__init__x sP ztransaction.__init__c C s d� | j�}d|| j| jf S )N�/z*<transaction name=%s, count=%d, usages=%d>)r% rT r rE �r re r r r �__repr__� s �ztransaction.__repr__c C s | j r| �� d S r? )rN �_abort�r r r r �__del__� s ztransaction.__del__c C s | j d u S r? �ra rk r r r � finalized� s ztransaction.finalizedc C s | j �g � dS )z�delay 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)rP r' rk r r r � startgroup� s ztransaction.startgroupc C s( | j �� }|D ]\}}| �||� qdS )z�apply 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)rP �pop� _addentry)r �qr0 r1 r r r �endgroup� s ztransaction.endgroupc C sP || j v s || jv s || jv r"dS | jr@| jd �||f� dS | �||� dS )z5record the state of an append-only file before updateN���)rM rK rX rP r' rq �r �file�offsetr r r �add� s ���ztransaction.addc C s` || j v s || jv s || jv r"dS |r2|| j|< n | j �|� | j�d||f � | j�� dS )z3add a append-only entry to memory and on-disk stateN� %s %d )rM rK rX rx rV r[ �flushru r r r rq s ��� ztransaction._addentryTr c C s� | j rd}t�|��|| jv s2|| jv s2|| jv r6dS | j| }|�|�\}}d| j|f }|� ||�} |� |�r�|� |�} |� | �} t j | | |d� nd} | �||| df� dS )aW Adds 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 s/ cannot use transaction.addbackup inside "group"Ns %s.backup.%s��hardlinkr F)rP r r rM rK rX rI �splitrN �reljoinr) r% r r& �_addbackupentry) r rv r| �location�msgr7 �dirname�filenameZbackupfilenameZ backupfiler8 r9 r r r � addbackup s( ��� ztransaction.addbackupc C sB | j �|� t| j �d | j|d < | j�d| � | j�� dS )z0register a new backup entry and write it to diskr � %s %s %s %d N)rW r' �lenrX rZ r[ rz )r �entryr r r r : s ztransaction._addbackupentryc C s | � |d|df� dS )z�register a temporary transaction file Such files will be deleted when the transaction exits (on both failure and success). r FN)r )r Ztmpfiler� r r r � registertmpA s ztransaction.registertmpr Fc C s |||||f}|| j |< dS )a] add a function to generates some files at transaction commit The `genfunc` argument is a function capable of generating proper content of each entry in the `filename` tuple. At transaction close time, `genfunc` will be called with one file object argument per entries in `filenames`. The transaction itself is responsible for the backup, creation and final write of such file. The `genid` argument is used to ensure the same set of file is only generated once. Call to `addfilegenerator` for a `genid` already present will overwrite the old entry. The `order` argument may be used to control the order in which multiple generator will be executed. The `location` arguments may be used to indicate the files are located outside of the the standard directory for transaction. It should match one of the key of the `transaction.vfsmap` dictionary. The `post_finalize` argument can be set to `True` for file generation that must be run after the transaction has been finalized. N�r^ )r �genid� filenames�genfunc�orderr� � post_finalizer� r r r �addfilegeneratorJ s %z transaction.addfilegeneratorc C s || j v r| j |= dS )z=reverse of addfilegenerator, remove a file generator functionNr� )r r� r r r �removefilegeneratorr s z transaction.removefilegeneratorc C s( d}|t krd }}n|tk}|tk}tt�| j��D ]�\}}d}|\}} } } } |r\| r\q6n |rf| sfq6| j| } g }z�| D ]V}||7 }|r�| j|| d� d}n | j || d� || f| j v }|� | |dd|d�� qz| |� |D ] }|� � q�|d d �= W |D ] }|� � q�q6|D ]}|� � �q0 q6|S )NFT)r� rC )Z atomictempr )� GEN_GROUP_ALL�GEN_GROUP_POST_FINALIZE�GEN_GROUP_PRE_FINALIZEr r Z iteritemsr^ rI r� r� rR r' r �discard)r �suffix�group�anyZ skip_postZskip_pre�idr� r� r� r� r� r� r7 �filesre r r0 r r r �_generatefilesx sD � �ztransaction._generatefilesc C s || j v rdS | j�|�S �Nr )rM rK �get)r rv r r r � findoffset� s ztransaction.findoffsetc C sD | j �d� g }| j �� D ]$}|�d�\}}|�|t|�f� q|S )Nr � )rV �seek� readlinesr} r' �int)r r- r4 rv Ztroffsetr r r � readjournal� s ztransaction.readjournalc C s� || j v r*|sdS | j �|� || j|< n8|| jv rZ|sN| j|= | j �|� qb|| j|< nt|��| j�d||f � | j�� dS )zn replace can only replace already committed entries that are not pending in the queue Nry )rM �removerK rx �KeyErrorrV r[ rz ru r r r �replace� s ztransaction.replacec C s, | j d7 _ | jd7 _| j�|� | S )Nr )r rE rT r' rh r r r �nest� s ztransaction.nestc C sH | j dkr| jd8 _| jr(| j�� | j dkrD| jdkrD| �� d S )Nr r )r rE rT rp rj rk r r r �release� s ztransaction.releasec C s | j dkS r� )r rk r r r �running� s ztransaction.runningc C s || j |< dS )z�add 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)r_ �r �category�callbackr r r � addpending� s ztransaction.addpendingc C sL t | j�}|D ] }| j�|�| �}| jp*|| _q| j| jdd�O _| jS )zpwrite pending file to temporary version This is used to allow hooks to view a transaction before commits .pending)r� )r r_ rp r` r� )r � categories�catr� r r r � writepending� s ztransaction.writependingc C s || j v S )z0check is a callback already exist for a categoryrm �r r� r r r � hasfinalize� s ztransaction.hasfinalizec C s || j |< dS )z�add 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. Nrm r� r r r � addfinalize� s ztransaction.addfinalizec C s || j |< dS )z�add 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)rc r� r r r � addpostclose s ztransaction.addpostclosec C s | j �|d�S )z1return a postclose callback added before, or NoneN)rc r� r� r r r � getpostclose s ztransaction.getpostclosec C s || j |< dS )a add 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)rd r� r r r �addabort s ztransaction.addabortc C s || j |< dS )z�adds 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)rb r� r r r � addvalidator s ztransaction.addvalidatorc C s� | j dkr~t| j�D ]}| j| | � qd| _| jtd� | jrl| j}i | _t|�}|D ]}|| | � qXq:d| _| jtd� | j d8 _ | j dkr�dS | j�� | j �� | j D ]�\}}}}|| j vr�|r�| � d||f � q�| j | } |s�|r�| � |�r�z| �|� W q� tttjf�yZ } z,|�s.� | � d| �|�| f � W Y d} ~ q�d} ~ 0 0 q�i | _t� | _| �� | j�r�| �� d| _| j�| j��r�| j�| j� | j�| j ��r�| j�| j � | j D ]�\}} }}|| j v�r |�r | � d||f � �q�| j | } |�r�| � |��r�z| �|� W nN tttjf�yx } z,|�sL� | � d| �|�| f � W Y d} ~ n d} ~ 0 0 �q�g | _ d| _ | � | d� d| _ t| j �}|D ]}| j | | � �q�d| _ dS ) zcommit the transactionr N)r� r s. couldn't remove %s: unknown cache location %s s couldn't remove %s: %s �- couldn't remove %s: unknown cache location%s T) r r rb r� r� ra r� rV r rZ rW rI rF r) r! r r" r r r% rK rL rM � _writeundorJ rG �isfilerY rN rQ rc ) r r� Z callbacksr� r� r4 r0 r5 r6 r7 r3 Z_fr r r r ' s� � � �� � ztransaction.closec C s | � � dS )z�abort the transaction (generally called on error, or when the transaction is not explicitly committed before going out of scope)N)rj rk r r r �aborty s ztransaction.abortc C s | j du rdS d| j }| j�|d�}|�dt � | jD ]�\}}}}|sLq:|sVd}n�|| jvrx|rx| �d||f � q:| j| }|�|�\} } | � | j �s�J | ��| � | j | j d�} |� | | �}t j|�|�|�|�dd � |�d ||||f � q:|�� dS ) z4write transaction data for possible future undo callNr rC rD r r� r Tr{ r� )rO rG rU r[ r\ rW rI rF r} � startswithrN r� r~ r r& r% r ) r Zundo_backup_pathZundobackupfiler4 r0 r5 r6 �ur7 �basere �unamer r r r� � s2 �� ztransaction._writeundoc C sl | � � }d| _d| _| j�� | j�� �z"|s|| js|| jrJ| j� | j� | j r^| j� | j � W d | _ | � | d� d | _ d S | � t d�� zZt| j�D ]}| j| | � q�d | _t| j | j | j| j|| jd| jd� | � t d�� W nL t�y0 } z2| � t d�� | � t d�t�|� � W Y d }~n d }~0 0 W d | _ | � | d� d | _ nd | _ | � | d� d | _ 0 d S )Nr Fs transaction abort! �r/ s rollback completed s( rollback failed - please run hg recover s (failure reason: %s) )r� r rE rV r rZ rW rY rG r! rN rQ rF r r rd r< rI rR � BaseExceptionr r( )r r- r� r: r r r rj � sV �� � � ztransaction._abort)NNNNNNr> )Tr )r )r r F)r> )&�__name__� __module__� __qualname__rf ri rl �propertyrn r ro rs rx rq r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� rj r r r r r= w s~ � _ ! � ' , Q r= s8 journal was created by a different version of Mercurial c C sH g }g }| � |��}|�� }W d � n1 s00 Y |D ]R} z$| �d�\} } |�| t| �f� W q> ty� |td�t�| � � Y q>0 q>d| } | � | ��r.| � | �}|�� }|�r.|d dd� } | dt kr�|t � nJ|dd� D ]<}|r�|dd� }|�d�\} } }}|�| | |t |�f� q�t ||| ||||d � dS ) 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 file offset pairs, delimited by newlines. The corresponding '*.backupfiles' file should contain a list of file backupfile 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. Nr� s couldn't read journal entry %r! r r rt s %dr r� )rU r� r} r' r� � ValueErrorr r Zbytestrr) r\ �BAD_VERSION_MSG�boolr< )r+ r, rv r* r/ r- r. r2 �linesr4 r0 r1 Z backupjournalZver�liner5 r6 r r r �rollback� sD & � �r� )TN)N)Z __future__r r# Zi18nr � r r r Zutilsr r\ r� r� r� r r< Z transactionalr= r� r� r r r r �<module> s* � K V�