KOKINIO - MANAGER
Edit File: lock.cpython-312.opt-1.pyc
� �(f� � �� � d dl mZ d dl mZ d dlmZmZmZ d dlmZ d dl m Z d dl Z d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZ ej* d� Zd� Zd � Zd � Zd � Zd � Z G d � de � Z y)� )�absolute_import)�unicode_literals)�ProcessLockError�ThreadLockError� LockError)�_)�miscN�dnfc � � t j j � set j | j d� � j � }t j j t j � d|� } | S )N�utf-8�locks) r �util� am_i_root�hashlib�sha1�encode� hexdigest�os�path�joinr � getCacheDir)�dir_�hexdirs �-/usr/lib/python3.12/site-packages/dnf/lock.py� _fit_lock_dirr & sX � � �8�8� � � � � � �d�k�k�'� 2�3�=�=�?���w�w�|�|�D� ,� ,� .���@�� �K� c �l � t t j j t | � d� d| � S )Nzdownload_lock.pid�cachedir�� ProcessLockr r r r �r � exit_on_locks r �build_download_lockr# / �. � � �r�w�w�|�|�M�(�$;�=P�Q�!�|�#3� 5� 5r c �l � t t j j t | � d� d| � S )Nzmetadata_lock.pid�metadatar r! s r �build_metadata_lockr' 3 r$ r c �l � t t j j t | � d� d| � S )Nzrpmdb_lock.pid�RPMDBr )� persistdirr" s r �build_rpmdb_lockr+ 8 s. � � �r�w�w�|�|�M�*�$=�?O�P� �L� 0� 2� 2r c �l � t t j j t | � d� d| � S )Nz log_lock.pid�logr )�logdirr" s r �build_log_lockr/ = s- � � �r�w�w�|�|�M�&�$9�>�J� �,� .� 0� 0r c �2 � e Zd Zdd�Zd� Zd� Zd� Zd� Zd� Zy) r c �n � || _ d| _ || _ || _ t j � | _ y )Nr )�blocking�count� description�target� threading�RLock� thread_lock)�selfr5 r4 r2 s r �__init__zProcessLock.__init__C s. � � �� ��� �&��� �� �$�?�?�,��r c � � | j j d�� sd| j z }t |� �| xj dz c_ y )NF)r2 z'%s already locked by a different thread� )r8 �acquirer4 r r3 )r9 �msgs r � _lock_threadzProcessLock._lock_threadJ sA � �� � �'�'��'�7�;�d�>N�>N�N�C�!�#�&� &� � � �a�� r c � � t j | j t j t j z d� } t j |t j t j z � t j |d� }t |� dk( rEt j |t! |� j# d� � |t j |� S t% |� }||k( r|t j |� S t j, d|z t j. � s�t j0 |dt j2 � t j4 |d� t j |t! |� j# d� � |t j |� S |t j |� S # t $ r=}|j t j k( rY d }~t j |� y� d }~ww xY w# t& $ r$ t) d� | j z }t+ |� �w xY w# t j |� w xY w)Ni� ���� r r z�Malformed lock file found: %s. Ensure no other dnf/yum process is running and remove the lock file manually or run systemd-tmpfiles --remove dnf.conf.z /proc/%d/stat)r �openr5 �O_CREAT�O_RDWR�fcntl�flock�LOCK_EX�LOCK_NB�OSError�errno� EWOULDBLOCK�close�read�len�write�strr �int� ValueErrorr r �access�F_OK�lseek�SEEK_SET� ftruncate)r9 �pid�fd�e�old_pidr> s r � _try_lockzProcessLock._try_lockP s� � � �W�W�T�[�[�"�*�*�r�y�y�"8�%� @��% � �� � �B�� � �� � � =�>� �g�g�b�"�o�G��7�|�q� �����S��X�_�_�W� 5�6��2 �H�H�R�L�/ %� �g�,�� �#�~�� �H�H�R�L� �9�9�_�w� 6����@�����Q�� � �,�� � �R��#�����S��X�_�_�W� 5�6�� �H�H�R�L� � �H�H�R�L��E � ��7�7�e� /� /�/� �@ �H�H�R�L�? �� �� � %�� >� ?� CG�+�+�O�� ��n�$� %��* �H�H�R�L�s\ �5G �8AI �" H �-I � BI �0I � H � H�-I �H�H � I �-H=�=I � Ic �b � | xj dz c_ | j j � y �Nr< )r3 r8 �release)r9 s r �_unlock_threadzProcessLock._unlock_threadz s! � � � � �a�� � ��� � �"r c �2 � t j j t j j | j � � | j � d}t j � }| j |� }||k7 r�|dk7 rc| j s-| j � d| j |fz }t ||� �||k7 r%t d� |z }t j! |� |}t# j$ d� | j |� }||k7 r��y y )NrA z%s already locked by %dz*Waiting for process with pid %d to finish.r< )r r � ensure_dirr r �dirnamer5 r? �getpidr] r2 ra r4 r r �logger�info�time�sleep)r9 �prev_pid�my_pidrY r> s r � __enter__zProcessLock.__enter__~ s� � � �����B�G�G�O�O�D�K�K� 8�9� ������������n�n�V�$���V�m��b�y��}�}��'�'�)�3�t�7G�7G��6M�M�C�*�3��4�4��s�?�� H�I�S�Q�C��K�K��$� "�H� �J�J�q�M��.�.��(�C� �V�mr c � � | j dk( r t j | j � | j � y r_ )r3 r �unlinkr5 ra )r9 �exc_argss r �__exit__zProcessLock.__exit__� s) � � �:�:��?� �I�I�d�k�k� "� ��� r N)F) �__name__� __module__� __qualname__r: r? r] ra rl rp � r r r r B s! � �-�� (�T#�)�& r r ) � __future__r r �dnf.exceptionsr r r �dnf.i18nr �dnf.yumr � dnf.loggingr �dnf.utilrK rF r �loggingr r6 rh � getLoggerrf r r# r' r+ r/ �objectr rt r r �<module>r~ sm ��* '� '� G� G� � � � � � � � � � � � �� � �5� !���5�5� 2� 0� R �&� R r