/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
New Directory
Upload File
HOME
a �+�b� � @ 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 Z lrucachedict�_cache� collections�deque�_inqueue� _accepting� threading�Event� _newentry�_thread)�self�uir � r �9/usr/lib64/python3.9/site-packages/mercurial/repocache.py�__init__ s zrepoloader.__init__c C s4 | j jdkrd S d| _tj| jd�| _| j�� d S )Nr T)�target)r r r r �Thread� _mainloopr �start�r r r r r ( s zrepoloader.startc C sB | j s d 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 �� rt�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 ZProgrammingErrorr �peekr& r r r �get@ s �zrepoloader.getc sn �j rjt�� �j�� �j r �j�� z�j�� � W n tyL Y q Y n0 t � �j � �fdd�� qq d S )Nc s �� � �S �N)�_loadr �r' r r r �<lambda>] � z&repoloader._mainloop.<locals>.<lambda>) r �gcZcollectr �waitr# r �popleft� IndexErrorr Z callcatchr r r r. r r M s zrepoloader._mainloopc C sr t �� }z| j�|�}W n$ ty< t�| j|��� }Y n0 t |� |j � dd|t �� | � | j� ||� d S )Ns repocaches& loaded repo into cache: %s (in %.3fs) ) r Ztimerr �pop�KeyErrorr Z repositoryr Z 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� | |� q4| j � | � d S r, ) Z invalidateallZ changelogZobsstoreZ_allZ successorsZ predecessorsZchildrenr Z cachefuncsZgetrevsZ _phasecacheZ loadphaserevs)r: �namer r r r7 r s r7 c C s~ |j }| j }d|v r6|d |d< }|j |j_|j_d|v rX|d |d< }|j|j_d|v rz|d |d< }|j|j_dS )z/Copy cached attributes from srcrepo to destrepos changelogs obsstores _phasecacheN)Z _filecacheZsvfs�obj�openerZ _realopener)ZsrcrepoZdestrepoZ destfilecacheZ srcfilecacheZcer r r � copycache s rB )Z __future__r r r1 r � r r r r r �objectr r7 rB r r r r �<module> s [