| Server IP : 74.208.236.16 / Your IP : 216.73.217.15 Web Server : Apache System : Linux info 3.0 #1337 SMP Tue Jan 01 00:00:00 CEST 2000 all GNU/Linux User : u102440577 ( 7172810) PHP Version : 8.4.26 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /kunden/lib/python3/dist-packages/mercurial/__pycache__/ |
Upload File : |
�
6�h+ � �d � S SK Jr S SKrS SKrS SKrSSKJrJrJrJ r J
r
" S S5 r S r S r
g) � )� annotationsN� )�error�hg�obsolete�scmutil�utilc �B � \ rS rSrSrS rS rS rS rS r S r
S r S
r g ) �
repoloader� z�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 �� � UR 5 U l [ R " US9U l [
R " US9U l SU l [ R " 5 U l S U l g )N)�max)�maxlenF)
�copy�_uir � lrucachedict�_cache� collections�deque�_inqueue�
_accepting� threading�Event� _newentry�_thread)�self�uir s �5/usr/lib/python3/dist-packages/mercurial/repocache.py�__init__�repoloader.__init__ sQ � ��7�7�9����'�'�F�3�� � $�)�)��8��
� ���"� � �*����� � c �� � U R ( a eU R R S:X a g SU l [ R
" U R S9U l U R R 5 g )Nr T)�target)r r r r r �Thread� _mainloop�start�r s r r& �repoloader.start( sQ � ��<�<� � � �=�=� � �1� $� � ��� �'�'�t�~�~�>�� � � � ��� r! c � � U R ( d g SU l U R R 5 U R R 5 S U l U R
R
5 U R R
5 g )NF)r r r �set�joinr �clearr r' s r �stop�repoloader.stop1 sZ � ��|�|� � ��� ����� � � � ������ � � � ���� �
�
��� r! c �n � U R R U5 U R R 5 g)z6Request to load the specified repository in backgroundN)r �appendr r* �r �paths r �load�repoloader.load; s$ � � �
�
� � �T�"� ����� r! c �� � U R ( a5 U R R 5 ( a [ R " S5 eU R R US5 $ )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 �peekr1 s r �get�repoloader.get@ sL � � �<�<�D�L�L� 1� 1� 3� 3��(�(�C��
� �{�{� � ��d�+�+r! c �� ^ ^� T R ( a� [ R " 5 T R R 5 T R ( an T R R 5 T R R 5 m[ R " T R UU 4S j5 T R ( a Mn T R ( a M� g g ! [ a M" f = f)Nc �& >� TR T 5 $ �N)�_load)r2 r s ��r �<lambda>�&repoloader._mainloop.<locals>.<lambda>] s �� �D�J�J�t�4Dr! ) r �gc�collectr �waitr, r �popleft�
IndexErrorr � callcatchr r1 s `@r r% �repoloader._mainloopM s� �� ��o�o�
�J�J�L� �N�N� � � !��/�/����$�$�&�� �=�=�0�0�2�D� �!�!�$�(�(�,D�E�
�/�/�/� �o�o�o�� "� ���s �/C �
C%�$C%c � � [ R " 5 n U R R U5 n[ U5 UR R SSU[ R " 5 U-
5 U R R X5 g ! [ a2 [
R " U R U5 R 5 n N�f = f)Ns repocaches& loaded repo into cache: %s (in %.3fs)
)
r �timerr �pop�KeyErrorr �
repositoryr �
unfiltered� _warmupcacher �log�insert)r r2 r& �repos r r> �repoloader._load_ s� � ��
�
� �� >��;�;�?�?�4�(�D� �T�� ��� � � � 6� � �J�J�L�5� �
�
� � ���4�&�� � >��=�=����4�0�;�;�=�D� >�s �B
�
9C �C )r r r r r r N)
�__name__�
__module__� __qualname__�__firstlineno__�__doc__r r& r- r3 r9 r% r> �__static_attributes__� r! r r r s+ � �� � � � �
,�F�$'r! r c � � U R 5 U R U R R U R R U R R
U R R [ R H n[ R " X5 M U R R X R R 5 5 g r= )
�
invalidateall� changelog�obsstore�_all�
successors� predecessors�childrenr �
cachefuncs�getrevs� _phasecache�phase�tiprev)rQ �names r rN rN r s� � ������N�N��M�M����M�M� � ��M�M� � ��M�M����#�#������$� $� �����4� � �!6�!6�!8�9r! c �n � UR nU R nSU; a@ US =US' nUR =UR l UR R l SU; a% US =US' nUR UR l SU; a& US =US' nUR UR l gg)z/Copy cached attributes from srcrepo to destrepos changelogs obsstores _phasecacheN)�
_filecache�svfs�obj�opener�_inner)�srcrepo�destrepo�
destfilecache� srcfilecache�ces r � copycachers � s� � � �'�'�M��%�%�L��|�#�+7� �+E�E�
�l�#�b�/7�}�}�<����
����
�
�,��l�"�*6�{�*C�C�
�k�"�R� �m�m���� �� �%�-9�.�-I�I�
�n�%�� �
�
����
� &r! )�
__future__r r rA r � r r r r r r rN rs rY r! r �<module>rv s4 �� #� � � �� �W'� W'�v
:� &r!