3
ft`t @ s d dl mZ d dl mZ d dlmZ d dlmZmZ d dlm Z d dlZ
d dl Z
d dl Z
d dl
Z
d dlZ
d dlZd dlZd dlZd dlZejdZdd d
gd gd gd
gdd d gd Zd
d Zdd Zdd Zdd ZG dd dejZdS ) )absolute_import)unicode_literals)commands)_P_)miscNdnfmetadatadbcachez expire-cachepackages)r r r
z expire-cacheallc c sV xPt j| D ]B\}}}t jj|| }x(|D ] }t jj||}t jj|V q*W q W dS )z:Traverse dirpath recursively and yield relative filenames.N)oswalkpathrelpathjoinnormpath)dirpathrootdirsfilesbasefr r /usr/lib/python3.6/clean.py_tree1 s
r c s fdd| D S )z5Yield those filenames that match any of the patterns.c 3 s( | ] } D ]}t j||r
|V q
qd S )N)rematch).0r p)patternsr r < s z_filter..r )r r r )r r _filter: s r" c C sL d}xB|D ]:}t jj| |}tjtjjtd| t j
| |d7 }q
W |S )z(Remove the given filenames from dirpath.r zRemoving file %s ) r
r r loggerlogr loggingZDDEBUGr r Zunlink_f)r r countr r r r r _clean? s
r( c s0 t jjd fdd| D }tdd |D S )z:Return the repo IDs that have some cached metadata around.r c 3 s | ]}t j |V qd S )N)r r )r r )metapatr r r! M s z _cached_repos..c s s | ]}|r|j d V qdS )ZrepoidN)group)r mr r r r! N s )r repo CACHE_FILESset)r Zmatchesr )r) r
_cached_reposJ s r/ c @ s0 e Zd ZdZd ZedZedd Zdd Z dS )
CleanCommandzSA class containing methods needed by the cli to execute the
clean command.
cleanzremove cached datac C s | j ddtj tdd d S )Ntype+zMetadata type to clean)nargschoiceshelp) add_argument _CACHE_TYPESkeysr )parserr r r
set_argparserY s zCleanCommand.set_argparserc C sf | j jj}tjj|d}tjj|d}tjj| j jjd}x$y|oJ|oJ| t dd | j
j D }t t
|}tjtddj| d|krt|}| j jjj| |jd tjtd dd |D }t|t||} tjtd
d | | d S Q R X W q> tjj k
r\ }
z:| j jj sHtd |
j } tj| t j d
n|
W Y d d }
~
X q>X q>W d S )NTc s s | ]}t | D ]
}|V qqd S )N)r8 )r ctr r r r! g s z#CleanCommand.run..zCleaning data: z expire-cachezCache was expiredc S s g | ]}t jj| qS r )r r, r- )r r= r r r
q s z$CleanCommand.run..z%d file removedz%d files removedz*Waiting for process with pid %d to finish. )!r Zconfcachedirr lockZbuild_metadata_lockZbuild_download_lockZbuild_rpmdb_lockZ
persistdirr. Zoptsr2 listr r$ debugr r r/ Z_repo_persistorZexpired_to_addupdateremoveinfor( r" r
exceptionsZ LockErrorZ exit_on_lockpidtimeZsleep) selfrA Zmd_lockZ
download_lockZ
rpmdb_locktypesr Zexpiredr r' emsgr r r run_ s2
zCleanCommand.runN)r1 )
__name__
__module__ __qualname____doc__aliasesr Zsummary staticmethodr; rO r r r r r0 Q s
r0 ) Z
__future__r r Zdnf.clir Zdnf.i18nr r Zdnf.yumr r Zdnf.exceptionsZdnf.lockZ dnf.loggingZdnf.repor& r
r rJ Z getLoggerr$ r8 r r" r( r/ ZCommandr0 r r r r s0