֦i v d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
Z
m Z d dl Z d dl
Z
d dlZdZdZdZdZdZdZdZ G d d
ej, Z G d d e Z G d
de Z G d dej, Z G d dej6 Z G d de Z G d dej6 Z G d dej6 Z G d dej6 Z G d d ej6 Z! G d d ej6 Z" G d d e" Z# G d! d"ej6 Z$ G d# d$e% Z&y)% N)ST_DEVST_INOST_MTIMEi<# i=# i># i?# i Q c 0 e Zd Z dZdZddZd Zd Zd Zy)BaseRotatingHandlerNc z t j j | ||||| || _ || _ || _ y )Nmodeencodingdelayerrors)logging FileHandler__init__r r r selffilenamer r r
r s )/usr/lib64/python3.12/logging/handlers.pyr z BaseRotatingHandler.__init__6 sG $$T8$.6e,2 % 4
c | j | r| j t j j | | y # t
$ r | j
| Y y w xY wN)shouldRollover
doRolloverr r emit Exception handleErrorr records r r zBaseRotatingHandler.emitA sW %""6*! $ $T6 2 % V $ %s AA A"!A"c \ t | j s|}|S | j | }|S r )callablenamer)r default_nameresults r rotation_filenamez%BaseRotatingHandler.rotation_filenameO s6
#!F
ZZ -F
r c t | j s7t j j | rt j
|| y y | j || y r )r! rotatorospathexistsrename)r sourcedests r rotatezBaseRotatingHandler.rotateb sH %ww~~f% &$' &
LL &r )NFN) __name__
__module__ __qualname__r" r' r r r% r. r r r r - s'
EG % &'r r c & e Zd Z ddZd Zd Zy)RotatingFileHandlerNc |dkD rd}d|vrt j | }t j | ||||| || _ || _ y )Nr abr r
r )io
text_encodingr r maxBytes backupCount)r r r r; r< r r
r s r r z RotatingFileHandler.__init__| s\ 2 a<D d?''1H$$T8TH+0 % A
&r c 8 | j r!| j j d | _ | j dkD r:t | j dz
dd D ] }| j d| j
|fz }| j d| j
|dz fz }t j j | sft j j | rt
j | t
j || | j | j
dz }t j j | rt
j | | j | j
| | j s| j | _ y y )Nr z%s.%dz.1)streamcloser< ranger% baseFilenamer( r) r* remover+ r. r
_open)r isfndfns r r z RotatingFileHandler.doRollover s= ;; KK DK a 4++a/B7,,W8I8I17M-MN,,W8I8I89A8? .? @77>>#&ww~~c* #IIc3' 8 (():):T)ABCww~~c" # KK))3 /zz **,DK r c | j | j | _ | j dkD r| j j }|syd| j | z }|t | z | j k\ rTt j j | j r*t j j | j syyy)Nr Fz%s
T) r@ rE r; tellformatlenr( r) r* rC isfile)r r posmsgs r r z"RotatingFileHandler.shouldRollover s ;; **,DK ==1 ++""$C 4;;v..CSX~ .77>>$"3"34RWW^^DL]L]=^ r )r6 r r NFN)r/ r0 r1 r r r r2 r r r4 r4 w s! DE48"'H'.r r4 c 4 e Zd Z ddZd Zd Zd Zd Zy)TimedRotatingFileHandlerNc
t j | }t j | |d||| |j | _ || _ || _ || _ | j
dk( rd| _ d| _
d}
n=| j
dk( rd| _ d | _
d
}
n | j
d k( rd | _ d
| _
d}
n| j
dk( s| j
dk( rd| _ d| _
d}
n| j
j d rd| _ t | j
dk7 rt d| j
z | j
d dk s| j
d dkD rt d| j
z t | j
d | _ d| _
d}
nt d| j
z t! j" |
t j$ | _ | j |z | _ | j( }t* j, j/ | r t+ j0 | t2 } n t t5 j4 } | j7 | | _ y ) Nr6 r8 Sr> z%Y-%m-%d_%H-%M-%Sz0(?H
YY#
j!8 (DM$DK8H
YY
!
!#
& ,DM499~" !knrnwnw!wxxyy|c!TYYq\C%7 !PSWS\S\!\]] 1 .DN$DK8H F RS S
8RXX6
0
$$
77>>( #!(+ADIIK A ..q1r c
|| j z }| j dk( s | j j d r| j rt j
| }nt j | }|d }|d }|d }|d }| j t }nJ| j j dz | j j z dz | j j z }||dz |z dz |z z
} | dk r| t z
} |d z d
z }|| z }| j j d rk|}
|
| j k7 r@|
| j k r| j |
z
} nd|
z
| j z d z } || t z z
}|| j t d
z z
z
}n|| j t z
z
}| j sK|d } t j | d }
| |
k7 r)| s d }t j |d
z
d sd}nd
}||z
}|S )NrY rZ rU r r> r? rW )
rb r_ rd r` rm gmtime localtimera _MIDNIGHThourminutesecondrg )r currentTimer$ rp currentHour
currentMinute
currentSecond
currentDay rotate_tsrday
daysToWaitdstNow
dstAtRolloveraddends r rn z(TimedRotatingFileHandler.computeRollover s t}}, 99
"dii&:&:3&?xxKK ,NN;/A$K aDM aDM1J{{" % "kk . . 3dkk6H6H H" LKK&& ' kB . >" D AAv Y (1n 1
1_F yy##C( $..(T^^+%)^^c%9
%&Wt~~%=%A
j9 44F$--)a-77$--)33882 $v 6r :
]*!!& #~~fTk :2 >%&F!%f$F
r c 2 t t j }|| j k\ rjt j j | j r@t j j | j s| j | | _ yyy)NFT) rf rm ro r( r) r* rC rM rn )r r rp s r r z'TimedRotatingFileHandler.shouldRollovere sm
ww~~d / /0 HYHY9Z #'"6"6q"9 r c t j j | j \ }}t j | }g }| j
q|dz }t
| }|D ][ }|d | |k( s ||d }| j j | s-|j t j j || ] n|D ] }| j j | } | s!| j | j dz | d z }
t j j |
|k( r0|j t j j || | j j || j dz } | r t
| | j k rg }|S |j |d t
| | j z
}|S )N.r r> )r( r) splitrC listdirr" rL rk fullmatchappendjoinsearchbasenamestartr< sort) r dirNamebaseName fileNamesr$ prefixplenfileNamerc mrH s r getFilesToDeletez)TimedRotatingFileHandler.getFilesToDeletex s
GGMM$*;*; <JJw' :: ^Fv;D %ET?f, %de_F}}..v6
bggll7H&EF & &
MM((2 **T%6%6%># ;; KK DK D%%s+ a **, ! -zz **,DK ..{;r )hr> r NFFNN)r/ r0 r1 r rn r r r r2 r r rQ rQ s2 DE?C A2FKZ&$L&@g @) r Handlerr hostportaddresssock closeOnError retryTime
retryStartretryMax retryFactorr r r s r r zSocketHandler.__init__ sn & < DL $>63E3EFF g &
t||,
s 5B B-c t j }| j d}n|| j k\ }|r | j | _ d | _ y y # t $ r} | j | j
| _ nH| j | j z | _ | j | j kD r| j | _ || j z | _ Y y w xY wNT) rm r r r r r retryPeriodr r )r nowattempts r createSocketzSocketHandler.createSocketG s
iik >> !Gdnn,G
8 OO - !%
8>>)'+D$'+'7'7$:J:J'JD$''$--7+/==(!$t'7'7!7
8s A BCCc | j | j | j r | j j | y y # t $ r$ | j j d | _ Y y w xY wr )r r sendallr rA r r s r sendzSocketHandler.sendc sj 99 99
! !!!$
! !
!s A *A54A5c > |j }|r| j | }t |j }|j |d< d |d< d |d< |j dd t
j |d }t j dt | }||z S )NrO argsexc_infomessager> z>L) r rK dict__dict__
getMessagepoppickledumpsstructpackrL )r r eidummydr slens r
makePicklezSocketHandler.makePicklev s __
KK'E
!$$&%& *
i LLA {{4Q(axr c | j r.| j r"| j j d | _ y t j j | | y r )r r rA r r r r s r r zSocketHandler.handleError sA IIOO DI OO ' 'f 5r c | j | }| j | y # t $ r | j | Y y w xY wr )r r r r )r r r s r r zSocketHandler.emit sB %'A IIaL % V $ %s "& AAc | j | j }|rd | _ |j t j j | | j y # | j w xY wr )acquirer rA r r releaser r s r rA zSocketHandler.close sX
99D
OO ! !$ ' LLNDLLN AA( (A:N)r> ) r/ r0 r1 r r r r r r r rA r2 r r r r s/
2"88!&, 6
% r r c e Zd Z d Zd Zd Zy)DatagramHandlerc B t j | || d| _ y )NF)r r r r s r r zDatagramHandler.__init__ s# tT40 !r c | j t j }nt j }t j |t j }|S r )r r r AF_INET
SOCK_DGRAM)r familyr s r r zDatagramHandler.makeSocket s@ 99 ^^F^^F MM&&"3"3 4r c | j | j | j j || j y r )r r sendtor r s r r zDatagramHandler.send s7 99 DLL)r N)r/ r0 r1 r r r r2 r r r r s "
*r r c
x e Zd Z dZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZdZdZd Zd
Zd Zd Zd
ZdZdZdZdZdZ dZ dZ dZ dZ dZ!dZ"eeee
eeee eeeed Z#i deded ed ed ed ed e d!ed"e
d#ed$ed%ed&ed'ed(e d)ed*ee e e e e e!e"d+Z$d,d-d.d/d0d1Z%d2e&fe d3fd4Z'd5 Z(d6 Z)d7 Z*d8 Z+d9 Z,d:Z-d;Z.d< Z/y3)=
SysLogHandlerr r> r[ rr rs rt ru rv
) alertcritcriticaldebugemergerrerrorinfonoticepanicwarnwarningauthauthprivconsolecrondaemonftpkernlprmailnewsntpsecurityz solaris-cronsysloguseruucplocal0)local1local2local3local4local5local6local7r
r r r r )DEBUGINFOWARNINGERRORCRITICAL localhostNc t j j | || _ || _ || _ d | _ | j y r )r r r r facilitysocktyper r )r r r4 r5 s r r zSysLogHandler.__init__M sC
&
r c L | j }|t j }t j t j | | _ | j j | || _ y # t
$ r | j j
| j t j }t j t j | | _ | j j | || _ Y y # t
$ r | j j
w xY ww xY wr )r5 r r r r r rA r )r r use_socktypes r _connect_unixsocketz!SysLogHandler._connect_unixsocketb s }} !,,L mmFNNLA KK ( (DM
KK }}(!--L -- EDK
##G, ,
!!#
s "A, ,A)D#"C::%D D#c F | j }| j }t |t rd| _ | j | y d| _ |t j }|\ }}t j ||d| }|s t
d |D ]K }|\ }}}} }
d x} } t j ||| } |t j k( r| j |
n | | _ || _ y # t $ r Y y w xY w# t $ r }
|
} | | j Y d }
~
d }
~
ww xY w)NTFr z!getaddrinfo returns an empty list)
r r5
isinstancestr
unixsocketr8 r r r getaddrinfor r rA )r r r5 r r ressresafproto_sar r excs r r zSysLogHandler.createSocketz s3 ,,== gs # "DO
((1 $DO !,, JD$%%dD!X>D ABB-0*HeQ !!d%!==Xu=D 6#5#55 R( DK $DM3
$ % C'
%s) C* ;C9* C65C69 D DD c t |t r| j | }t |t r| j | }|dz |z S )Nrr )r: r; facility_namespriority_names)r r4 prioritys r encodePriorityz SysLogHandler.encodePriority sL h $**84H h $**84HA
))r c | j | j }|rd | _ |j t j j | | j y # | j w xY wr )r r rA r r r r s r rA zSysLogHandler.close sX
;;D "
OO ! !$ ' LLNDLLNr c < | j j |d S )Nr ) priority_mapget)r levelNames r mapPriorityzSysLogHandler.mapPriority s" $$Y ::r Tc | j | }| j r| j |z }| j r|dz
}d| j | j | j |j z }|j d }|j d }||z }| j s| j | j r | j j | y | j t j" k( r'| j j% || j y | j j' | y # t $ rS | j j | j | j | j j | Y y w xY w# t( $ r | j+ | Y y w xY w)N z<%d>utf-8)rK ident
append_nulrI r4 rO levelnameencoder r r< r r rA r8 r r5 r r r r r )r r rO prios r r zSysLogHandler.emit sk %++f%Czzjj3&v
D / /
040@0@AQAQ0R T TD;;w'D**W%C*C;;!!#*KK$$S)
&"3"33 ""3 5 ##C( *KK%%',,T\\:KK$$S)* % V $ %s> CF# E $AF# (F# AF F# F F# #G ?G )0r/ r0 r1 LOG_EMERG LOG_ALERTLOG_CRITLOG_ERR LOG_WARNING
LOG_NOTICELOG_INFO LOG_DEBUGLOG_KERNLOG_USERLOG_MAIL
LOG_DAEMONLOG_AUTH
LOG_SYSLOGLOG_LPRLOG_NEWSLOG_UUCPLOG_CRON LOG_AUTHPRIVLOG_FTPLOG_NTP LOG_SECURITY LOG_CONSOLE LOG_SOLCRON
LOG_LOCAL0
LOG_LOCAL1
LOG_LOCAL2
LOG_LOCAL3
LOG_LOCAL4
LOG_LOCAL5
LOG_LOCAL6
LOG_LOCAL7rG rF rL SYSLOG_UDP_PORTr r8 r rI rA rO rT rU r r2 r r r r s $ IIHGKJHI HHHJHJGHHHLGGLKK JJJJJJJJ
N
!
"
#
$ #""""""1
N< L !,_ ="T *0,%\ * ;
EJ&%r r c $ e Zd Z ddZd Zd Zy) SMTPHandlerNc t t j j | t |t t
f r|\ | _ | _ n|d c| _ | _ t |t t
f r|\ | _ | _ nd | _ || _
t |t r|g}|| _ || _
|| _ || _ y r )r r r r: listtuplemailhostmailportusernamepasswordfromaddrr; toaddrssubjectsecurer )r r r r r credentialsr r s r r zSMTPHandler.__init__ s " & hu
.+3 (DM4=+3T (DM4= kD%= 1+6 (DM4= DM
gs # iG r c | j S r )r r s r
getSubjectzSMTPHandler.getSubject s ||r c dd l }ddlm} dd l}| j }|s |j
}|j
| j || j } | }| j |d< dj | j |d< | j | |d< |j j |d< |j | j! | | j" r| j$ idd l} | j$ d } | j$ d }
|j+ |
|
} |j- |j/ | |j- |j1 | j" | j2 |j5 | |j7 y # t( $ r d } Y w xY w# t( $ r d }
Y w xY w# t8 $ r | j; | Y y w xY w) Nr ) EmailMessager From,ToSubjectDater> )certfilekeyfilecontext) smtplib
email.messager email.utilsr SMTP_PORTSMTPr r r r r r utilsry set_contentrK r r ssl
IndexError_create_stdlib_contextehlostarttlsloginr send_messagequitr r ) r r r r emailr smtprO r r r r s r r zSMTPHandler.emit) s
' % 2 ==D ((<<
tT\\<JD .C --CK .CI !__V 4C N ++//1CK OODKK / 0}};;* '"&++a.(#';;q> " 8 8!)7 9 G IIKMM'M2IIK
4==$--8 c " IIK! & '"&'
& (#'( % V $ %sU C1G 5F! F2 B G ! F/,G .F//G 2 G =G ?G G G G )NNg @)r/ r0 r1 r r r r2 r r r{ r{ s 9<" H -%r r{ c 4 e Zd Z ddZd Zd Zd Zd Zd Zy) NTEventLogHandlerNc
t j j | dd l}dd l}|| _ || _ |sxt j j | j j }t j j |d }t j j |d d }|| _ || _
| j j ||| |j" | _ t j& |j( t j* |j( t j, |j. t j0 |j" t j2 |j" i| _ y # t $ r}t! |dd dk7 r Y d }~d }~ww xY w# t6 $ r t9 d d | _ Y y w xY w)Nr zwin32service.pydwinerrorrt zWThe Python Win32 extensions for NT (service, event logging) appear not to be available.) r r r win32evtlogutil win32evtlogappname_welur( r) r __file__r dllnamelogtypeAddSourceToRegistryr getattrEVENTLOG_ERROR_TYPEdeftyper- EVENTLOG_INFORMATION_TYPEr. r/ EVENTLOG_WARNING_TYPEr0 r1 typemap ImportErrorprint)r r r r r r es r r zNTEventLogHandler.__init__b sX & /"DL(DJ ''--
(;(;< ''--
3 '',,wqz3FG"DL"DL
..wI '::DL
+"G"G +"G"G+"C"C
+"A"A +"A"A DL
1j$/14 5
?
@ DJ s= B F E8 BF 8 F FF F F F=<F=c y)Nr> r2 r s r getMessageIDz NTEventLogHandler.getMessageID s r c y)Nr r2 r s r getEventCategoryz"NTEventLogHandler.getEventCategory s r c d | j j |j | j S r )r rM levelnor r s r getEventTypez NTEventLogHandler.getEventType s( || ==r c > | j rp | j | }| j | }| j | }| j | }| j j | j ||||g y y # t $ r | j | Y y w xY wr ) r r r r rK ReportEventr r r )r r idcattyperO s r r zNTEventLogHandler.emit s ::
)&&v.++F3((0kk&)
&&t||RdSEJ
) (
)s A.A? ?B B c D t j j | y r )r r rA r s r rA zNTEventLogHandler.close s d#r )N Application) r/ r0 r1 r r r r r rA r2 r r r r X s& ! F >)" $r r c , e Zd Z ddZd Zd Zd Zy) HTTPHandlerNc t j j | |j }|dvr t d |s
| t d || _ || _ || _ || _ || _ || _
y )N)GETPOSTzmethod must be GET or POSTz3context parameter only makes sense with secure=True) r r r r^ re r urlmethodr r r )r r r r r r r s r r zHTTPHandler.__init__ s & ( 9: :'- 0 1
1 & r c |j S r )r r s r mapLogRecordzHTTPHandler.mapLogRecord s
r c dd l }|r)|j j || j }|S |j j | }|S )Nr r ) http.clientclientHTTPSConnectionr HTTPConnection)r r r http
connections r
getConnectionzHTTPHandler.getConnection sP 44T4<<4PJ 33D9Jr c dd l }| j }| j || j }| j }|j
j
| j | }| j dk( r#|j d dk\ rd}nd}|d||fz z }|j | j | |j d }|dk\ r|d | }| j dk( r6|j dd |j d
t t | | j redd l} d | j z j! d }
d
| j# |
j% j' d z }
|j d|
|j) | j dk( r |j+ |j! d |j- y # t. $ r | j1 | Y y w xY w)Nr r ?&z%c%s:r z Content-typez!application/x-www-form-urlencodedzContent-lengthz%s:%srS zBasic ascii
Authorization) urllib.parser r r r parse urlencoder r find
putrequest putheaderr; rL r base64rW b64encodestripdecode
endheadersr getresponser r ) r r urllibr r r dataseprF r r s r r zHTTPHandler.emit s
# % 99D""45A((C<<))$*;*;F*CDD{{e#HHSMQ& C CFc4[ 00
LLc * #AAvBQx {{f$ N ?A ,c#d)n= t / //77@ v / / 2 8 8 : A A' JJ OQ/
LLN{{f$t{{7+,
MMO % V $ %s GG G10G1)r FNN)r/ r0 r1 r r r r r2 r r r r s% KO ( )%r r c , e Zd Z d Zd Zd Zd Zd Zy)BufferingHandlerc ` t j j | || _ g | _ y r )r r r capacitybuffer)r r s r r zBufferingHandler.__init__# s) &
r c H t | j | j k\ S r )rL r r r s r shouldFlushz BufferingHandler.shouldFlush+ s! DKK DMM12r c | j j | | j | r| j y y r )r r r r r s r r zBufferingHandler.emit4 s7
6" F # JJL $r c | j | j j | j y # | j w xY wr )r r clearr r s r r zBufferingHandler.flush? s:
KK LLNDLLNs > Ac | j t j j | y # t j j | w xY wr )r r r rA r s r rA zBufferingHandler.closeK s:
( JJL OO ! !$ 'GOO ! !$ 's 3 !AN)r/ r0 r1 r r r r rA r2 r r r r s
3
(r r c H e Zd Z ej ddfdZd Zd Zd Zd Z y)
MemoryHandlerNTc \ t j | | || _ || _ || _ y r )r r
flushLeveltarget flushOnClose)r r r r r s r r zMemoryHandler.__init__\ s/ !!$1$ (r c ~ t | j | j k\ xs |j | j k\ S r )rL r r r r r s r r zMemoryHandler.shouldFlushp s8 DKK DMM1 4 4??2 4r c | j || _ | j y # | j w xY wr )r r r )r r s r setTargetzMemoryHandler.setTargetw s1
DK LLNDLLNs + =c | j | j rF| j D ] }| j j | | j j | j y # | j w xY wr )r r r handler r r s r r zMemoryHandler.flush sa
{{ "kkFKK&&v. * !!# LLNDLLNs AA6 6Bc | j r| j | j d | _ t j | | j
y # | j
w xY w# | j d | _ t j | | j
w # | j
w xY wxY wr )r r r r r rA r r s r rA zMemoryHandler.close s
LLN
" &&t,
LLN
" &&t, s. A2 A A/2C B1 C1CC)
r/ r0 r1 r r0 r r r r rA r2 r r r r V s.
-4MM$ ")(4" r r c & e Zd Z d Zd Zd Zd Zy) QueueHandlerc ` t j j | || _ d | _ y r )r r r queuelistener)r r
s r r zQueueHandler.__init__ s) &
r c < | j j | y r )r
put_nowaitr s r enqueuezQueueHandler.enqueue s
f%r c | j | }t j | }||_ ||_ d |_ d |_ d |_ d |_ |S r )rK copyr rO r r exc_text
stack_info)r r rO s r preparezQueueHandler.prepare sU * kk&!6"
r c | j | j | y # t $ r | j | Y y w xY wr )r r r r r s r r zQueueHandler.emit s>
% LL f- . % V $ %s $ A AN)r/ r0 r1 r r r r r2 r r r r s & B %r r c H e Zd Z dZdddZd Zd Zd Zd Zd Z d
Z
d Z y)
QueueListenerNF)respect_handler_levelc > || _ || _ d | _ || _ y r )r
handlers_threadr )r r
r r s r r zQueueListener.__init__ s&
%:"r c : | j j | S r )r
rM )r blocks r dequeuezQueueListener.dequeue s zz~~e$$r c t j | j x| _ }d|_ |j y )N)r T) threadingThread_monitorr r r )r rp s r r zQueueListener.start s4 %++4==AA q r c |S r r2 r s r r zQueueListener.prepare s
r c | j | }| j D ]> }| j sd}n|j |j k\ }|s.|j | @ y r )r r r r levelr )r r handlerprocesss r r zQueueListener.handle sT f%}}G-- ..GMM9v&
%r c | j }t |d } | j d }|| j u r|r|j y | j | |r|j W# t j $ r Y y w xY w)N task_doneT)r
hasattrr _sentinelr( r Empty)r q
has_task_doner s r r! zQueueListener._monitor- s
JJ ;/
d+T^^+$
F# KKM ;;
s 1A2 #A2 2BBc P | j j | j y r )r
r
r* r s r enqueue_sentinelz QueueListener.enqueue_sentinelD s
dnn-r c h | j | j j d | _ y r )r/ r r r s r stopzQueueListener.stopN s,
r ) r/ r0 r1 r* r r r r r r! r/ r1 r2 r r r r s9
I?D ;% ' ..
r r )'r9 r r r( r r rm rh rl r r r r
r r DEFAULT_TCP_LOGGING_PORTDEFAULT_UDP_LOGGING_PORTDEFAULT_HTTP_LOGGING_PORTDEFAULT_SOAP_LOGGING_PORTry SYSLOG_TCP_PORTrz r r r4 rQ r r r r r r{ r r r r r objectr r2 r r r8 sH " 9 8 8 8 ) ) # " " " ! ! H''-- H'TT- Tlw< 2 w