f r 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 dej Z G d de Z G d dej Z G d dej Z G d dej Z G d d ej Z! G d d ej Z" G d d e" Z# G d! d"ej Z$ G d# d$e% Z&dS )% N)ST_DEVST_INOST_MTIMEi<# i=# i># i?# i Q c 2 e Zd Z dZdZddZd Zd Zd ZdS )BaseRotatingHandlerNFc | t j | ||||| || _ || _ || _ d S )Nmodeencodingdelayerrors)logging FileHandler__init__r r r selffilenamer r r
r s 7/opt/alt/python311/lib64/python3.11/logging/handlers.pyr z BaseRotatingHandler.__init__6 sR $$T8$.6e,2 % 4 4 4
c | | r| t j | | d S # t
$ r | | Y d S w xY wN)shouldRollover
doRolloverr r emit Exception handleErrorr records r r zBaseRotatingHandler.emitA s %""6**
"!!! $ $T6 2 2 2 2 2 % % % V $ $ $ $ $ $ %s A A A10A1c ` t | j s|}n| | }|S r )callablenamer)r default_nameresults r rotation_filenamez%BaseRotatingHandler.rotation_filenameO s8
## .!FFZZ --F
r c t | j s8t j | rt j || d S d S | || d S r )r! rotatorospathexistsrename)r sourcedests r rotatezBaseRotatingHandler.rotateb so %% 'w~~f%%
( &$'''''
(
(
LL & & & & &r )NFN) __name__
__module__ __qualname__r" r' r r r% r. r r r r - sf
EG % % % &' ' ' ' 'r r c ( e Zd Z ddZd Zd ZdS ) RotatingFileHandlerar NFc |dk rd}d|vrt j | }t | ||||| || _ || _ d S )Nr r5 br r
r )io
text_encodingr r maxBytes backupCount)r r r r; r< r r
r s r r z RotatingFileHandler.__init__| sr 2 a<<D d??'11H$$T8TH+0 % A A A
&r c | j r | j d | _ | j dk r/t | j dz
dd D ]}| d| j |fz }| d| j |dz fz }t j | rHt j | rt
j | t
j
|| | | j dz }t j | rt
j | | | j | | j s|
| _ d S d S )Nr z%s.%dz.1)streamcloser< ranger% baseFilenamer( r) r* remover+ r. r
_open)r isfndfns r r z RotatingFileHandler.doRollover sv ; K DK a 4+a/B77
(
(,,W8I17M-MNN,,W8I89A8? .? @ @7>>#&& (w~~c** ' #Ic3'''(():T)ABBCw~~c""
# KK)3 / / /z ' **,,DKKK ' 'r c t j | j r&t j | j sdS | j | | _ | j dk rgd| | z }| j dd | j
t | z | j k rdS dS )NFr z%s
T) r( r) r* rC isfiler@ rE r; formatseektelllenr r msgs r r z"RotatingFileHandler.shouldRollover s 7>>$+ , , RW^^DDU5V5V 5 ; **,,DK =1 4;;v...C K Q " " "{ !!CHH,
==tur )r5 r r NFN)r/ r0 r1 r r r r2 r r r4 r4 w sV DE48"' "' "' "'H' ' '. r r4 c 6 e Zd Z d dZd Zd Zd Zd
ZdS ) TimedRotatingFileHandlerhr> r NFc
t j | }t | |d||| | | _ || _ || _ || _ | 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 d rd| _ t | j dk rt d| j z | j d dk s| j d dk rt d| j z t | j d | _ d| _
d}
nt d| j z t! j |
t j | _ | j |z | _ | j }t* j | r t+ j | t2 } n t t5 j } | | | _ d S ) Nr5 r8 Sr> z%Y-%m-%d_%H-%M-%Sz0(?<!\d)\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(?!\d)M< z%Y-%m-%d_%H-%Mz*(?<!\d)\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(?!\d)H z %Y-%m-%d_%Hz$(?<!\d)\d{4}-\d{2}-\d{2}_\d{2}(?!\d)DMIDNIGHTr z%Y-%m-%dz (?<!\d)\d{4}-\d{2}-\d{2}(?!\d)Wi: rJ 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: %s) r9 r: r r upperwhenr< utcatTimeintervalsuffix
startswithrO
ValueErrorint dayOfWeekrecompileASCIIextMatchrC r( r) r* statr timecomputeRollover
rolloverAt) r r ra rd r< r r
rb rc r rm ts r r z!TimedRotatingFileHandler.__init__ s@ #H--$$T8S8+0 % A A AJJLL & 9 DM-DKJHH
Y#
DM*DKDHH
Y#
#DM'DK>HH
Y#
j!8!8 (DM$DK8HH
Y
!
!#
&
&
T ,DM49~~"" !knrnw!wxxxy|c!!TYq\C%7%7 !PSWS\!\]]] 1 . .DN$DK8HH F RSS S
8RX66
0
$
7>>( # # !!!(+AADIKK A ..q11r c || j z }| j dk s| j d r| j rt j | }nt j | }|d }|d }|d }|d }| j t }n,| 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 d rV|}
|
| j k r3|
| 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 sS|d } t j | d }
| |
k r+| s"d }t j |d
z
d sd}nd
}||z
}|S )Nr\ r] rX r r> r? rZ )
rd ra rf rb ro gmtime localtimerc _MIDNIGHThourminutesecondri )r currentTimer$ rr currentHour
currentMinute
currentSecond
currentDay rotate_tsrday
daysToWaitdstNow
dstAtRolloveraddends r rp z(TimedRotatingFileHandler.computeRollover s t}, 9
" "di&:&:3&?&? "x
0K ,,N;//A$K aDM aDM1J{" % "k . 3dk6H H" LK& ' kB . >" D AAvv Y (1n 1
1_F y##C((
4 $.((T^++%)^c%9
%&Wt~%=%A
j9 44F$-)a-77$-)338
%2 $v 6 6r :
]**! &!& #~fTk : :2 > '%&F!%f$F
r c * t t j }|| j k rft j | j r@t j | j s | | | _ dS dS dS )NFT) rh ro rq r( r) r* rC rK rp )r r rr s r r z'TimedRotatingFileHandler.shouldRolloverb s
w~~d /00
HY9Z9Z
#'"6"6q"9"9 u4ur c t j | j \ }}t j | }g }| j |dz }t
| }|D ]g}|d | |k rW||d }| j | r3| t j
|| hn|D ]}| j | } | r| | j dz | d z }
t j |
|k r4| t j
|| n2| j ||
dz } | t
| | j k rg }n3| |d t
| | j z
}|S )N.r r> )r( r) splitrC listdirr" rO rm fullmatchappendjoinsearchbasenamestartr< sort) r dirNamebaseName fileNamesr$ prefixplenfileNamere mrH s r getFilesToDeletez)TimedRotatingFileHandler.getFilesToDeleteu s
GMM$*; < <Jw'' : ^Fv;;D %
G
GETE?f,, %dee_F}..v66 G
bgll7H&E&EFFF
G &
F
F
M((22 F **T%6%<qt%CDDCw'',,88
bgll7H&E&EFFF
,,Xqwwyy1}EEA F v;;) ) )FF KKMMM ;S[[4+; ; ;<F
r c h t t j }| j | j z
}| j rt j | }nZt j | }t j | d }|d }||k r |rd}nd}t j ||z }| | j dz t j | j
| z }t j
| rd S | j r | j d | _ | | j | | j dk r+| D ]}t j | | j s| | _ | | | _ d S )Nr? rZ ry r r )rh ro rq rd rb rz r{ r% rC strftimere r( r) r* r@ rA r. r< r rD r
rE rp ) r r rr timeTupler dstThenr rH ss r r z#TimedRotatingFileHandler.doRollover s $)++&& Odm + 8 7 AII q))I^K004F mG # !FF "F N1v: 6 6 $$T%6%<%)]4; %J%J&K L L
7>># F ; K DK D%s+++ a **,,
! z ' **,,DK ..{;;r )rT r> r NFFNN)r/ r0 r1 r rp r r r r2 r r rS rS s DE?C A2 A2 A2 A2FK K KZ &$ $ $L&< &< &< &< &<r rS c . e Zd Z ddZd Zd Zd ZdS ) WatchedFileHandlerr5 NFc d|vrt j | }t j | ||||| d\ | _ | _ | d S )Nr7 r
)r? r? )r9 r: r r r devino _statstreamr s r r zWatchedFileHandler.__init__ sq d??'11H$$T8$.6e,2 % 4 4 4 $$( r c | j rRt j | j }|t |t
c| _ | _ d S d S r )r@ r( fstatfilenor r r r r sress r r z WatchedFileHandler._statstream sO ; <8DK . . 0 011D!%f tF| DHdhhh < <r c t j | j }n# t $ r d }Y nw xY w|r,|t | j k s|t | j k rq| j h| j | j
d | _ | | _ | d S d S d S r )
r( rn rC FileNotFoundErrorr r r r r@ flushrA rE r r s r reopenIfNeededz!WatchedFileHandler.reopenIfNeeded s 74,--DD DDD #tF|tx//4<483K3K{& !!### !!### " "jjll """"" '& 4L3Ks ,,c p | t j | | d S r )r r r r r s r r zWatchedFileHandler.emit s:
v.....r )r5 NFN)r/ r0 r1 r r r r r2 r r r r sd & AF < < <
# # #8/ / / / /r r c B e Zd Z d Zd dZd Zd Zd Zd Zd Z d Z
d
S )
SocketHandlerc t j | || _ || _ ||| _ n ||f| _ d | _ d| _ d | _ d| _ d| _
d| _ d S )NFg ?g >@g @) r Handlerr hostportaddresssock closeOnError retryTime
retryStartretryMax retryFactorr r r s r r zSocketHandler.__init__ sz &&& < DLL $<DL !
r r> c H | j t j | j | }n}t j t j t j }| | | | j n## t $ r | w xY w|S )Ntimeout)
r socketcreate_connectionr AF_UNIX SOCK_STREAM
settimeoutconnectOSErrorrA )r r r$ s r
makeSocketzSocketHandler.makeSocket3 s 9 -dlGLLLFF]6>63EFFF g & & &
t|,,,,
s $A? ? B c j t j }| j d}n || j k }|r | | _ d | _ d S # t $ rW | j
| j | _ n0| j | j z | _ | j | j k r | j | _ || j z | _ Y d S w xY wd S NT) ro r r r r r retryPeriodr r )r nowattempts r createSocketzSocketHandler.createSocketD s
ikk > !GGdn,G 8
8 OO - - !%
8
8
8>)'+D$$'+'7$:J'JD$'$-77+/=(!$t'7!7
8 8 8s A A B0/B0c | j | | j rN | j | d S # t $ r$ | j d | _ Y d S w xY wd S r )r r sendallr rA r r s r sendzSocketHandler.send` s 9 9 !
! !!!$$$$$
!
!
! !!!
! ! !s A *A/.A/c N |j }|r| | }t |j }| |d< d |d< d |d< | dd t
j |d }t j dt | }||z S )NrQ argsexc_infomessager> z>L) r rL dict__dict__
getMessagepoppickledumpsstructpackrO )r r eidummydr slens r
makePicklezSocketHandler.makePickles s _
(KK''E
! !$$&&%& *
i LA {4Q((axr c | j r)| j r"| j d | _ d S t j | | d S r )r r rA r r r r s r r zSocketHandler.handleError sX 6 6 IOO DIII O ' 'f 5 5 5 5 5r c | | }| | d S # t $ r | | Y d S w xY wr )r r r r )r r r s r r zSocketHandler.emit sh %''A IIaLLLLL % % % V $ $ $ $ $ $ %s */ AAc | | j }|rd | _ | t j | | d S # | w xY wr )acquirer rA r r releaser r s r rA zSocketHandler.close sw
9D
O ! !$ ' ' ' LLNNNNNDLLNNNN AA0 0BN)r> ) r/ r0 r1 r r r r r r r rA r2 r r r r
s
2 "8 8 88! ! !& , 6 6 6
%
%
% r r c " e Zd Z d Zd Zd ZdS )DatagramHandlerc N t | || d| _ d S )NF)r r r r s r r zDatagramHandler.__init__ s/ tT4000 !r c | j
t j }n t j }t j |t j }|S r )r r r AF_INET
SOCK_DGRAM)r familyr s r r zDatagramHandler.makeSocket s: 9 ^FF^F M&&"3 4 4r c ~ | j | | j || j d S r )r r sendtor r s r r zDatagramHandler.send sC 9 DL)))))r N)r/ r0 r1 r r r r2 r r r r sF " " "
*
*
*
*
*r r c
z 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/d3S )=
SysLogHandlerr r> rJ rt ru rv rw rx
) alertcritcriticaldebugemergerrerrorinfonoticepanicwarnwarningauthauthprivconsolecrondaemonftpkernlprmailnewsntpsecurityz solaris-cronsysloguseruucplocal0)local1local2local3local4local5local6local7r r r r r
)DEBUGINFOWARNINGERRORCRITICAL localhostNc t j | || _ || _ || _ d | _ | d S r )r r r r facilitysocktyper r )r r r5 r6 s r r zSysLogHandler.__init__J sS
&&&
r c | j }| t j }t j t j | | _ | j | || _ d S # t
$ r | j | j t j }t j t j | | _ | j | || _ Y d S # t
$ r | j w xY ww xY wr )r6 r r r r r rA r )r r use_socktypes r _connect_unixsocketz!SysLogHandler._connect_unixsocket_ s } !,L mFNLAA K ( ( ( (DMMM
K }(!-L - EEDK
##G,,, ,
!!###
s !A AD:!C %DDc P | j }| j }t |t r0d| _ | | d S # t $ r Y d S w xY wd| _ | t j }|\ }}t j ||d| }|st
d |D ]z}|\ }}}} }
d x} } t j ||| } |t j
k r| |
n/# t $ r"}
|
} | | Y d }
~
sd }
~
ww xY w| | | | _ || _ d S )NTFr z!getaddrinfo returns an empty list)
r r6
isinstancestr
unixsocketr9 r r r getaddrinfor r rA )r r r6 r r ressresafproto_sar r excs r r zSysLogHandler.createSocketw s ,= gs # # ! % "DO
((11111
$DO !, JD$%dD!X>>D
C ABBB
%
%-0*HeQ !!d%!=Xu==D 6#555 R(((E % % % C'
% DK $DMMMs) A
AA(;C%%
D/D Dc t |t r
| j | }t |t r
| j | }|dz |z S )Nrt )r; r< facility_namespriority_names)r r5 prioritys r encodePriorityz SysLogHandler.encodePriority sV h $ $ 5*84H h $ $ 5*84HA
))r c | | j }|rd | _ | t j | | d S # | w xY wr )r r rA r r r r s r rA zSysLogHandler.close sw
;D
"
O ! !$ ' ' ' LLNNNNNDLLNNNNr c : | j |d S )Nr ) priority_mapget)r levelNames r mapPriorityzSysLogHandler.mapPriority s" $$Y :::r Tc ` | | }| j r
| j |z }| j r|dz
}d| | j | |j z }| d }| d }||z }| j s| | j
r{ | j | d S # t $ rQ | j
| | j | j | Y d S w xY w| j t j k r"| j || j d S | j | d S # t( $ r | | Y d S w xY w)N z<%d>utf-8)rL ident
append_nulrJ r5 rP levelnameencoder r r= r r rA r9 r r6 r r r r r )r r rQ prios r r zSysLogHandler.emit s %++f%%Cz
'j3&
v
D / /
040@0@AQ0R0R T T TD;;w''D**W%%C*C;
$!!###
)*K$$S))))) * * *K%%''',,T\:::K$$S))))))* &"333 ""3 55555 ##C((((( % % % V $ $ $ $ $ $ %s7 B9F
=C AD40F
3D448F
.F
F-,F-)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_LOCAL7rH rG rM SYSLOG_UDP_PORTr r9 r rJ rA rP rU rV 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 ZdS ) SMTPHandlerN @c t j | t |t t
f r|\ | _ | _ n|d c| _ | _ t |t t
f r|\ | _ | _ nd | _ || _
t |t r|g}|| _ || _
|| _ || _ d S 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 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 |d< d
| j |d< | | |d< |j
|d< | | | | j r^| j 7| |j | j | | | j | j | | | d S # t2 $ r | | Y d S w xY w) Nr ) EmailMessager From,ToSubjectDate)smtplib
email.messager email.utilsr SMTP_PORTSMTPr r r r r r utilsr{ set_contentrL r r ehlostarttlsloginr send_messagequitr r )r r r r emailr smtprQ s r r zSMTPHandler.emit% s
% NNN 2 2 2 2 2 2 =D
) (<<
tT\<JJD ,..C -CK ..CI !__V 4 4C N +//11CK OODKK / / 0 0 0}
9;*IIKKK!DM4;//IIKKK
4=$-888 c " " " IIKKKKK % % % V $ $ $ $ $ $ %s EE FF)NNr} )r/ r0 r1 r r r r2 r r r| r| sQ 9<! ! ! ! F % % % % %r r| c 6 e Zd Z d dZd Zd Zd Zd Zd ZdS )
NTEventLogHandlerN Applicationc
. t j | dd l}dd l}|| _ || _ |stt j | j j
}t j |d }t j |d d }|| _ || _
| j ||| n-# t $ r }t! |dd dk r Y d }~nd }~ww xY w|j | _ t j |j t j |j t j |j t j |j t j |j i| _ d S # t6 $ r t9 d d | _ Y d S w xY w)Nr zwin32service.pydwinerrorrv 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/ r0 EVENTLOG_WARNING_TYPEr1 r2 typemap ImportErrorprint)r r r r r r es r r zNTEventLogHandler.__init__O s &&& / / / / / / / /"DL(DJ
H '--
(;<< '--
33 ',,wqz3FGG"DL"DL
..wIIII
1j$//144 54444
':DL
+"G +"G+"C
+"A +"A DLLL ?
@
@
@ DJJJJ s= BE0 < C E0
D#C>9E0 >DA+E0 0 FFc dS )Nr> r2 r s r getMessageIDz NTEventLogHandler.getMessageIDr s qr c dS )Nr r2 r s r getEventCategoryz"NTEventLogHandler.getEventCategory| s qr c N | j |j | j S r )r rN levelnor r s r getEventTypez NTEventLogHandler.getEventType s% | ===r c X | j r | | }| | }| | }| | }| j | j ||||g d S # t $ r | | Y d S w xY wd S r ) r r r r rL ReportEventr r r )r r idcattyperQ s r r zNTEventLogHandler.emit s : )
)&&v..++F33((00kk&))
&&t|RdSEJJJJJ
)
)
) ((((((
) ) )s A8B B'&B'c F t j | d S r )r r rA r s r rA zNTEventLogHandler.close s% d#####r )Nr ) r/ r0 r1 r r r r r rA r2 r r r r E sy ! ! ! ! F > > >) ) )" $ $ $ $ $r r c . e Zd Z ddZd Zd Zd ZdS ) HTTPHandlerGETFNc t j | | }|dvrt d |s|t d || _ || _ || _ || _ || _ || _
d S )N)r POSTzmethod must be GET or POSTz3context parameter only makes sense with secure=True) r r r r` rg r urlmethodr r context)r r r r r r r s r r zHTTPHandler.__init__ s &&& ( ( 9:: : 1'- 0 1 1
1 & r c |j S r )r r s r mapLogRecordzHTTPHandler.mapLogRecord s
r c dd l }|r"|j || j }n|j | }|S )Nr )r ) http.clientclientHTTPSConnectionr HTTPConnection)r r r http
connections r
getConnectionzHTTPHandler.getConnection sV : 44T4<4PPJJ 33D99Jr c > dd l }| j }| || j }| j }|j | | }| j dk r(| d dk rd}nd}|d||fz z }|
| j | | d }|dk r
|d | }| j dk rF| dd | d
t t | | j rtdd l} d | j z d }
d
| |
d z }
| d|
| | j dk r(| | d | d S # t. $ r | | Y d S w xY w)Nr r ?&z%c%s:r z Content-typez!application/x-www-form-urlencodedzContent-lengthz%s:%srT zBasic ascii
Authorization) urllib.parser r r r parse urlencoder r find
putrequest putheaderr< rO r base64rX b64encodestripdecode
endheadersr getresponser r ) r r urllibr rT r dataseprF r r s r r zHTTPHandler.emit s"
# % 9D""455A(C<))$*;*;F*C*CDDD{e##HHSMMQ&& CC CFc4[ 00
LLc * * * #AAvvBQBx {f$$ N ?A A A ,c#d))nn===
0
t //77@@ v / / 2 2 8 8 : : A A' J JJ OQ///
LLNNN{f$$t{{7++,,,
MMOOOOO % % % V $ $ $ $ $ $ %s G4G9 9 H H )r FNN)r/ r0 r1 r r r r r2 r r r r sd KO ( )% )% )% )% )%r r c . e Zd Z d Zd Zd Zd Zd ZdS )BufferingHandlerc b t j | || _ g | _ d S r )r r r capacitybuffer)r r s r r zBufferingHandler.__init__ s1 &&&
r c > t | j | j k S r )rO r r r s r shouldFlushz BufferingHandler.shouldFlush s DK DM12r c | j | | | r| d S d S r )r r r r r s r r zBufferingHandler.emit! sP
6""" F # # JJLLLLL r c | | j | d S # | w xY wr )r r clearr r s r r zBufferingHandler.flush, sR
K LLNNNNNDLLNNNNs A A c | t j | d S # t j | w xY wr )r r r rA r s r rA zBufferingHandler.close8 sQ
( JJLLL O ! !$ ' ' ' ' 'GO ! !$ ' ' ' 's 8 !AN)r/ r0 r1 r r r r rA r2 r r r r
sd
3 3 3
( ( ( ( (r r c @ e Zd Z ej ddfdZd Zd Zd Zd Z dS )
MemoryHandlerNTc h t | | || _ || _ || _ d S r )r r
flushLeveltarget flushOnClose)r r r r r s r r zMemoryHandler.__init__I s; !!$111$ (r c ^ t | j | j k p|j | j k S r )rO r r r r r s r r zMemoryHandler.shouldFlush] s3 DK DM1 4 4?2 4r c | || _ | d S # | w xY wr )r r r )r r s r setTargetzMemoryHandler.setTargetd sE
DK LLNNNNNDLLNNNNs 4 A
c | | j r=| j D ] }| j | | j | d S # | w xY wr )r r r handler r r s r r zMemoryHandler.flushn s
{
$ "k / /FK&&v.... !!### LLNNNNNDLLNNNNs AA1 1Bc | j r| | d | _ t | | d S # | w xY w# | d | _ t | | w # | w xY wxY wr )r r r r r rA r r s r rA zMemoryHandler.close s
LLNNN
" &&t,,,
LLNNN
" &&t,,, s. B !A* *B C(!C:C(C%%C()
r/ r0 r1 r r1 r r r r rA r2 r r r r C su
-4M$ ") ) ) )(4 4 4 " r r c ( e Zd Z d Zd Zd Zd ZdS ) QueueHandlerc T t j | || _ d S r )r r r queue)r r s r r zQueueHandler.__init__ s* &&&
r c < | j | d S r )r
put_nowaitr s r enqueuezQueueHandler.enqueue s%
f%%%%%r c | | }t j | }||_ ||_ d |_ d |_ d |_ d |_ |S r )rL copyr rQ r r exc_text
stack_inforP s r preparezQueueHandler.prepare sY * kk&!!6""
r c | | | d S # t $ r | | Y d S w xY wr )r r r r r s r r zQueueHandler.emit sh
% LL f-- . . . . . % % % V $ $ $ $ $ $ %s (- AAN)r/ r0 r1 r r r r r2 r r r r sV & & & B % % % % %r r c J e Zd Z dZdddZd Zd Zd Zd Zd Z d
Z
d Z dS )
QueueListenerNF)respect_handler_levelc @ || _ || _ d | _ || _ d S r )r handlers_threadr )r r r r s r r zQueueListener.__init__ s,
%:"""r c 8 | j | S r )r rN )r blocks r dequeuezQueueListener.dequeue s z~~e$$$r c t j | j x| _ }d|_ | d S )N)r T) threadingThread_monitorr r r )r rr s r r zQueueListener.start s= %+4=AAAA q r c |S r r2 r s r r zQueueListener.prepare s
r c | | }| j D ]3}| j sd}n|j |j k }|r| | 4d S r )r r r r levelr )r r handlerprocesss r r zQueueListener.handle sp f%%} ' 'G-
: .GM9
'v&&&
' 'r c ( | j }t |d } | d }|| j u r|r| d S | | |r| n# t j $ r Y d S w xY wz)N task_doneT)r hasattrr _sentinelr# r Empty)r q
has_task_doner s r r zQueueListener._monitor s
J ;//
d++T^++$ &
E F### "KKMMM;
s 4A= +A= =BBc F | j | j d S r )r r r% r s r enqueue_sentinelz QueueListener.enqueue_sentinel0 s'
dn-----r c p | | j d | _ d S r )r* r r r s r stopzQueueListener.stop: s:
r ) r/ r0 r1 r% r r r r r r r* r, r2 r r r r s
I?D ; ; ; ; ;% % % ' ' ' .. . .
r r )'r9 r r r( r r ro rj rn r r r r r r DEFAULT_TCP_LOGGING_PORTDEFAULT_UDP_LOGGING_PORTDEFAULT_HTTP_LOGGING_PORTDEFAULT_SOAP_LOGGING_PORTrz SYSLOG_TCP_PORTr| r r r4 rS r r r r r r| r r r r r objectr r2 r r <module>r3 s " 9 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 ) ) ) ) ) ) ) ) ) ) # " " " ! ! H' H' H' H' H''- H' H' H'TQ Q Q Q Q- Q Q Qfw< w< w< w< w< 2 w< w< w<rG/ G/ G/ G/ G/, G/ G/ G/Te e e e eGO e e eN(* (* (* (* (*m (* (* (*TU% U% U% U% U%GO U% U% U%nN% N% N% N% N%'/ N% N% N%`i$ i$ i$ i$ i$ i$ i$ i$VX% X% X% X% X%'/ X% X% X%t7( 7( 7( 7( 7(w 7( 7( 7(rJ J J J J $ J J J ZF% F% F% F% F%7? F% F% F%Rk k k k k F k k k k k r