cj. d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z m
Z
dZe j Zdad dZd Zd Zd Zd Zd Zd
Zd Z ej4 d ej6 Z d
Z G d de Z G d de e Z! G d de"e Z# G d de$e Z% G d de Z&d Z' G d de& Z(e(Z)d Z*edfd Z+d Z,y) N)ThreadingTCPServerStreamRequestHandleriF# c dd l }t | t rZt j j | st
| d t j j | st | d t | |j r| }nX |j | }t | d r|j | n(t j | }|j | | t# | }t% j& t) t+ || }t- ||| t% j. y # |j $ r}t | d| d }~ww xY w# t% j. w xY w)Nr z doesn't existz is an empty filereadline)encodingz
is invalid: ) configparser
isinstancestrospathexistsFileNotFoundErrorgetsize RuntimeErrorRawConfigParser ConfigParserhasattr read_fileio
text_encodingread ParsingError_create_formatterslogging _acquireLock_clearExistingHandlers_install_handlers_install_loggers _releaseLock) fnamedefaultsdisable_existing_loggersr r cpe
formattershandlerss '/usr/lib64/python3.12/logging/config.py
fileConfigr( 5 sD % ww~~e$#ug^$<= = ' %(9 :; ;% 556
; **84Buj) U# ++H51 $B'J %R4X'?@ (( ; %
aS 9: : ; s%
AD9 #E 9E EE E6c | j d } | j d }t | }| D ] }|dz |z } t || } |S # t $ r t | t || }Y >w xY w)N.r )splitpop
__import__getattrAttributeError)nameusedfoundns r' _resolver4 a s} 3 ::c?D 88A;D t E
czA~ &E1%E L & t E1%E &s A
A0/A0c 6 t t j | S N)mapr
strip)alists r'
_strip_spacesr: o s syy% c | d d }t | si S |j d }t | }i }|D ] }d|z }| j |ddd }| j |ddd }| j |d dd
}| j |d dd }t j
} | | j d }
|
r t
|
} |&t |t t } | ||||
} n
| ||| } | ||< |S )Nr% keys,z formatter_%sformatT)rawfallbackdatefmtstyle%r! class)r! ) lenr+ r: getr Formatterr4 evalvars) r# flistr% formsectnamefsdfsstlr! c
class_namefs r' r r r s & | V $E u: KK E % EJ!D(
VVHhD4V
@ffXydTfBffXwD3f?66(JD46H \%%g.
$A Hd7m4H"c32A"c3A
4# $ r; c b | d d }t | si S |j d }t | }i }g }|D ]3 }| d|z }|d }|j dd } t |t t }|j dd } t | t t } |j d
d }
t |
t t }
|| i |
} || _
d |v r|d } | j | t | r| j || t |t j j r0|j d
d }
t |
r|j! | |
f | ||< 6 |D ] \ } }| j# || |S # t t f$ r t | }Y 7w xY w)Nr& r= r> z
handler_%srE formatter args()kwargsz{}leveltarget)rF r+ r: rG rI rJ r r/ NameErrorr4 r0 setLevel setFormatter
issubclassr&
MemoryHandlerappend setTarget)r# r% hlistr& fixupshandsectionklassfmtrW rY hrZ r[ ts r' r r s % zN6 "E u: KK E % EH
F\D() kk+r* $W
.E {{64(D$w-(Xt,fd7m, 4 "6 " g G$E
JJu s8
NN:c? + eW - - ; ; < [[2.F6{
q&k*/ 2 1 HQK O+ * $ UOE $s FF.-F.c t j }| D ]o }|j j | }||v rIt |t j
r;|j
t j g |_ d|_ i||_
q y )NT) r rootmanager
loggerDictr PlaceHolderr] NOTSETr& propagatedisabled)existing
child_loggersdisable_existingrl logloggers r' _handle_existing_loggersrx sn < rl logger_rootrZ r& z logger_%squalnamerq )rA r* r )r+ listr: remover rl r] r&
removeHandlerrF
addHandlerrm rn r= sortgetint getLoggerindexra rq rr rx )r# r& ru llistrf rl rv rZ ri rc re rs rt qnrq rw iprefixedpflen num_existings r' r r st $
yM& !E KK E u% &E LL G < * DLL++0023H
MMO M[3&'
Z
NN;N; ""2&
>r"Q&ACxHME x=Ll"A;v&(2!((!5Q l"
OOB g G$E OOE " #A # $$
# u:KK$E!%(E !!(4.1 5 T X}6FGr; c t j j t j t j d d t j d d = y r6 )r _handlersclearshutdown _handlerList r; r' r r " s> + W))!,- Q r; z^[a-z_][a-z0-9_]*$c N t j | }|st d| z y)Nz!Not a valid Python identifier: %rT)
IDENTIFIERmatch
ValueError)sms r' valid_identr , s) A [a-z]+)://(?P.*)$z ^\s*(\w+)\s*z^\.\s*(\w+)\s*z^\[\s*(\w+)\s*\]\s*z^\d+$ ext_convert cfg_convert)extcfgc F t | | _ | | j _ y r6 )r configr )r r s r' __init__zBaseConfigurator.__init__ s $V, #' r; c J |j d }|j d } | j | }|D ] }|d|z z
} t || } |S # t $ r | j | t || }Y Dw xY w# t
$ r}t
d|d| }||d }~ww xY w)Nr* r zCannot resolve z: )r+ r, importerr. r/ ImportErrorr )r r r0 r1 r2 fragr$ vs r' resolvezBaseConfigurator.resolve s wws|xx{ MM$'E d
"1 #E4 0E L & 1MM$' #E4 0E1 a;D AHHJqM*A$$**40!((*Q-(A **006A hhjm # 1 1 7 7 < !#A +$'H$%aD >D$38$&@ A A' , $- +$%cF +s *D& &D76D7c J t |t s$t |t rt | }| |_ |S t |t s$t |t
rt | }| |_ |S t |t s0t |t r t |d st
| }| |_ |S t |t ri| j j | }|rL|j }|d }| j j |d }|r|d }t | | } || }|S )N_fieldsprefixsuffix)r r r r r r~ r r r r
CONVERT_PATTERNr groupdictvalue_convertersrG r. )r r r r r converterr s r' r zBaseConfigurator.convert s
% 0Zt5L"5)E!%E $ # E>2z%7N"5)E!%E E?3E5)'%2K#E*E!%E s
#$$**51AKKM8 1 1 5 5fd C x[F 'i 8I %f -E r; c 8 |j d }t | s| j | }|D ci c] }|dk7 s t | s||| }} |di |}|j dd }|r%|j D ] \ }}t ||| |S c c}w )NrX r* r )r, callabler r itemssetattr) r r rQ krY r propsr0 r s r' configure_customz!BaseConfigurator.configure_custom s ? JJt { QA(.P118 A!VAY,PV
3% ${{} ee, -
Qs
B B
Bc > t |t r t | }|S r6 )r r~ r r s r' as_tuplezBaseConfigurator.as_tuple s > eT "%LE r; N)r r r recompiler r r r r r staticmethodr- r r r r r r r r r r; r' r r t s !bjj!IJO 2::o.L "** ./K BJJ 56M BJJx(M J'H(*# D8 r; r c t t j t j f ryddlm} t | ryddg}t fd|D S )NTr )Queue
put_nowaitrG c 3 J K | ] }t t |d y wr6 )r r. ).0methodobjs r' z(_is_queue_like_object.. s' 6 46 VT23 4s #)r queuer SimpleQueuemultiprocessing.queuesall)r MPQueueminimal_queue_interfaces ` r' _is_queue_like_objectr sY 4# U%6%6787#w ,U 3 6 46 6 6r; c P e Zd Z d Zd Zd Zd Zd Zd Zd Z d dZ
d d Z d d
Z y )
DictConfiguratorc | j }d|vr t d |d dk7 rt d|d z |j dd }i }t j |r|j d| }|D ]s }|t j vrt d|z t j | }|| }|j d d }|r$|j t j | u |j d | }
|
D ] } | j ||
| d |j dd } | r$ | j | d n|j dd } t |j d| }
|
D ] } | j |
| |
|< |j d| }|D ] } | j || ||< |j d| }g }t | D ]# } | j! || }||_ |||< % |D ]# } | j! || }||_ |||< % t j* } t- | j. j0 j3 }|j5 g }|j d | }
|
D ] }||v ro|j7 | dz }|dz }t9 | }t9 | }||k r*|| d | |k( r|j) || |dz
}||k r*|j; | | j ||
| t= ||| |j dd } | r | j | t j> y # t $ r} t d
|z | d } ~ ww xY w# t $ r} t d
|z | d } ~ ww xY w# t $ r} t d | d } ~ ww xY w# t $ r} t d|z | d } ~ ww xY w# t $ r} t d|z | d } ~ ww xY w# t $ rC} dt% | j& v r|j) | nt d
|z | Y d } ~ kd } ~ ww xY w# t $ r} t d
|z | d } ~ ww xY w# t $ r} t d
|z | d } ~ ww xY w# t $ r} t d | d } ~ ww xY w# t j> w xY w)Nversionz$dictionary doesn't specify a versionr} zUnsupported version: %s incrementalFr& z No handler found with name %rrZ z Unable to configure handler %rrz Tz Unable to configure logger %rrl z Unable to configure root loggerr" r% z Unable to configure formatter %rfiltersz Unable to configure filter %rz not configured yetr* ) r r r, r r rG r r] _checkLevel Exceptionconfigure_loggerconfigure_rootr configure_formatterconfigure_filtersortedconfigure_handlerr0 r
__cause__ra rl r~ rm rn r= r r rF r rx r )r r r
EMPTY_DICTr& r0 handlerhandler_configrZ r$ rz rl ru r% r deferredrs rt r r r r s r' configurezDictConfigurator.configure s # F " CD D ) ! 6 9J JK K jj 6
Q #!::j*= $D7#4#44 ( *36:*; < <A&-&7&7&=G-5d^N$2$6$6w$EE $ ' 0 01D1DU1K L % !**Y
; #D= --dGDM4H $ zz&$/: ++D$7
$*::.H$#O &( $ZZ j A
&DG+/+C+C?
!#
**Y
; #Dx' $NN4 01 4#'#: #H
'*8} , . '{6E 2h > - 4 4Xa[ A FA , . !-= --dGDMB $< )=)9; zz&$/: ++D1
"G ) A", .248.9 #:?@ AA % = ( *.04*5 6;<== % : ( *2 389:: % G ( *8:>*? @EFGG % D ( *57;*< =BCDD % A0C 4DD $OOD 1", .248.9 #:?@ A 2A % = ( *.04*5 6;<==N % = ( *.04*5 6;<==2 % : ( *2 389::
"sX 9R2 AM))R2 N R2 1N) 5R2 9OR2 *O&$R2 & PR2 Q.C R2 8R2
Q5 #R2 R ) N2NNR2 N&N!!N&&R2 ) O2 N>>OR2 O#O O##R2 & P/O>>PR2 Q8Q
R2
QR2 Q2 Q--Q22R2 5 R>R
RR2 R/ R**R//R2 2Sc " d|v r|d } | j | }|S |j dd }|j dd }|j dd }|j dd }|j d d } |st
j }
n t | }
i } | | | d < d
|v r |
||||d
fi | }|S |
|||fi | }|S # t $ rC}dt | vr |j d |d< ||d< | j | }Y d }~|S d }~ww xY w) NrX z'format'r? rh rB rC rD rE r! validate)r r r
r, rG r rH r4 ) r r factoryr terh dfmtrC cnamer! rQ rY s r' r z$DictConfigurator.configure_formatter sN 6 6> TlG
7 ..v6L
5 **Xt,C::i.DJJw,EJJw-E zz*d3H%% UOF
#%-z" V#3eVJ-?J6J
3e6v6
K
7 SW,
!'
8 4u
&t ..v68
K
7s C D 8D Dc d|v r| j | }|S |j dd }t j | }|S )NrX r0 rV )r rG r Filter)r r r r0 s r' r
z!DictConfigurator.configure_filter sH 3 6>**62F
::fb)D ^^D)F
r; c |D ]J } t | st t |dd r|}n| j d | }|j | L y # t $ r}t d|z |d }~ww xY w)Nfilterr zUnable to add filter %r)r r. r addFilterr r )r filtererr rS filter_r$ s r' add_filtersz DictConfigurator.add_filters sy =A
GA;(71h+E"F G "kk) 4Q 7G""7+
G !:Q!>?QF
Gs AA A/A**A/c . d|v r|j d }nt j }|j dd }|j dt j j
}|j dg } ||g|d|i} ||fi |}||_ |S )Nr respect_handler_levelFlistenerr& )r, r r r r&
QueueListenerr# ) r rg rY qrhllklassr& r# r s r' _configure_queue_handlerz)DictConfigurator._configure_queue_handler s f
7#A
Ajj0%8J(8(8(F(FG::j"-!BhBcB$V$#r; c t | }|j dd }|r | j d | }|j dd }|j dd }d|v r1|j d }t | s| j
| }|}n|j d } t | r| }
n| j
| }
t |
t j j ryd|v rt j |d |d< d |v r, |d } | j d
| } t | t j s |j | t d | |d < nt |
t j j r3d
|v r|d
}
t |
t" r5| j
|
}t | st d|
z | |d
< nYt |
t r0d|
vrt d|
z | j% t |
|d
< nt' |
st d|
z d|v r|d }t |t( r2t |t j j* st d|z t |t" rS| j
| }t |t( r}t |t j j* sYt d|z t |t r-d|vrt d|z | j% t | }nt d|z t | st d|z ||d< d
|v rg } |d
D ]^ }| j d
| }t |t j s |j | t d|z |j- | ` ||d
< nt |
t j j. r d|v r| j1 |d |d< n?t |
t j j2 rd|v r| j1 |d |d< t |
t j j r!t5 j6 | j8 |
}n|
}|D ci c] }|dk7 s t; | s||| }} |di |}|r|j= | |$|j? t j | |r| jA || |j dd }|r%|jC D ] \ }}tE ||| |S # t $ r}t d|z |d }~ww xY w# t $ r}t d z |d }~ww xY w# t $ r}t dz |d }~ww xY wc c}w # t $ r5}dt# | vr |j d |d< |di |}Y d }~&d }~ww xY w)NrU r% zUnable to set formatter %rrZ r rX rE
flushLevelr[ r& ztarget not configured yetz Unable to set target handler %rr zInvalid queue specifier %rr# z Invalid listener specifier %rz)Required handler %r is not configured yetz!Unable to set required handler %rmailhostaddressr* z'stream'streamstrmr )#r r, r r r r r r_ r r& r` r r Handlerupdater QueueHandlerr
r r r r$ ra SMTPHandlerr
SysLogHandler functoolspartialr( r r^ r] r r r )r r config_copyrU r$ rZ r rQ r r rg tnthqspecr% lspecr# rc hnri r rY r r r r0 r s r' r z"DictConfigurator.configure_handler s 46l JJ{D1
: KK 5i @
7D)**Y- 6>
4 AA;LLOGJJw'E U+%!1!1!?!?@ 6)+2+>+>vl?S+TF<(v%X #H - ![[ 4R 8 )"goo > "MM+ 6"+,G"H H+-x( E7#3#3#@#@A f$ "7OE!%- LL / '{"+,H5,P"Q Q*+#w#E40 u,"+,H5,P"Q Q*.*?*?U *Lw 25 9 '(Du(L MM ' ": .E!%. )%1A1A1O1O P"+,Ke,S"T T%eS1'+||E':H )(D 9$.x9I9I9W9W$X&/0ORW0W&X X 't 4 #5 0&/0ORW0W&X X'+'<'!>?#++D,I,I5Q (.P118 A!VAY,P
' &v&F * OOG / / 6 7 VW -
3% ${{} ee, -
e
: "&(1"2 389:
:8 % X ()JR)O PVWWXf % Z ()Lr)Q RXYYZ Q 'R(
$ZZ 1F6N &v&F 'ss T. AU A&U. <
V VV V . U 7UU U+U&&U+. V 7VV W *W Wc |D ]$ } |j | j d | & y # t $ r}t d|z |d }~ww xY w)Nr& zUnable to add handler %r)r r r r )r rw r& ri r$ s r' add_handlersz DictConfigurator.add_handlers sX <A
H!!$++j"9!"<=
H !;a!?@aG
Hs !, A AA c ` |j dd }|$|j t j | |ss|j d d D ] }|j | |j dd }|r| j
|| |j dd }|r| j || y y y )NrZ r& r )rG r] r r r& r r= r )r rw r r rZ ri r& r s r' common_logger_configz%DictConfigurator.common_logger_config s
7D) OOG / / 6 7__Q'$$Q' ( zz*d3H!!&(3 jjD1G 1 r; c t j | }| j ||| d|_ |j dd }|||_ y y )NFrq )r r r? rr rG rq )r r0 r r rw rq s r' r z!DictConfigurator.configure_logger sQ <""4( !!&&+> JJ{D1 (F !r; c T t j }| j ||| y r6 )r r r? )r r r rl s r' r z DictConfigurator.configure_root s% 8 " !!$ .ConfigStreamHandlerc | j }|j d }t | dk( rt j d| d }| j j | }t | |k r/||j |t | z
z }t | |k r/| j
j | j
j
| }|2|j d } dd l}|j | }t | | j
j" r%| j
j" j% y y y # t $ rH t j | } t | n## t $ r t j Y nw xY wY w xY w# t& $ r }|j( t* k7 r Y d }~y d }~ww xY w)N z>Lr zutf-8)
connectionrecvrF structunpackserververifydecodejsonloadsrD r r StringIOr( traceback print_excreadysetOSErrorerrno RESET_ERROR)r connchunkslenrQ r filer$ s r' handlez*listen..ConfigStreamHandler.handle s~
! u:?!==u5a8D OO 0 0 6E e*t+ % $U2C(D D e*t+{{))5 $ 2 25 9 ( % W 5 6 ' #zz% 0A &qM {{(( ))--/ )- # ) 6 $&;;u#5D 6 *4 0#, 6 ) 3 3 5 6
6
77k) *
sg B F AF % E :F F! E-,F- F
F F
FF FF F= F88F=N)r r r r_ r r; r' ConfigStreamHandlerrG s % r; r` c * e Zd Z dZdedddfdZd Zy)$listen..ConfigSocketReceiverr} localhostNc t j | ||f| t j d| _ t j
d| _ || _ || _ y )Nr r} ) r r r r abortr timeoutrV rO )r hostportr rV rO s r' r z-listen..ConfigSocketReceiver.__init__ sL ' 'tTlG D "DJ " DL DJ DKr; c < dd l }d}|s|j | j j gg g | j \ }}}|r| j t j | j }t j |s| j y )Nr )
selectsocketfilenorf handle_requestr r re r server_close)r rj re rdwrexs r' serve_until_stoppedz8listen..ConfigSocketReceiver.serve_until_stopped s E #]]DKK,>,>,@+A+-r+/<< 9
B '')$$&
$$&
r; )r r r allow_reuse_addressDEFAULT_LOGGING_CONFIG_PORTr rr r r; r' ConfigSocketReceiverrb s& +2M !d ! r; ru c ( e Zd Z fdZd Z xZS )listen..Serverc t | || _ || _ || _ || _ t
j | _ y r6 ) superr rcvrhdlrrh rO threadingEventrV )r rz r{ rh rO Server __class__s r' r z listen..Server.__init__ s: &$ ( * DI DI DI DK" *DJr; c l | j | j | j | j | j }| j dk( r|j
d | _ | j j
t j |a t j |j y )N)rh r rV rO r r} ) rz rh r{ rV rO server_addressrW r r _listenerr rr )r rN s r' runzlisten..Server.run s YYDIItyy%)ZZ&*kk 3F yyA~ " 1 1! 4 JJNN " I " & & (r; )r r r r r
__classcell__)r r~ s @r' r~ rw s
+ )r; r~ )r r r| Thread)rh rO r` ru r~ s @r' listenr sJ &, 2 ,\ 1 >)!! ). &(;T6 JJr; c t j t r
dt _ d at j y # t j w xY w)Nr} )r r r re r r r; r'
stopListeningr + sB IO I s ? A)NTN)-rY r4 r r logging.handlersr r r rL r| rT socketserverr r rt
ECONNRESETrZ r r( r4 r: r r rx r r r Ir r objectr r r r~ r r r r r r rC rD r r r r; r' r s "
A #
) X !:$L/,THn RZZ,bdd
3
f B
@T?
@ #T? #@e_ @Av AF66V=' V=p #(
,D xKt r;