← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/filelock/__pycache__/_marker.cpython-312.pyc
57 lines
�
c�bj� � �� � U d dl mZ d dlZd dlZd dlmZ d dlmZmZm Z ddl
m Z m Z ddl
mZmZ ddlmZ d Zd
ed < d Zd
ed< ed Z G d� de � Z G d� de� Zdd�Zdd�Zdd�Zg d�Zy)� )� annotationsN)�suppress)�Final�Literal�
NamedTuple� )� host_name�process_start_token)� SoftFileLock�_read_lock_file)� write_allz
filelock/2z
Final[str]� _PROTOCOLi���z
Final[int]�_MAX_PID)�lease�unknownc �Z � e Zd ZU dZded< ded< ded< dZd ed
< dZd ed < dZd
ed< y)� OwnerRecordz+The owner published in a protocol 2 marker.�int�pid�str�hostname� OwnerMode�modeN�
str | None�tokenz float | None�lease_duration�
int | None�start)�__name__�
__module__� __qualname__�__doc__�__annotations__r r r � � �g/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/filelock/_marker.pyr r s2 � �5� �H��M�
�O� �E�:� �#'�N�L�'� �E�:� r% r c �r � e Zd ZU dZded< ed d�� Zed
d�� Zedd�� Zdd�Z d d�Z
dd �Z dd
�Z y )�MarkerSoftFileLockzAAn existence lock whose marker carries a protocol 2 owner record.r � _owner_modec �" � | j � S )z�
The owner named by the marker on disk.
:returns: the published record, or ``None`` when no marker exists or its record is malformed or protocol 1
)� _read_owner��selfs r& �ownerzMarkerSoftFileLock.owner) s � � � � �!�!r% c �B � | j � x}�dS |j S )z�
The PID of the process holding this lock, read from the marker.
:returns: the PID, or ``None`` when no marker exists or its record is unreadable
N)r+ r �r- r. s r& r zMarkerSoftFileLock.pid3 s& � � "&�!1�!1�!3�3��<�t�K�%�)�)�Kr% c � � | j � }|duxr: |j t j � k( xr |j t � k( S )z�
Whether the marker on disk names this process.
:returns: ``True`` when the marker's PID and hostname match this process
N)r+ r �os�getpidr r r0 s r& �is_lock_held_by_usz%MarkerSoftFileLock.is_lock_held_by_us= sC � � � � �"���D� �_�U�Y�Y�"�)�)�+�%=�_�%�.�.�T]�T_�B_�_r% c �$ � | j � y)a-
Remove the marker whoever holds it, so a later contender can acquire.
Forced breaking voids mutual exclusion: the previous holder keeps running and keeps using whatever the lock
protects. Reserve it for an operator clearing a marker whose holder is known to be gone.
N)�
break_lockr, s r& � force_breakz MarkerSoftFileLock.force_breakH s � �
���r% c � � t t t � 5 t t | j
� d � cd d d � S # 1 sw Y y xY w)Nr )r �OSError�
ValueError� parse_markerr � lock_filer, s r& r+ z MarkerSoftFileLock._read_ownerQ s1 � �
�g�z�
*� ����� ?�� B�C� +�
*�
*��s �!A � A c �J � t |t | j � � � y )N)r
�
encode_marker�_published_record)r- �fds r& �_write_lock_infoz#MarkerSoftFileLock._write_lock_infoV s � ��"�m�D�$:�$:�$<�=�>r% c � � t t j � t � | j t t j � � �� S )N)r r r r )r r2 r3 r r) r
r, s r& r? z$MarkerSoftFileLock._published_recordY s4 � ��� � � � �[��!�!�%�b�i�i�k�2�
�
r% N)�return�OwnerRecord | None)rC r )rC �bool)rC �None)r@ r rC rF )rC r )
r r r! r" r# �propertyr. r r4 r7 r+ rA r? r$ r% r& r( r( # s_ � �K� ��
�"� �"� �L� �L� �`� �`���
?�
r% r( c � � t d| j � �d| j � �d| j � �g}| j � |j d| j � �� | j � |j d| j ��� | j � |j d| j � �� dj d� |D � � j � S ) z>Render an owner record as the bytes a protocol 2 marker holds.zpid=zhost=zmode=ztoken=z duration=zstart=� c 3 �& K � | ] }|� d ��� � y�w)�
Nr$ )�.0�lines r& � <genexpr>z encode_marker.<locals>.<genexpr>k s � �� �1�5�4�d�V�2�;�5�s �)
r r r r r �appendr r �join�encode)�record�liness r& r> r> b s� � �
�$�v�z�z�l�+�u�V�_�_�4E�-F�%�PV�P[�P[�}�H]� ^�E�
�|�|� �
� � �v�f�l�l�^�,�-�
� � �(�
� � �y��!6�!6� 9�:�;�
�|�|� �
� � �v�f�l�l�^�,�-�
�7�7�1�5�1� 1� 8� 8� :�:r% c �� � | r,| j � j � x}r |d t k7 ryi }|dd D ] }|j d� \ }}}|s y|||< �" t |� S )zcReturn the owner a protocol 2 marker names, or ``None`` when the record is malformed or protocol 1.r Nr �=)�strip�
splitlinesr � partition�
_build_record)�contentrS �fieldsrM �key� separator�values r& r; r; n ss � � �G�M�M�O�$>�$>�$@�@�5�@�U�1�X�QZ�EZ�� �F��a�b� �� $���s� 3� ��Y������s� � �
�� � r% c � � | j d� x}�y |dk( rdnd}| j d� }|rd| vry t | d � }d| v rt | d � nd }d| v rt | d � nd }d|cxk r t k sy y | j d � }|dk( r |� |�t j |� r|d
kD sy t ||||||� � S # t $ r Y y w xY w) Nr r r �hostr �durationr r r r )r r r r r r )�getr �floatr: r �math�isfiniter )r[ � publishedr r r ra r r s r& rY rY { s � �
�Z�Z��'�'� �0��!*�g�!5�g�9�D��z�z�&�!�H� �u�F�*����&��-� ��0:�f�0D�5��
�+�,�$��(/�6�(9��F�7�O�$�t��
�� �x� �� �� �J�J�w� �E� �w��E�M�X�-=�d�m�m�T\�F]�bj�mn�bn�� �3���E�Zb�jo� p�p�� � ���s �6C � C�C)r( r r r> r; )rR r rC �bytes)rZ r rC rD )r[ zdict[str, str]rC rD ) �
__future__r rd r2 �
contextlibr �typingr r r � _identityr r
�_softr r �_utilr
r r# r r r r( r> r; rY �__all__r$ r% r& �<module>ro ss �� "� � � � -� -� 5� 0� �
%� �:� $� ��*� �
�&� '� � �*� �<
� � <
�~ ;�
!�q�8 �r%