U
iÛfŽ ã @ sJ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
m Z dZ e j
Zdad*dd„Zdd„ Zd d
„ Zd d „ Zd
d„ Zdd„ Zdd„ Zdd„ Ze dej¡Zdd„ ZG dd„ de ƒZ G dd„ de e ƒZ G d d „ d e e ƒZ!G d d „ d e"e ƒZ#G d d!„ d!e ƒZ$G d"d#„ d#e$ƒZ%e%Z&d$d%„ Z'e dfd&d'„Z(d(d)„ Z)dS )+é N)ÚThreadingTCPServerÚStreamRequestHandleriF# Tc C s„ dd l }t| |jƒr| }n*| |¡}t| dƒr:| | ¡ n
| | ¡ t|ƒ}t ¡ z t ƒ t ||ƒ}t
|||ƒ W 5 t
¡ X d S )Nr Úreadline)Ú configparserÚ
isinstanceZRawConfigParserZ ConfigParserÚhasattrZ read_fileÚreadÚ_create_formattersÚloggingÚ _acquireLockÚ _releaseLockÚ_clearExistingHandlersÚ_install_handlersÚ_install_loggers)ZfnameÚdefaultsÚdisable_existing_loggersr ÚcpÚ
formattersÚhandlers© r ú3/opt/alt/python38/lib64/python3.8/logging/config.pyÚ
fileConfig3 s
r c C sl | d¡} | d¡}t|ƒ}| D ]F}|d | }zt||ƒ}W q tk
rd t|ƒ t||ƒ}Y q X q |S )NÚ.r )ÚsplitÚpopÚ
__import__ÚgetattrÚAttributeError)ÚnameÚusedÚfoundÚnr r r Ú_resolveU s
r" c C s t tj| ƒS ©N)ÚmapÚstrÚstrip)Zalistr r r Ú
_strip_spacesc s r' c C s® | d d }t |ƒsi S | d¡}t|ƒ}i }|D ]v}d| }| j|ddd d}| j|ddd d}| j|d dd
d}tj}| | d ¡} | r”t| ƒ}||||ƒ}
|
||< q2|S ) Nr Úkeysú,z formatter_%sÚformatT)ÚrawÚfallbackÚdatefmtÚstyleú%Úclass)Úlenr r' Úgetr
Ú Formatterr" ) r Zflistr ZformZsectnameZfsZdfsZstlÚcÚ
class_nameÚfr r r r f s$
r c
C s^ | d d }t |ƒsi S | d¡}t|ƒ}i }g }|D ]}| d| }|d }| dd¡}zt|ttƒƒ}W n ttfk
rŽ t |ƒ}Y nX | dd ¡} t| ttƒƒ} | d
d ¡}
t|
ttƒƒ}
|| |
Ž} d |krè|d } |
| ¡ t |ƒrþ| || ¡ t |tj
jƒr2| d
d¡}
t |
ƒr2| | |
f¡ | ||< q6|D ]\} }| || ¡ q@|S )Nr r( r) z
handler_%sr0 Ú formatterÚ Úargsú()Úkwargsz{}ÚlevelÚtarget)r1 r r' r2 ÚevalÚvarsr
r Ú NameErrorr" ÚsetLevelÚ setFormatterÚ
issubclassr Ú
MemoryHandlerÚappendZ setTarget)r r Úhlistr ZfixupsÚhandÚsectionÚklassÚfmtr9 r; Úhr< r= Útr r r r | sB
r c C sT t j}| D ]D}|jj| }||krHt|t jƒsN| t j¡ g |_d|_ q
||_
q
d S )NT) r
ÚrootÚmanagerÚ
loggerDictr Z PlaceHolderrA ZNOTSETr Ú propagateÚdisabled)ÚexistingÚ
child_loggersÚdisable_existingrM ÚlogÚloggerr r r Ú_handle_existing_loggers¡ s rW c C s | d d }| d¡}tt|ƒƒ}| d¡ | d }tj}|}d|krX|d }| |¡ |jd d … D ]}| |¡ qf|d } t | ƒr°| d¡} t| ƒ} | D ]}
|
||
¡ qœt|j j
¡ ƒ} | ¡ g } |D ](}| d| }|d }
|jd
d d }t |
¡}|
| krv| |
¡d }|
d
}t |ƒ}t | ƒ}||k rl| | d |… |kr`| | | ¡ |d 7 }q2| |
¡ d|kr’|d }| |¡ |jd d … D ]}| |¡ q ||_d|_|d } t | ƒrÐ| d¡} t| ƒ} | D ]}
|
||
¡ qäqÐt| | |ƒ d S )NÚloggersr( r) rM Z logger_rootr< r z logger_%sÚqualnamerP é )r, r r )r Úlistr' Úremover
rM rA r Ú
removeHandlerr1 Ú
addHandlerrN rO r( ÚsortZgetintÚ getLoggerÚindexrE rP rQ rW )r r rT ZllistrH rM rU r< rK rF rG rR rS ZqnrP rV ÚiÚprefixedÚpflenÚ num_existingr r r r · sd
r c C s. t j ¡ t t jd d … ¡ t jd d …= d S r# )r
Ú _handlersÚclearZshutdownZ _handlerListr r r r r
s
r
z^[a-z_][a-z0-9_]*$c C s t | ¡}|std| ƒ‚dS )Nz!Not a valid Python identifier: %rT)Ú
IDENTIFIERÚmatchÚ
ValueError)ÚsÚmr r r Ú valid_ident s
rm c @ s e Zd Zddd„Zdd„ ZdS )ÚConvertingMixinTc C sB | j |¡}||k r>|r || |< t|ƒtttfkr>| |_||_|S r# )Ú configuratorÚconvertÚtypeÚConvertingDictÚConvertingListÚConvertingTupleÚparentÚkey)Úselfrv ÚvalueÚreplaceÚresultr r r Úconvert_with_key" s
ÿz ConvertingMixin.convert_with_keyc C s0 | j |¡}||k r,t|ƒtttfkr,| |_|S r# )ro rp rq rr rs rt ru )rw rx rz r r r rp . s
ÿzConvertingMixin.convertN)T)Ú__name__Ú
__module__Ú __qualname__r{ rp r r r r rn s
rn c @ s( e Zd Zdd„ Zddd„Zd dd„ZdS )
rr c C s t | |¡}| ||¡S r# )ÚdictÚ __getitem__r{ ©rw rv rx r r r r€ C s zConvertingDict.__getitem__Nc C s t | ||¡}| ||¡S r# )r r2 r{ ©rw rv Údefaultrx r r r r2 G s zConvertingDict.getc C s t | ||¡}| j||ddS ©NF)ry )r r r{ r‚ r r r r K s zConvertingDict.pop)N)N)r| r} r~ r€ r2 r r r r r rr @ s
rr c @ s e Zd Zdd„ Zddd„ZdS )rs c C s t | |¡}| ||¡S r# )r[ r€ r{ r r r r r€ Q s zConvertingList.__getitem__éÿÿÿÿc C s t | |¡}| |¡S r# )r[ r rp )rw Úidxrx r r r r U s zConvertingList.popN)r… )r| r} r~ r€ r r r r r rs O s rs c @ s e Zd Zdd„ ZdS )rt c C s t | |¡}| j||ddS r„ )Útupler€ r{ r r r r r€ [ s zConvertingTuple.__getitem__N)r| r} r~ r€ r r r r rt Y s rt c @ sˆ e Zd Ze d¡Ze d¡Ze d¡Ze d¡Ze d¡Z dddœZ
e e ƒZ
d d
„ Zd d „ Zd
d„ Zdd„ Zdd„ Zdd„ Zdd„ ZdS )ÚBaseConfiguratorz%^(?P[a-z]+)://(?P.*)$z ^\s*(\w+)\s*z^\.\s*(\w+)\s*z^\[\s*(\w+)\s*\]\s*z^\d+$Ú ext_convertÚ cfg_convert)ZextZcfgc C s t |ƒ| _| | j_d S r# )rr Úconfigro )rw r‹ r r r Ú__init__t s
zBaseConfigurator.__init__c C s | d¡}| d¡}z^| |¡}|D ]H}|d| 7 }zt||ƒ}W q$ tk
rj | |¡ t||ƒ}Y q$X q$|W S tk
r¼ t ¡ dd … \}}td||f ƒ}|| |_ |_
|‚Y nX d S )Nr r rZ zCannot resolve %r: %s) r r Úimporterr r Ú ImportErrorÚsysÚexc_inforj Ú __cause__Ú
__traceback__) rw rk r r r ZfragÚeÚtbÚvr r r Úresolvex s"
zBaseConfigurator.resolvec C s
| |¡S r# )r– ©rw rx r r r r‰ s z BaseConfigurator.ext_convertc C sþ |}| j |¡}|d kr&td| ƒ‚nÔ|| ¡ d … }| j| ¡ d }|rú| j |¡}|rn|| ¡ d }nd| j |¡}|rÒ| ¡ d }| j |¡s || }n2zt |ƒ}|| }W n t
k
rÐ || }Y nX |rè|| ¡ d … }qHtd||f ƒ‚qH|S )NzUnable to convert %rr zUnable to convert %r at %r) Ú WORD_PATTERNri rj Úendr‹ ÚgroupsÚ DOT_PATTERNÚ
INDEX_PATTERNÚ
DIGIT_PATTERNÚintÚ TypeError)rw rx Úrestrl Údr† r! r r r rŠ “ s4
ÿz BaseConfigurator.cfg_convertc C sÐ t |tƒs$t |tƒr$t|ƒ}| |_n¨t |tƒsHt |tƒrHt|ƒ}| |_n„t |tƒsvt |tƒrvt|dƒsvt|ƒ}| |_nVt |t ƒrÌ| j
|¡}|rÌ| ¡ }|d }| j
|d ¡}|rÌ|d }t| |ƒ}||ƒ}|S )NÚ_fieldsÚprefixÚsuffix)r rr r ro rs r[ rt r‡ r r% ÚCONVERT_PATTERNri Ú groupdictÚvalue_convertersr2 r )rw rx rl r¡ r£ Z converterr¤ r r r rp µ s0
ÿÿ
zBaseConfigurator.convertc sj ˆ d¡}t|ƒs | |¡}ˆ dd ¡}‡ fdd„ˆ D ƒ}|f |Ž}|rf| ¡ D ]\}}t|||ƒ qP|S )Nr: r c s i | ]}t |ƒr|ˆ | “qS r ©rm ©Ú.0Úk©r‹ r r Ú
Ø s z5BaseConfigurator.configure_custom..)r Úcallabler– ÚitemsÚsetattr)rw r‹ r4 Úpropsr; rz r rx r r¬ r Úconfigure_customÑ s
z!BaseConfigurator.configure_customc C s t |tƒrt|ƒ}|S r# )r r[ r‡ r— r r r Úas_tupleß s
zBaseConfigurator.as_tupleN)r| r} r~ ÚreÚcompiler¥ r˜ r› rœ r r§ Ú staticmethodr r rŒ r– r‰ rŠ rp r² r³ r r r r rˆ ` s
þ" rˆ c @ sZ e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zddd„Z ddd„Z
ddd„Z dS )ÚDictConfiguratorc C sÊ | j }d|krtdƒ‚|d dkr2td|d ƒ‚| dd¡}i }t ¡ zn|r | d|¡}|D ]„}|tjkr€td| ƒ‚qdz6tj| }|| }| d d ¡}|r´| t |¡¡ W qd t
k
ræ } ztd
| ƒ| ‚W 5 d } ~ X Y qdX qd| d |¡}
|
D ]N}z| ||
| d ¡ W qú t
k
rF } ztd
| ƒ| ‚W 5 d } ~ X Y qúX qú| dd ¡} | r¸z| | d ¡ W n. t
k
rš } ztdƒ| ‚W 5 d } ~ X Y nX n| dd ¡} t
ƒ | d|¡}
|
D ]P}z| |
| ¡|
|< W n2 t
k
r } ztd| ƒ| ‚W 5 d } ~ X Y nX qÂ| d|¡}|D ]P}z| || ¡||< W n2 t
k
rp } ztd| ƒ| ‚W 5 d } ~ X Y nX q$| d|¡}g }t|ƒD ]v}z | || ¡}||_|||< W nN t
k
r } z.dt| jƒkrâ| |¡ ntd
| ƒ| ‚W 5 d } ~ X Y nX qŽ|D ]Z}z | || ¡}||_|||< W n2 t
k
r` } ztd
| ƒ| ‚W 5 d } ~ X Y nX q
tj} t| jj ¡ ƒ}| ¡ g }| d |¡}
|
D ]Â}||kr| |¡d }|d }t |ƒ}t |ƒ}||k r|| d |… |krú| || ¡ |d7 }qÌ| |¡ z| ||
| ¡ W n2 t
k
rV } ztd
| ƒ| ‚W 5 d } ~ X Y nX q˜t ||| ƒ | dd ¡} | r¸z| | ¡ W n. t
k
r¶ } ztdƒ| ‚W 5 d } ~ X Y nX W 5 t ¡ X d S )NÚversionz$dictionary doesn't specify a versionrZ zUnsupported version: %sÚ incrementalFr z No handler found with name %rr< z Unable to configure handler %rrX Tz Unable to configure logger %rrM z Unable to configure root loggerr r z Unable to configure formatter %rÚfiltersz Unable to configure filter %rútarget not configured yetr ) r‹ rj r r
r r r2 rf rA Ú _checkLevelÚ ExceptionÚconfigure_loggerÚconfigure_rootr
Úconfigure_formatterÚconfigure_filterÚsortedÚconfigure_handlerr r% r‘ rE rM r[ rN rO r( r_ ra r1 r\ rW )rw r‹ r¹ Z
EMPTY_DICTr r ÚhandlerZhandler_configr< r“ rX rM rT r rº ZdeferredrR rS rb rc rd re r r r Ú configureë s
ÿ
ÿÿ ÿÿ ÿ ÿ ÿÿ ÿÿ ÿÿ ÿÿ
ÿÿÿ ÿzDictConfigurator.configurec
C sâ d|krr|d }z| |¡}W qÞ tk
rn } z2dt|ƒkr>‚ | d¡|d< ||d< | |¡}W 5 d }~X Y qÞX nl| dd ¡}| dd ¡}| dd¡}| dd ¡}|s®tj} nt|ƒ} d |krÒ| ||||d ƒ}n | |||ƒ}|S )
Nr: z'format'r* rJ r- r. r/ r0 Zvalidate)r² rŸ r% r r2 r
r3 r" )
rw r‹ Úfactoryrz ÚterJ Zdfmtr. Úcnamer4 r r r rÀ ‰ s* z$DictConfigurator.configure_formatterc C s. d|kr| |¡}n| dd¡}t |¡}|S )Nr: r r8 )r² r2 r
ZFilter)rw r‹ rz r r r r rÁ s
z!DictConfigurator.configure_filterc C sX |D ]N}z| | jd | ¡ W q tk
rP } ztd| ƒ|‚W 5 d }~X Y qX qd S )Nrº zUnable to add filter %r)Z addFilterr‹ r½ rj )rw Zfiltererrº r6 r“ r r r Ú add_filters¶ s
z DictConfigurator.add_filtersc
s„ t ˆ ƒ}ˆ dd ¡}|r\z| jd | }W n0 tk
rZ } ztd| ƒ|‚W 5 d }~X Y nX ˆ dd ¡}ˆ dd ¡}dˆ kr ˆ d¡}t|ƒs˜| |¡}|}nˆ d¡} | | ¡}
t|
tj j
ƒrFdˆ krFz>| jd ˆ d } t | tj ƒsˆ
|¡ td
ƒ‚| ˆ d< W n6 tk
rB } ztd ˆ d ƒ|‚W 5 d }~X Y nX nZt|
tj jƒrtd ˆ krt| ˆ d ¡ˆ d < n,t|
tj jƒr d
ˆ kr | ˆ d
¡ˆ d
< |
}ˆ dd ¡} ‡ fdd„ˆ D ƒ}
z|f |
Ž}W nL tk
r } z,dt|ƒkrô‚ |
d¡|
d< |f |
Ž}W 5 d }~X Y nX |r.| |¡ |d k rH| t |¡¡ |rZ| ||¡ | r€| ¡ D ]\}}t|||ƒ qh|S )Nr7 r zUnable to set formatter %rr< rº r: r0 r= r r» z Unable to set target handler %rZmailhostZaddressr c s i | ]}t |ƒr|ˆ | “qS r r¨ r© r¬ r r r æ s z6DictConfigurator.configure_handler..z'stream'ÚstreamZstrm)r r r‹ r½ rj r® r– rC r
r rD r ZHandlerÚupdaterŸ Z SMTPHandlerr³ Z
SysLogHandlerr% rB rA r¼ rÉ r¯ r° )rw r‹ Z config_copyr7 r“ r< rº r4 rÆ rÈ rI Zthr± r; rz rÇ r rx r r¬ r rà ¾ s~ ÿÿ
ÿ
ÿÿÿÿ
z"DictConfigurator.configure_handlerc C sX |D ]N}z| | jd | ¡ W q tk
rP } ztd| ƒ|‚W 5 d }~X Y qX qd S )Nr zUnable to add handler %r)r^ r‹ r½ rj )rw rV r rK r“ r r r Ú add_handlersý s
z DictConfigurator.add_handlersFc C s‚ | dd ¡}|d k r$| t |¡¡ |s~|jd d … D ]}| |¡ q6| dd ¡}|rb| ||¡ | dd ¡}|r~| ||¡ d S )Nr< r rº )r2 rA r
r¼ r r] rÌ rÉ )rw rV r‹ r¹ r< rK r rº r r r Úcommon_logger_config s z%DictConfigurator.common_logger_configc C s6 t |¡}| |||¡ | dd ¡}|d k r2||_d S )NrP )r
r` rÍ r2 rP )rw r r‹ r¹ rV rP r r r r¾ s
z!DictConfigurator.configure_loggerc C s t ¡ }| |||¡ d S r# )r
r` rÍ )rw r‹ r¹ rM r r r r¿ s z DictConfigurator.configure_rootN)F)F)F) r| r} r~ rÅ rÀ rÁ rÉ rà rÌ rÍ r¾ r¿ r r r r r· å s $ ?
r· c C s t | ƒ ¡ d S r# )ÚdictConfigClassrÅ r¬ r r r Ú
dictConfig& s rÏ c sD G dd„ dt ƒ}G dd„ dtƒ}G ‡ fdd„dtjƒ‰ ˆ ||| |ƒS )Nc @ s e Zd Zdd„ ZdS )z#listen..ConfigStreamHandlerc S sD z
| j }| d¡}t|ƒdkr
t d|¡d }| j |¡}t|ƒ|k rb|| |t|ƒ ¡ }q>| jjd k rz| j |¡}|d k rô| d¡}z dd l}| |¡}t
|ƒ W nH t k
rò t
|¡}z t|ƒ W n t k
rì t ¡ Y nX Y nX | jjr
| jj ¡ W n2 tk
r> } z|jtkr.‚ W 5 d }~X Y nX d S )Né z>Lr zutf-8)Z
connectionZrecvr1 ÚstructZunpackÚserverÚverifyÚdecodeÚjsonÚloadsrÏ r½ ÚioÚStringIOr Ú tracebackÚ print_excÚreadyÚsetÚOSErrorÚerrnoÚ RESET_ERROR)rw ZconnÚchunkZslenrÕ r¡ Úfiler“ r r r ÚhandleF s6
z*listen..ConfigStreamHandler.handleN)r| r} r~ râ r r r r ÚConfigStreamHandler? s rã c @ s, e Zd ZdZdedddfdd„Zdd„ ZdS )z$listen..ConfigSocketReceiverrZ Z localhostNc S s> t | ||f|¡ t ¡ d| _t ¡ d| _|| _|| _d S )Nr rZ ) r rŒ r
r Úabortr ÚtimeoutrÛ rÓ )rw ZhostÚportrÄ rÛ rÓ r r r rŒ t s z-listen..ConfigSocketReceiver.__init__c S s` dd l }d}|sT| | j ¡ gg g | j¡\}}}|r<| ¡ t ¡ | j}t ¡ q | ¡ d S )Nr )
ÚselectZsocketÚfilenorå Zhandle_requestr
r rä r Z server_close)rw rç rä ZrdZwrZexr r r Úserve_until_stopped~ s þ
z8listen..ConfigSocketReceiver.serve_until_stopped)r| r} r~ Zallow_reuse_addressÚDEFAULT_LOGGING_CONFIG_PORTrŒ ré r r r r ÚConfigSocketReceiverm s ÿ
rë c s& e Zd Z‡‡ fdd„Zdd„ Z‡ ZS )zlisten..Serverc s4 t ˆ | ƒ ¡ || _|| _|| _|| _t ¡ | _d S r# ) ÚsuperrŒ ÚrcvrÚhdlrræ rÓ Ú threadingZEventrÛ )rw rí rî ræ rÓ )ÚServerÚ __class__r r rŒ Ž s z listen..Server.__init__c S sZ | j | j| j| j| jd}| jdkr0|jd | _| j ¡ t ¡ |a t
¡ | ¡ d S )N)ræ rÄ rÛ rÓ r rZ ) rí ræ rî rÛ rÓ Zserver_addressrÜ r
r Ú _listenerr ré )rw rÒ r r r Úrun– s þ
zlisten..Server.run)r| r} r~ rŒ ró Ú
__classcell__r ©rð )rñ r rð Œ s rð )r r rï ZThread)ræ rÓ rã rë r rõ r Úlisten+ s . rö c C s* t ¡ ztrdt_d aW 5 t ¡ X d S )NrZ )r
r r rò rä r r r r Ú
stopListening¥ s r÷ )NT)*rÞ r× r
Zlogging.handlersr´ rÑ r rï rÙ Z socketserverr r rê Z
ECONNRESETrß rò r r" r' r r rW r r
rµ ÚIrh rm Úobjectrn r rr r[ rs r‡ rt rˆ r· rÎ rÏ rö r÷ r r r r Ú sF
"%W!
Az