python (3.12.0)
Browse
Usage
Versions
̑e 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 D/BuggyBox/python/3.12.0/bootstrap/lib/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 sB ;; KK DK a 4++a/B7
(,,W8I8I17M-MN,,W8I8I89A8? .? @77>>#&ww~~c* #IIc3'
( (():):T)ABCww~~c" # KK))3 /zz **,DK r c t j j | j r*t j j | j sy| j
| j
| _ | j dkD rdd| j | z }| j
j dd | j
j t | z | j k\ ryy)NFr z%s
T) r( r) r* rC isfiler@ rE r; formatseektelllenr r msgs r r z"RotatingFileHandler.shouldRollover s 77>>$++ ,RWW^^DDUDU5V ;; **,DK ==1 4;;v..C KK Q "{{ !CH,
=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| _ nR| 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$ | 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-%Sz-^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(\.\w+)?$M< z%Y-%m-%d_%H-%Mz'^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(\.\w+)?$H z %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+)?$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< utcatTimeintervalsuffixextMatch
startswithrO
ValueErrorint dayOfWeekrecompileASCIIrC r( r) r* statr timecomputeRollover
rolloverAt) r r r` rc r< r r
ra rb r ts r r z!TimedRotatingFileHandler.__init__ s ##H-$$T8S8+0 % AJJL & 99 DM-DK LDM
YY#
DM*DK FDM
YY#
#DM'DK @DM
YY#
j!8 (DM$DK :DM
YY
!
!#
& ,DM499~" !knrnwnw!wxxyy|c!TYYq\C%7 !PSWS\S\!\]] 1 .DN$DK :DM F RS S
4=="((;
0
$$
77>>( #!(+ADIIK A ..q1r c l || j z }| j dk( s | j j d rx| 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 r|}
|
| j k7 rx|
| j k r| j |
z
} nd|
z
| j z d z } || d z z } | j s.|d }
t j | d }|
|k7 r |
sd
}nd}| |z
} | }|S )Nr[ r\ rW r r> r r? rY )
rc r` rf ra rn gmtime localtimerb _MIDNIGHThourminutesecondri )r currentTimer$ rq currentHour
currentMinute
currentSecond
currentDay rotate_tsrday
daysToWait
newRolloverAtdstNow
dstAtRolloveraddends r ro z(TimedRotatingFileHandler.computeRollover s t}}, 99
"dii&:&:3&?xxKK ,NN;/A$K aDM aDM1J{{" % "kk . . 3dkk6H6H H" LKK&& ' kB . >" D A1u Y (1n 1
1_F yy##C( $..(T^^+%)^^c%9
%&Wt~~%=%A
$*jL.I$JM 88!"2(,}(Eb(I
!]2#)).)- )V 3M *F
r c 2 t t j }|| j k\ rjt j j | j r@t j j | j s| j | | _ yyy)NFT) rh rn rp r( r) r* rC rK ro )r r rq s r r z'TimedRotatingFileHandler.shouldRolloverX sm
ww~~d / /0 HYHY9Z #'"6"6q"9 r c B t j j | j \ }}t j | }g }t j j | \ }}|dz }t
| }|D ] } | j | j | sK!| j | s9| j | r(t
| |dz kD r| |dz j sk| d | |k( st| |d }
|
j d } | D ]N } | j j | s |j t j j || t
| | j k rg }|S |j! |d t
| | j z
}|S )N.r> )r( r) splitrC listdirsplitextrO r" rf endswithisdigitre matchappendjoinr< sort)
r dirNamebaseName fileNamesr$ neprefixplenfileNamerd partsparts
r getFilesToDeletez)TimedRotatingFileHandler.getFilesToDeletek s
GGMM$*;*; <JJw' ww )1S6{! Hzz! **84
!++H5(:K:KA:NMTAX.xQ7G7O7O7Q &(!$% S) ! D}}**40
bggll7H&EF % , v;)) )F
KKM ;S[4+;+; ;<F
r c | j r!| j j d | _ t t j }t j | d }| j
| j z
}| j rt j | }n>t j | }|d }||k7 r |rd}nd}t j ||z }| j | j dz t j | j | z }t j j | rt j | | j# | j | | j$ dkD r*| j' D ] }t j | | j( s| j+ | _ | j- | } | |k r| | j z } | |k r| j. dk( s| j. j1 d r5| j s)t j | d }
||
k7 r |sd}nd}| |z
} | | _ y )Nr? rY rx r r r[ r\ )r@ rA rh rn rz rp rc ra ry r% rC strftimerd r( r) r* rD r. r< r r
rE ro r` rf ) r r r rq timeTupledstThenr rH sr r s r r z#TimedRotatingFileHandler.doRollover s ;; KK DK$))+& ,R0 OOdmm + 88 AI q)I mG !F "F NN1v: 6 $$T%6%6%<%)]]4;; %J&K L
77>># IIcN D%%s+ a **,
!
zz **,DK ,,[9
{* )DMM 9M {*
II #tyy';';C'@$(( NN= 9" =M & "F !F '
'r )hr> r NFFNN)r/ r0 r1 r ro r r r r2 r r rS rS s1 DE?C ;2zGR&(T0(r rS c , e Zd Z ddZd Zd Zd Zy)WatchedFileHandlerNc d|vrt j | }t j j | ||||| d\ | _ | _ | j y )Nr7 r
)r? r? )r9 r: r r r devino _statstreamr s r r zWatchedFileHandler.__init__ s\ d?''1H$$T8$.6e,2 % 4 $$( r c | j rKt j | j j }|t |t
c| _ | _ y y r )r@ r( fstatfilenor r r r r sress r r z WatchedFileHandler._statstream sA ;;88DKK . . 01D!%f tF| DHdh r c t j | j }|r,|t | j
k7 s|t | j k7 rn| j a| j j | j j d | _ | j | _ | j y y y # t $ r d }Y w xY wr )
r( rm rC FileNotFoundErrorr r r r r@ flushrA rE r r s r reopenIfNeededz!WatchedFileHandler.reopenIfNeeded s 774,,-D tF|txx/4<4883K{{& !!# !!# " "jjl " ' 4L ! D s B? ? C
C
c f | j t j j | | y r )r r r r r s r r zWatchedFileHandler.emit s+
v.r )r6 NFN)r/ r0 r1 r r r r r2 r r r r s% & AF <
#8/r r c @ e Zd Z d Zd
dZd Zd Zd Zd Zd Z d Z
y )
SocketHandlerc t j j | || _ || _ ||| _ n ||f| _ d | _ d| _ d | _ d| _ d| _
d| _ y )NFg ?g >@g @) r Handlerr hostportaddresssock closeOnError retryTime
retryStartretryMax retryFactorr r r s r r zSocketHandler.__init__ sn & < DL $<DL !
r c ` | j #t j | j | }|S t j t j t j
}|j
| |j | j |S # t $ r |j w xY w)Ntimeout)
r socketcreate_connectionr AF_UNIX SOCK_STREAM
settimeoutconnectOSErrorrA )r r r$ s r
makeSocketzSocketHandler.makeSocket7 s 99 --dllGLF
]]6>>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) rn r r r r r retryPeriodr r )r nowattempts r createSocketzSocketHandler.createSocketH 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.sendd 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 )NrQ argsexc_infomessager> z>L) r rL dict__dict__
getMessagepoppickledumpsstructpackrO )r r eidummydr slens r
makePicklezSocketHandler.makePicklew 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> rJ rs rt ru rv rw
) 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 r9 r: s r r zSysLogHandler.__init__P 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 )r: r r r r r rA r )r r use_socktypes r _connect_unixsocketz!SysLogHandler._connect_unixsockete 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 r:
isinstancestr
unixsocketr= r r r getaddrinfor r rA )r r r: r r ressresafproto_sar r excs r r zSysLogHandler.createSocket} s8 ,,== 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 )Nrs )r? r@ facility_namespriority_names)r r9 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)rL ident
append_nulrN r9 rT levelnameencoder r rA r r rA r= r r: r r r r r )r r rQ 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_LOCAL7rL rK rQ SYSLOG_UDP_PORTr r= r rN rA rT rY rZ 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" rk| j$ 9|j' |j( | j$ |j' |j+ | j" | j, |j/ | |j1 y # t2 $ r | j5 | Y y w xY w) Nr ) EmailMessager From,ToSubjectDate)smtplib
email.messager email.utilsr SMTP_PORTSMTPr r r r r r utilsrz set_contentrL r r ehlostarttlsloginr send_messagequitr r )r r r r emailr smtprQ s r r zSMTPHandler.emit+ s.
% 2 ==D ((<<
tT\\<JD .C --CK .CI !__V 4C N ++//1CK OODKK / 0}};;*IIK!DMM4;;/IIK
4==$--8 c " IIK % V $ %s E-E1 1F
F)NNg @)r/ r0 r1 r r r r2 r r r r s 9<! F %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.pydwinerrorru 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_TYPEdeftyper2 EVENTLOG_INFORMATION_TYPEr3 r4 EVENTLOG_WARNING_TYPEr5 r6 typemap ImportErrorprint)r r r r r r r s r r zNTEventLogHandler.__init__U 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.getMessageIDx s r c y)Nr r2 r s r getEventCategoryz"NTEventLogHandler.getEventCategory s r c d | j j |j | j S r )r rR 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 rL ReportEventr r r )r r idcattyperQ 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 K 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_ rg r urlmethodr r context)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:%srX zBasic ascii
Authorization) urllib.parser r r r parse urlencoder r find
putrequest putheaderr@ rO r base64r\ 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 )rO 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.emit' s7
6" F # JJL $r c | j | j j | j y # | j w xY wr )r r clearr r s r r zBufferingHandler.flush2 s:
KK LLNDLLNs > Ac | j t j j | y # t j j | w xY wr )r r r rA r s r rA zBufferingHandler.close> 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__O s/ !!$1$ (r c ~ t | j | j k\ xs |j | j k\ S r )rO r r r r r s r r zMemoryHandler.shouldFlushc s8 DKK DMM1 4 4??2 4r c | j || _ | j y # | j w xY wr )r r r )r r s r setTargetzMemoryHandler.setTargetj 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.flusht sf
{{ "kk /FKK&&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 r5 r r r r rA r2 r r r r I 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 )rL copyr rQ r r exc_text
stack_inforP 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 rR )r blocks r dequeuezQueueListener.dequeue s zz~~e$$r c t j | j x| _ }d|_ |j y )N)r T) threadingThread_monitorr r start)r rq 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 sY 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_sentinel7 s
dnn-r c h | j | j j d | _ y r )r. r r r s r stopzQueueListener.stopA s,
r ) r/ r0 r1 r) r r r r r r r. r0 r2 r r r r s9
I?D ;% ' ..
r r )'r9 r r r( r r rn rj rm r r r r r r DEFAULT_TCP_LOGGING_PORTDEFAULT_UDP_LOGGING_PORTDEFAULT_HTTP_LOGGING_PORTDEFAULT_SOAP_LOGGING_PORTr~ SYSLOG_TCP_PORTr{ r r r4 rS r r r r r r r r r r r objectr r2 r r <module>r7 sH " 9 8 8 8 ) ) # " " " ! ! H''-- H'TQ- Qf{( 2 {(zG/,, G/TeGOO eN(*m (*TW%GOO W%rN%'// N%`i$ i$VX%'// X%t7(w 7(rJ $ J ZG%7?? G%Tk F k r