] @ s* d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m
Z
d d l Z y d d l Z Wn e
k
r d Z Yn Xd Z d Z d Z d Z d Z d Z d' Z Gd
d d e j Z Gd d
d
e Z Gd d d e Z Gd d d e j Z Gd d d e j Z Gd d d e Z Gd d d e j Z Gd d d e j Z Gd d d e j Z Gd d d e j Z Gd d d e j Z! Gd d! d! e! Z" Gd" d# d# e j Z# e r&Gd$ d% d% e$ Z% d S)( N)ST_DEVST_INOST_MTIMEi<# i=# i># i?# i < c @ sF e Z d Z d d d d Z d d Z d d Z d d
Z d S) BaseRotatingHandlerNFc C sD t j j | | | | | | | _ | | _ d | _ d | _ d S)N)logging FileHandler__init__modeencodingnamerrotator)selffilenamer r delay r -/opt/alt/python35/lib64/python3.5/handlers.pyr
5 s
z BaseRotatingHandler.__init__c C sV y0 | j | r | j t j j | | Wn t k
rQ | j | Yn Xd S)N)shouldRollover
doRolloverr r emit Exception handleError)r recordr r r r ? s
zBaseRotatingHandler.emitc C s+ t | j s | } n | j | } | S)N)callabler
)r Z default_nameresultr r r rotation_filenameM s
z%BaseRotatingHandler.rotation_filenamec C sH t | j s4 t j j | rD t j | | n | j | | d S)N)r r ospathexistsrename)r sourcedestr r r rotate` s zBaseRotatingHandler.rotate)__name__
__module__ __qualname__r
r r r# r r r r r / s
r c @ sC e Z d Z d d d d d d d Z d d Z d d
Z d S) RotatingFileHandlerar NFc C sA | d k r d } t j | | | | | | | _ | | _ d S)Nr r( )r r
maxBytes backupCount)r r r r) r* r r r r r r
z s
z RotatingFileHandler.__init__c C s3 | j r | j j d | _ | j d k rx t | j d d d D] } | j d | j | f } | j d | j | d f } t j j | rH t j j | r t j | t j
| | qH W| j | j d } t j j | rt j | | j | j | | j s/| j
| _ d S)Nr z%s.%dz.1)streamcloser* ranger baseFilenamer r r remover r# r _open)r iZsfndfnr r r r s$
z RotatingFileHandler.doRolloverc C s} | j d k r | j | _ | j d k ry d | j | } | j j d d | j j t | | j k ry d Sd S)Nr z%s
r+ )r- r2 r) formatseektelllen)r r msgr r r r s "z"RotatingFileHandler.shouldRollover)r$ r% r& r
r r r r r r r' u s r' c @ sa e Z d Z d d d d d d d d d Z d d Z d
d Z d d
Z d d Z d S)TimedRotatingFileHandlerhr+ r NFc
C s; t j | | d | | | j | _ | | _ | | _ | | _ | j d k rp d | _ d | _ d | _ nP| j d k r d | _ d | _ d | _ n#| j d
k r d | _ d | _ d | _ n | j d
k s | j d k rd | _ d | _ d | _ n | j j
d rd | _ t | j d k rIt d | j | j d d k so| j d d k rt d | j t
| j d | _ d | _ d | _ n t d | j t j | j t j | _ | j | | _ t j j | rt j | t } n t
t j } | j | | _ d S) Nr( Sr+ z%Y-%m-%d_%H-%M-%Sz-^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(\.\w+)?$Mr z%Y-%m-%d_%H-%Mz'^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(\.\w+)?$Hz %Y-%m-%d_%Hz!^\d{4}-\d{2}-\d{2}_\d{2}(\.\w+)?$DMIDNIGHTr z%Y-%m-%dz^\d{4}-\d{2}-\d{2}(\.\w+)?$W r5 zHYou must specify a day for weekly rollover from 0 to 6 (0 is Monday): %s06z-Invalid day specified for weekly rollover: %sz'Invalid rollover interval specified: %si i iQ i iQ i: )r r
upperwhenr* utcatTimeintervalsuffixextMatch
startswithr9
ValueErrorint dayOfWeekrecompileASCIIr r r statr timecomputeRollover
rolloverAt)
r r rG rJ r* r r rH rI tr r r r
sJ
& z!TimedRotatingFileHandler.__init__c C s | | j } | j d k s. | j j d r| j rI t j | } n t j | } | d } | d } | d } | d } | j d k r t } n( | j j d | j j
d | j j } | | d | d | } | d k r | t 7} | d d
} | | } | j j d r| }
|
| j k r|
| j k rN| j |
} n d |
| j d } | | d } | j s| d }
t j | d } |
| k r|
sd } n d } | | 7} | } | S)NrA rB r r r+ rC r i i iQ r, r, i)
rJ rG rM rH rU gmtime localtimerI _MIDNIGHTZhourZminutesecondrP )r currentTimer rX Z currentHourZ
currentMinuteZ
currentSecondZ
currentDayZ rotate_tsrZdayZ
daysToWait
newRolloverAtdstNow
dstAtRolloveraddendr r r rV sH
!
z(TimedRotatingFileHandler.computeRolloverc C s) t t j } | | j k r% d Sd S)Nr+ r )rO rU rW )r r rX r r r r H s z'TimedRotatingFileHandler.shouldRolloverc C s t j j | j \ } } t j | } g } | d } t | } xb | D]Z } | d | | k rM | | d } | j j | rM | j t j j | | qM W| j
t | | j k r g } n | d t | | j } | S)N.) r r splitr0 listdirr9 rL matchappendjoinsortr* ) r ZdirNameZbaseNameZ fileNamesr prefixZplenZfileNamerK r r r getFilesToDeleteT s
z)TimedRotatingFileHandler.getFilesToDeletec C s | j r | j j d | _ t t j } t j | d } | j | j } | j ro t j | } nM t j | } | d } | | k r | r d } n d } t j | | } | j | j
d t j | j | } t
j j | rt
j | | j | j
| | j d k rJx! | j D] } t
j | q3W| j sb| j | _ | j | } x | | k r| | j } qtW| j d k s| j j d r| j rt j | d
}
| |
k r| sd } n d } | | 7} | | _ d S) Nr+ i rg r rA rB r, r, ir, i)r- r. rO rU r^ rW rJ rH r] r r0 strftimerK r r r r1 r# r* ro r r2 rV rG rM ) r ra rd rX Z timeTupleZdstThenrf r4 src re r r r r k sH
+
z#TimedRotatingFileHandler.doRollover)r$ r% r& r
rV r ro r r r r r r; s
!6 I r; c @ s= e Z d Z d d d d d Z d d Z d d Z d S)
WatchedFileHandlerr( NFc C s< t j j | | | | | d \ | _ | _ | j d S)Nr+ r, r, )r, r, )r r r
devino _statstream)r r r r r r r r r
s zWatchedFileHandler.__init__c C s@ | j r< t j | j j } | t | t | _ | _ d S)N)r- r fstatfilenor r rs rt )r sresr r r ru s z WatchedFileHandler._statstreamc C s y t j | j } Wn t k
r0 d } Yn X| s^ | t | j k s^ | t | j k r | j d k r | j j | j j
d | _ | j | _ | j t
j j | | d S)N)r rT r0 FileNotFoundErrorr rs r rt r- flushr. r2 ru r r r )r r rx r r r r s
-
zWatchedFileHandler.emit)r$ r% r& r
ru r r r r r rr s rr c @ ss e Z d Z d d Z d d d Z d d Z d d Z d
d Z d d
Z d d Z d d Z
d S)
SocketHandlerc C s t j j | | | _ | | _ | d k r: | | _ n | | f | _ d | _ d | _ d | _ d | _ d | _
d | _ d S)NFg ?g >@g @) r Handlerr
hostportaddresssock closeOnError retryTime
retryStartretryMax retryFactor)r r} r~ r r r r
s zSocketHandler.__init__r+ c C s | j d k r* t j | j d | } n[ t j t j t j } | j | y | j | j Wn t k
r | j Yn X| S)Ntimeout)
r~ socketcreate_connectionr AF_UNIX SOCK_STREAM
settimeoutconnectOSErrorr. )r r r r r r
makeSocket s
zSocketHandler.makeSocketc C s t j } | j d k r$ d } n | | j k } | r y | j | _ d | _ Wnq t k
r | j d k r | j | _ n1 | j | j | _ | j | j k r | j | _ | | j | _ Yn Xd S)NT) rU r r r r r Z retryPeriodr r )r ZnowZattemptr r r createSocket s
zSocketHandler.createSocketc C se | j d k r | j | j ra y | j j | Wn( t k
r` | j j d | _ Yn Xd S)N)r r sendallr r. )r rq r r r send, s
zSocketHandler.sendc C s | j } | r | j | } t | j } | j | d L) r r6 dict__dict__
getMessagepoppickledumpsstructpackr9 )r r eidummydrq Zslenr r r
makePickle? s
zSocketHandler.makePicklec C sB | j r+ | j r+ | j j d | _ n t j j | | d S)N)r r r. r r| r )r r r r r r U s
zSocketHandler.handleErrorc C sF y | j | } | j | Wn t k
rA | j | Yn Xd S)N)r r r r )r r rq r r r r c s
zSocketHandler.emitc
C sR | j z6 | j } | r/ d | _ | j t j j | Wd | j Xd S)N)acquirer r. r r| release)r r r r r r. r s
zSocketHandler.closeN) r$ r% r& r
r r r r r r r. r r r r r{ s
r{ c @ s4 e Z d Z d d Z d d Z d d Z d S)DatagramHandlerc C s t j | | | d | _ d S)NF)r{ r
r )r r} r~ r r r r
s zDatagramHandler.__init__c C s= | j d k r t j } n t j } t j | t j } | S)N)r~ r r AF_INET
SOCK_DGRAM)r familyrq r r r r s
zDatagramHandler.makeSocketc C s3 | j d k r | j | j j | | j d S)N)r r sendtor )r rq r r r r s
zDatagramHandler.sendN)r$ r% r& r
r r r r r r r s r c * @ s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
d Z d Z d Z
d Z d Z d Z d Z d Z d Z d
Z d Z d Z d
Z d Z d Z d Z d Z d Z d Z d Z d e d e d e d e
d e d e d e d e d e d e d e d e i Z d! e d" e d# e d$ e d% e d& e d' e d( e
d) e d* e d+ e d, e d- e d. e d/ e d0 e d1 e d2 e d3 e d4 e d5 e i Z d6 d d7 d d8 d d9 d d: d i Z! d; e" f e d< d= d> Z# d? d@ Z$ dA dB Z% dC dD Z& dE dF Z' dG Z( dH Z) dI dJ Z* d< S)K
SysLogHandlerr r+ r5 rY rZ r[ r\ rC
ZalertZcritcriticaldebugZemergerrerrorinfoZnoticeZpanicwarnwarningZauthZauthprivZcrondaemonZftpZkernZlprZmailZnewsZsecurityZsysloguserZuucpZlocal0Zlocal1Zlocal2Zlocal3Zlocal4Zlocal5Zlocal6Zlocal7DEBUGINFOWARNINGERRORCRITICAL localhostNc C s t j j | | | _ | | _ | | _ t | t rl d | _ y | j | Wqt
k
rh YqXn"d | _ | d k r t j } | \ } } t j
| | d | } | s t
d x | D] } | \ } } } }
} d } }
y6 t j | | | }
| t j k r |
j | PWq t
k
re} z! | } |
d k rS|
j WYd d } ~ Xq Xq W| d k r|| |
| _ | | _ d S)NTFr z!getaddrinfo returns an empty list)r r| r
r facilitysocktype
isinstancestr
unixsocket_connect_unixsocketr r r getaddrinfor r r. )r r r r r} r~ Zressresafproto_sar r excr r r r
sB
! zSysLogHandler.__init__c C s | j } | d k r t j } t j t j | | _ y | j j | | | _ Wn t k
r | j j | j d k r t j } t j t j | | _ y | j j | | | _ Wn" t k
r | j j Yn XYn Xd S)N)r r r r r r r. r )r r Z use_socktyper r r r G s&
z!SysLogHandler._connect_unixsocketc C sD t | t r | j | } t | t r8 | j | } | d >| BS)NrY )r r facility_namespriority_names)r r priorityr r r encodePriority_ s
z SysLogHandler.encodePriorityc
C s= | j z! | j j t j j | Wd | j Xd S)N)r r r. r r| r )r r r r r. l s
zSysLogHandler.closec C s | j j | d S)Nr ) priority_mapget)r levelNamer r r mapPriorityw s zSysLogHandler.mapPriority Tc C sL y&| j | } | j r( | j | } | j r; | d 7} d | j | j | j | j } | j d } | j d } | | } | j r y | j j
| Wq%t k
r | j j | j
| j | j j
| Yq%Xn; | j t j k r| j j | | j n | j j | Wn t k
rG| j | Yn Xd S)N z<%d>zutf-8)r6 ident
append_nulr r r levelnameencoder r r r r. r r r r r r r r )r r r: Zprior r r r s.
zSysLogHandler.emit)+r$ r% r& Z LOG_EMERGZ LOG_ALERTZLOG_CRITZLOG_ERRZ LOG_WARNINGZ
LOG_NOTICEZLOG_INFOZ LOG_DEBUGZLOG_KERNZLOG_USERZLOG_MAILZ
LOG_DAEMONZLOG_AUTHZ
LOG_SYSLOGZLOG_LPRZLOG_NEWSZLOG_UUCPZLOG_CRONZ LOG_AUTHPRIVZLOG_FTPZ
LOG_LOCAL0Z
LOG_LOCAL1Z
LOG_LOCAL2Z
LOG_LOCAL3Z
LOG_LOCAL4Z
LOG_LOCAL5Z
LOG_LOCAL6Z
LOG_LOCAL7r r r SYSLOG_UDP_PORTr
r r r. r r r r r r r r r s 5
r c @ s= e Z d Z d d d d d Z d d Z d d Z d S) SMTPHandlerNg @c C s t j j | t | t t f r: | \ | _ | _ n | d | _ | _ t | t t f rw | \ | _ | _ n d | _ | | _
t | t r | g } | | _ | | _
| | _ | | _ d S)N)r r| r
r listtuplemailhostmailportusernamepasswordfromaddrr toaddrssubjectsecurer )r r r r r credentialsr r r r r r
s zSMTPHandler.__init__c C s | j S)N)r )r r r r r
getSubject s zSMTPHandler.getSubjectc C sY y3d d l } d d l m } d d l } | j } | sC | j } | j | j | d | j } | } | j | d s8 T
FL<*PbM9?@