3
ft`r( @ s d dl mZ d dl mZ d dlZd dlZd dlZd dlZd dlZ d dl
Z
d dl Z
d dl Z d dl
Z
d dlZd dlZd dlZdZe
jZe
jZe
jZe
jZe
jZdZdZdZdZd d
ZG d d d e Z ee
je
je
je
je
je
jeeeed
Z dd Z ee
je
jdZ dd Z!dd Z"d%Z#dd Z$G dd de
j%j&Z'dd Z(d d Z)G d d d e Z*G d!d" d"e Z+e j,j-j.ee j,j-j/ee j,j-j0ee j,j-j1ee j,j-j2ee j,j-j3ee j,j-j4eiZ5G d#d$ d$e j,j-Z6e6 Z7e j,j8j9e7 dS )& )absolute_import)unicode_literalsNd c s dd fdd}|S )zGMethod decorator turning the method into noop on second or later calls.c _ s d S )N )Z_argsZ_kwargsr r /usr/lib/python3.6/logging.pynoop3 s zonly_once..noopc s" | f|| t | j d S )N)setattr__name__)selfargskwargs)funcr r r
swan_song5 s z only_once..swan_songr )r r r )r r r
only_once1 s r c @ s e Zd Zdd Zdd ZdS )_MaxLevelFilterc C s
|| _ d S )N) max_level)r r r r r
__init__; s z_MaxLevelFilter.__init__c C s |j | jkrdS dS )Nr )Zlevelnor )r recordr r r
filter> s z_MaxLevelFilter.filterN)r
__module__ __qualname__r r r r r r
r : s r ) r r r r r r
c C s t j| tS )N)_VERBOSE_VAL_MAPPINGgetTRACE)
cfg_errvalr r r
_cfg_verbose_val2levelQ s r% )r r r c C s t j| tjS )N)_ERR_VAL_MAPPINGr" loggingWARNING)r$ r r r
_cfg_err_val2level^ s r) c C s | d S )Nz.gzr )namer r r
compression_namerc s r+ i c C s\ t | d>}tj |d&}x |jt}|s,P |j| q W W d Q R X W d Q R X tj| d S )Nrbwb)opengzipread
CHUNK_SIZEwriteosremove)sourcedestZsfZwfdatar r r
compression_rotatorj s
"r9 c s& e Zd Zd fdd Zdd Z ZS )
MultiprocessRotatingFileHandlerar NFc s. t t| j|||||| tjjdd| _d S )Nz /var/log/T)superr: r dnflockZbuild_log_lock rotate_lock)r filenamemodemaxBytes backupCountencodingZdelay) __class__r r
r v s
z(MultiprocessRotatingFileHandler.__init__c C s xyR| j |rD| j* tj| jj}| j tj| j| W d Q R X tj j
| | d S t j j
t j jfk
r~ tjd Y q tk
r | j| d S X qW d S )Ng{Gz?)ZshouldRolloverr? r4 statZ baseFilenamest_modeZ
doRolloverchmodr' Z FileHandleremitr=
exceptionsZProcessLockErrorZThreadLockErrortimeZsleep ExceptionZ handleError)r r rA r r r
rI { s
z$MultiprocessRotatingFileHandler.emit)r; r r NF)r
r r r rI
__classcell__r r )rE r
r: u s r: c C sl t jj| s,tjjt jj| tjj| t| ||d}t j
dd}t j |_
|j| |rht|_t|_|S )N)rB rC z%%(asctime)s %(levelname)s %(message)sz%Y-%m-%dT%H:%M:%S%z)r4 pathexistsr= utilZ
ensure_dirdirnameZtouchr: r' Z FormatterrK Z localtimeZ converterZ setFormatterr9 Zrotatorr+ Znamer)logfilelog_size
log_rotate log_compresshandlerZ formatterr r r
_create_filehandler s
rW c C s | j ttjj d S )N)logINFOr= constZ
LOG_MARKER)Zloggerr r r
_paint_mark s r[ c @ sB e Zd Zdd Zedd Zedd Zedd Zd
d
d Zd S )Loggingc C sP d | _ | _tjtd tjtd tjtd tjtd tjd dt_ d S )NDDEBUGSUBDEBUGr# ALLTF)
stdout_handlerstderr_handlerr' Z addLevelNamer] r^ r# r_ ZcaptureWarningsZraiseExceptions)r r r r
r s
zLogging.__init__c C st t jd}|jt t jtj}|jt |jt t j
|j | || _ t jtj
}|jt
|j | || _d S )Nr= )r' getLoggersetLevelr# Z
StreamHandlersysstdoutrY Z addFilterr r(
addHandlerr` stderrra )r
logger_dnfre rg r r r
_presetup s
zLogging._presetupc C s t jd}|jt tjj|tjj }t
||||}|j| |j | t jd} | j | t jd}
|
jt tjj|tjj }t
||||}|
j | t
jjj ||tk t jd} d| _| jt tjj|tjj}t
||||}| j | d S )Nr= z py.warningslibrepozdnf.rpmF)r' rb rc r# r4 rN joinr= rZ ZLOGrW rf Z LOG_LIBREPOlibdnfZrepoZ
LibrepoLogr_ Z propagater^ ZLOG_RPM) r
logfile_levellogdirrS rT rU rh rR rV logger_warningsZlogger_librepo
logger_rpmr r r
_setup_file_loggers s(
zLogging._setup_file_loggersc C s | j | j||||| tjd}|j| j tjd} | j| j | j| j tjd}
| jjt | jjt t |
t | | jj| | jj| d S )Nz py.warningszdnf.rpmr= )
ri rq r' rb rf ra r` rc r( r[ ) r Z
verbose_levelZ error_levelrm rn rS rT rU ro rp rh r r r
_setup s
zLogging._setupFc
C sf t |j}t|j}t |j}|j}|j}|j}|j} |rL| j ||||| S | j
||||||| S d S )N) r% Z
debuglevelr) Z
errorlevelZ logfilelevelrn rS rT rU rq rr )
r ZconfZfile_loggers_onlyZverbose_level_rZ
error_level_rZlogfile_level_rrn rS rT rU r r r
_setup_from_dnf_conf s
z Logging._setup_from_dnf_confN)F) r
r r r r ri rq rr rs r r r r
r\ s
r\ c @ s e Zd Zdd Zdd ZdS )Timerc C s || _ tj | _d S )N)whatrK start)r ru r r r
r s zTimer.__init__c C s6 t j | j }d| j|d f }tjdjt| d S )Nztimer: %s: %d msi r= )rK rv ru r' rb rX r] )r Zdiffmsgr r r
__call__ s zTimer.__call__N)r
r r r rx r r r r
rt s rt c s$ e Zd Z fddZdd Z ZS )LibdnfLoggerCBc s* t t| j tjd| _tjd| _d S )Nr= rj )r< ry r r' rb _dnf_logger_librepo_logger)r )rE r r
r s zLibdnfLoggerCB.__init__c G sf t |dkr|\}}nt |dkr.|\}}}}|tjjjkrP| jjt| | n| jjt| | dS )zoLog message.
source -- integer, defines origin (libdnf, librepo, ...) of message, 0 - unknown
r r N) lenrl utilsLoggerZLOG_SOURCE_LIBREPOr{ rX _LIBDNF_TO_DNF_LOGLEVEL_MAPPINGrz )r r6 r levelmessagerK pidr r r
r3 s
zLibdnfLoggerCB.write)r
r r r r3 rM r r )rE r
ry s ry i ):Z
__future__r r Zdnf.exceptionsr= Z dnf.constZdnf.lockZdnf.utilZ libdnf.reporl r' Zlogging.handlersr4 rd rK warningsr0 Z
SUPERCRITICALZCRITICALZERRORr( rY DEBUGr] r^ r# r_ r objectr r! r% r& r) r+ r2 r9 ZhandlersZRotatingFileHandlerr: rW r[ r\ rt r} r~ ZLevel_CRITICALZ Level_ERRORZ
Level_WARNINGZ Level_NOTICEZ
Level_INFOZ Level_DEBUGZ Level_TRACEr ry ZlibdnfLoggerCBZLogZ setLoggerr r r r
sv
a