a
©!cÊ ã @ sÒ 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 dlZe d¡Zdd „ Zd
d „ Zd d
„ Zdd„ Zdd„ ZG dd„ de ƒZ dS )é )Úabsolute_import)Úunicode_literals)ÚProcessLockErrorÚThreadLockErrorÚ LockError)Ú_)ÚmiscNÚdnfc C s6 t j ¡ s2t | d¡¡ ¡ }tj t
¡ d|¡} | S )Núutf-8Úlocks) r ÚutilZ am_i_rootÚhashlibZsha1ÚencodeZ hexdigestÚosÚpathÚjoinr Z getCacheDir)Zdir_Zhexdir© r ú,/usr/lib/python3.9/site-packages/dnf/lock.pyÚ
_fit_lock_dir& s
r c C s t tj t| ƒd¡d| ƒS )Nzdownload_lock.pidÚcachedir©Ú ProcessLockr r r r ©r Ú exit_on_lockr r r Úbuild_download_lock/ s ÿr c C s t tj t| ƒd¡d| ƒS )Nzmetadata_lock.pidÚmetadatar r r r r Úbuild_metadata_lock3 s ÿr c C s t tj t| ƒd¡d| ƒS )Nzrpmdb_lock.pidZRPMDBr )Z
persistdirr r r r Úbuild_rpmdb_lock8 s ÿr c C s t tj t| ƒd¡d| ƒS )Nz log_lock.pidÚlogr )Zlogdirr r r r Úbuild_log_lock= s ÿr c @ s> e Zd Zddd„Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ ZdS )r Fc C s& || _ d| _|| _|| _t ¡ | _d S )Nr )ÚblockingÚcountÚ descriptionÚtargetÚ threadingÚRLockÚ thread_lock)Úselfr# r" r r r r Ú__init__C s
zProcessLock.__init__c C s2 | j jdds d| j }t|ƒ‚| jd7 _d S )NF)r z'%s already locked by a different threadé )r& Úacquirer" r r! )r' Úmsgr r r Ú _lock_threadJ s
zProcessLock._lock_threadc
C s† t | jt jt jB d¡}zZzt |tjtjB ¡ W nL t y€ } z4|j
t
j krjW Y d }~W t |¡ dS ‚ W Y d }~n
d }~0 0 t
|d¡}t|ƒdkrÀt |t|ƒ d¡¡ |W t |¡ S z t|ƒ}W n( tyô tdƒ| j }t|ƒ‚Y n0 ||kr|W t |¡ S t d| t j¡sft |dt j¡ t |d¡ t |t|ƒ d¡¡ |W t |¡ S |W t |¡ S t |¡ 0 d S )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 Úopenr# ÚO_CREATÚO_RDWRÚfcntlZflockZLOCK_EXZLOCK_NBÚOSErrorÚerrnoZ EWOULDBLOCKÚcloseÚreadÚlenÚwriteÚstrr ÚintÚ
ValueErrorr r ÚaccessÚF_OKÚlseekÚSEEK_SETÚ ftruncate)r' ÚpidÚfdÚeZold_pidr+ r r r Ú _try_lockP sL
à
ç ý
ô
û
ýzProcessLock._try_lockc C s | j d8 _ | j ¡ d S ©Nr) )r! r& Úrelease)r' r r r Ú_unlock_threadz s zProcessLock._unlock_threadc C s¦ t j tj | j¡¡ | ¡ d}t ¡ }| |¡}||kr¢|dkrŒ| j
sj| ¡ d| j |f }t
||ƒ‚||krŒtdƒ| }t |¡ |}t d¡ | |¡}q4d S )Nr- z%s already locked by %dz*Waiting for process with pid %d to finish.r) )r r Z
ensure_dirr r Údirnamer# r, ÚgetpidrD r rG r" r r ÚloggerÚinfoÚtimeÚsleep)r' Zprev_pidZmy_pidrA r+ r r r Ú __enter__~ s"
zProcessLock.__enter__c G s" | j dkrt | j¡ | ¡ d S rE )r! r Úunlinkr# rG )r' Zexc_argsr r r Ú__exit__‘ s
zProcessLock.__exit__N)F) Ú__name__Ú
__module__Ú __qualname__r( r, rD rG rN rP r r r r r B s
*r ) Z
__future__r r Zdnf.exceptionsr r r Zdnf.i18nr Zdnf.yumr Z dnf.loggingr Zdnf.utilr4 r2 r
Zloggingr r$ rL Z getLoggerrJ r r r r r Úobjectr r r r r Ú s(