|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/mercurial/__pycache__/ |
Upload File : |
o
�]Lb� � @ sd d dl mZ d dlZd dlZd dlZddlmZmZmZm Z m
Z
G dd� de �Z dd� Z
d d
� ZdS ) � )�absolute_importN� )�error�hg�obsolete�scmutil�utilc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )�
repoloaderz�Load repositories in background thread
This is designed for a forking server. A cached repo cannot be obtained
until the server fork()s a worker and the loader thread stops.
c C s@ |� � | _tj|d�| _tj|d�| _d| _t �
� | _ d | _ d S )N)�max)�maxlenF)
�copy�_uir � lrucachedict�_cache� collections�deque�_inqueue�
_accepting� threading�Event� _newentry�_thread)�self�uir � r �5/usr/lib/python3/dist-packages/mercurial/repocache.py�__init__ s
zrepoloader.__init__c C s> | j rJ �| jjdkr
d S d| _tj| jd�| _ | j �� d S )Nr T)�target)r r r r r �Thread� _mainloop�start�r r r r r ( s
zrepoloader.startc C sB | j sd S d| _| j�� | j �� d | _ | j�� | j�� d S )NF)r r r �set�joinr �clearr r! r r r �stop1 s
zrepoloader.stopc C s | j �|� | j�� dS )z6Request to load the specified repository in backgroundN)r �appendr r" �r �pathr r r �load; s zrepoloader.loadc C s( | j r
| j �� r
t�d��| j�|d�S )z�Return a cached repo if available
This function must be called after fork(), where the loader thread
is stopped. Otherwise, the returned repo might be updated by the
loader thread.
s0 cannot obtain cached repo while loader is activeN)r �is_aliver �ProgrammingErrorr �peekr' r r r �get@ s
�zrepoloader.getc sv �j r9t�� �j�� �j r4�j�� z�j�� � W n ty$ Y nw t �
�j � �fdd�� �j s�j sd S d S )Nc s
�� � �S �N)�_loadr �r( r r r �<lambda>] s
z&repoloader._mainloop.<locals>.<lambda>) r �gc�collectr �waitr$ r �popleft�
IndexErrorr � callcatchr
r! r r0 r r M s
���zrepoloader._mainloopc C sr t �� }z| j�|�}W n ty t�| j|��� }Y nw t |� |j
� dd|t �� | � | j� ||� d S )Ns repocaches& loaded repo into cache: %s (in %.3fs)
)
r �timerr �pop�KeyErrorr �
repositoryr
�
unfiltered� _warmupcacher �log�insert)r r( r �repor r r r/ _ s �
�zrepoloader._loadN) �__name__�
__module__� __qualname__�__doc__r r r% r) r- r r/ r r r r r s
r c C sV | � � | j | jj | jj | jj | jj tjD ]}t� | |� q| j
� | � d S r. ) �
invalidateall� changelog�obsstore�_all�
successors� predecessors�childrenr �
cachefuncs�getrevs� _phasecache�
loadphaserevs)r@ �namer r r r= r s
r= c C s� |j }| j }d|v r|d |d< }|j |j_|j_d|v r,|d |d< }|j|j_d|v r?|d |d< }|j|j_dS dS )z/Copy cached attributes from srcrepo to destrepos changelogs obsstores _phasecacheN)�
_filecache�svfs�obj�opener� _realopener)�srcrepo�destrepo�
destfilecache� srcfilecache�cer r r � copycache s
�r[ )�
__future__r r r2 r � r r r r r �objectr r= r[ r r r r �<module> s [