B
¶þgýÄN‘Šã @ 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 d t
¡ X d S )Nr Úreadline)Ú configparserÚ
isinstanceZRawConfigParserZ ConfigParserÚhasattrZ read_fileÚreadÚ_create_formattersÚloggingÚ _acquireLockÚ_clearExistingHandlersÚ_install_handlersÚ_install_loggersÚ _releaseLock)ZfnameÚdefaultsÚdisable_existing_loggersr ÚcpÚ
formattersÚhandlers© r ú3/opt/alt/python37/lib64/python3.7/logging/config.pyÚ
fileConfig3 s
r c C sp | d¡} | d¡}t|ƒ}xN| D ]F}|d | }yt||ƒ}W q" tk
rf t|ƒ t||ƒ}Y q"X q"W |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 }x~|D ]v}d| }| j|ddd d}| j|ddd d}| j|d dd
d}tj}| | d ¡} | r–t| ƒ}||||ƒ}
|
||< q4W |S ) Nr Úkeysú,z formatter_%sÚformatT)ÚrawÚfallbackÚdatefmtÚstyleú%Úclass)Úlenr r& Úgetr
Ú Formatterr" ) r Úflistr ZformZsectnameZfsZdfsZstlÚcÚ
class_nameÚfr r r r f s$
r c
C sj | d d }t |ƒsi S | d¡}t|ƒ}i }g }x|D ]}| d| }|d }| dd¡}yt|ttƒƒ}W n ttfk
r’ t |ƒ}Y nX | dd ¡} t| ttƒƒ} | d
d ¡}
t|
ttƒƒ}
|| |
Ž} d |krì|d } |
| ¡ t |ƒr| || ¡ t |tj
jƒr8| d
d¡}
t |
ƒr8| | |
f¡ | ||< q:W x |D ]\} }| || ¡ qJW |S )Nr r' r( z
handler_%sr/ Ú formatterÚ Úargsz()Úkwargsz{}ÚlevelÚtarget)r0 r r& r1 Ú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 sX t j}xL| D ]D}|jj| }||krJt|t jƒsP| t j¡ g |_d|_ q ||_
q W d S )NT) r
ÚrootÚmanagerÚ
loggerDictr Z PlaceHolderr@ ZNOTSETr Ú propagateÚdisabled)ÚexistingÚ
child_loggersÚdisable_existingrL ÚlogÚloggerr r r Ú_handle_existing_loggers¡ s
rV c C s& | d d }| d¡}tt|ƒƒ}| d¡ | d }tj}|}d|krX|d }| |¡ x |jd d … D ]}| |¡ qhW |d } t | ƒr¸| d¡} t| ƒ} x| D ]}
|
||
¡ q¢W t|j j
¡ ƒ} | ¡ g } x>|D ]4}| d| }|d }
|jd
d d }t |
¡}|
| kr†| |
¡d }|
d
}t |ƒ}t | ƒ}x<||k rz| | d |… |krn| | | ¡ |d 7 }q@W | |
¡ d|kr¢|d }| |¡ x"|jd d … D ]}| |¡ q²W ||_d|_|d } t | ƒrÜ| d¡} t| ƒ} x | D ]}
|
||
¡ qúW qÜW t| | |ƒ d S )NÚloggersr' r( rL Z logger_rootr; r z logger_%sÚqualnamerO é )r+ r r )r Úlistr& Úremover
rL r@ r Ú
removeHandlerr0 Ú
addHandlerrM rN r' ÚsortZgetintÚ getLoggerÚindexrD rO rP rV )r r rS ZllistrG rL rT r; rJ rE rF rQ rR ZqnrO rU ÚiÚprefixedÚpflenÚ num_existingr r r r · sd
r c C s. t j ¡ t t jd d … ¡ t jd d …= d S )N)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
rl c @ s e Zd Zddd„Zdd„ ZdS )ÚConvertingMixinTc C sB | j |¡}||k r>|r || |< t|ƒtttfkr>| |_||_|S )N)Ú configuratorÚconvertÚtypeÚConvertingDictÚConvertingListÚConvertingTupleÚparentÚkey)Úselfru ÚvalueÚreplaceÚresultr r r Úconvert_with_key" s
z ConvertingMixin.convert_with_keyc C s0 | j |¡}||k r,t|ƒtttfkr,| |_|S )N)rn ro rp rq rr rs rt )rv rw ry r r r ro . s
zConvertingMixin.convertN)T)Ú__name__Ú
__module__Ú __qualname__rz ro r r r r rm s
rm c @ s( e Zd Zdd„ Zddd„Zd dd„ZdS )
rq c C s t | |¡}| ||¡S )N)ÚdictÚ __getitem__rz )rv ru rw r r r r C s zConvertingDict.__getitem__Nc C s t | ||¡}| ||¡S )N)r~ r1 rz )rv ru Údefaultrw r r r r1 G s zConvertingDict.getc C s t | ||¡}| j||ddS )NF)rx )r~ r rz )rv ru r€ rw r r r r K s zConvertingDict.pop)N)N)r{ r| r} r r1 r r r r r rq @ s
rq c @ s e Zd Zdd„ Zddd„ZdS )rr c C s t | |¡}| ||¡S )N)rZ r rz )rv ru rw r r r r Q s zConvertingList.__getitem__éÿÿÿÿc C s t | |¡}| |¡S )N)rZ r ro )rv Úidxrw r r r r U s zConvertingList.popN)r )r{ r| r} r r r r r r rr O s rr c @ s e Zd Zdd„ ZdS )rs c C s t | |¡}| j||ddS )NF)rx )Útupler rz )rv ru rw r r r r [ s zConvertingTuple.__getitem__N)r{ r| r} r r r r r rs Y s rs 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 )N)rq Úconfigrn )rv r‡ r r r Ú__init__t s
zBaseConfigurator.__init__c C sÄ | d¡}| d¡}y`| |¡}xP|D ]H}|d| 7 }yt||ƒ}W q& tk
rl | |¡ t||ƒ}Y q&X q&W |S tk
r¾ t ¡ dd … \}}td||f ƒ}|| |_ |_
|‚Y nX d S )Nr r rY zCannot resolve %r: %s) r r Úimporterr r Ú ImportErrorÚsysÚexc_infori Ú __cause__Ú
__traceback__) rv rj r r r ZfragÚeÚtbÚvr r r Úresolvex s"
zBaseConfigurator.resolvec C s
| |¡S )N)r’ )rv rw r r r r… s z BaseConfigurator.ext_convertc C s |}| j |¡}|d kr&td| ƒ‚nØ|| ¡ d … }| j| ¡ d }x´|rü| j |¡}|rp|| ¡ d }nd| j |¡}|rÔ| ¡ d }| j |¡s¢|| }n2yt |ƒ}|| }W n t
k
rÒ || }Y nX |rê|| ¡ d … }qJtd||f ƒ‚qJW |S )NzUnable to convert %rr zUnable to convert %r at %r) Ú WORD_PATTERNrh ri Úendr‡ ÚgroupsÚ DOT_PATTERNÚ
INDEX_PATTERNÚ
DIGIT_PATTERNÚintÚ TypeError)rv rw Úrestrk Údr‚ r! r r r r† “ s2
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 rq r~ rn rr rZ rs rƒ r r$ ÚCONVERT_PATTERNrh Ú groupdictÚvalue_convertersr1 r )rv rw rk rœ rž Z converterrŸ r r r ro µ s*
zBaseConfigurator.convertc sn ˆ d¡}t|ƒs | |¡}ˆ dd ¡}‡ fdd„ˆ D ƒ}|f |Ž}|rjx | ¡ D ]\}}t|||ƒ qRW |S )Nz()r c s i | ]}t |ƒrˆ | |“qS r )rl )Ú.0Úk)r‡ r r ú
Ø s z5BaseConfigurator.configure_custom..)r Úcallabler’ ÚitemsÚsetattr)rv r‡ r4 Úpropsr: ry r rw r )r‡ r Úconfigure_customÑ s
z!BaseConfigurator.configure_customc C s t |tƒrt|ƒ}|S )N)r rZ rƒ )rv rw 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† ro 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 ¡ z|rª| d|¡}xŒ|D ]„}|tjkr‚td| ƒ‚qfy6tj| }|| }| d d ¡}|r¶| t |¡¡ W qf t k
rè } ztd
| ƒ| ‚W d d } ~ X Y qfX qfW | d |¡}
xX|
D ]P}y|
||
| d ¡ W n2 t k
rL } ztd
| ƒ| ‚W d d } ~ X Y nX q W | dd ¡} | rÚy| | d ¡ W n. t k
r¤ } ztdƒ| ‚W d d } ~ X Y nX n0| dd ¡} t ƒ | d|¡}
xX|
D ]P}y|
|
| ¡|
|< W n2 t k
r } ztd| ƒ| ‚W d d } ~ X Y nX qÎW | d|¡}xX|D ]P}y| || ¡||< W n2 t k
r€ } ztd| ƒ| ‚W d d } ~ X Y nX q4W | d|¡}g }x‚t|ƒD ]v}y | || ¡}||_|||< W nN t k
r } z.dt| jƒkrö| |¡ ntd
| ƒ| ‚W d d } ~ X Y nX q¢W xb|D ]Z}y | || ¡}||_|||< W n2 t k
rx } ztd
| ƒ| ‚W d d } ~ X Y nX q"W tj} t| jj ¡ ƒ}| ¡ g }| d |¡}
xÎ|
D ]Æ}||kr0| |¡d }|d }t |ƒ}t |ƒ}x<||k r$|| d |… |kr| || ¡ |d7 }qêW | |¡ y|
||
| ¡ W n2 t k
rv } ztd
| ƒ| ‚W d d } ~ X Y nX q´W t ||| ƒ | dd ¡} | rÚy| | ¡ W n. t k
rØ } ztdƒ| ‚W d d } ~ X Y nX W d t ¡ X d S )NÚversionz$dictionary doesn't specify a versionrY zUnsupported version: %sÚ incrementalFr z No handler found with name %rr; z Unable to configure handler %rrW Tz Unable to configure logger %rrL z Unable to configure root loggerr r z Unable to configure formatter %rÚfiltersz Unable to configure filter %rztarget not configured yetr ) r‡ ri r r
r r1 re r@ Ú _checkLevelÚ ExceptionÚconfigure_loggerÚconfigure_rootr Úconfigure_formatterÚconfigure_filterÚsortedÚconfigure_handlerr r$ r rD rL rZ rM rN r' r^ r` r0 r[ rV r )rv r‡ r± Z
EMPTY_DICTr r ÚhandlerZhandler_configr; r rW rL rS r r² ZdeferredrQ rR ra rb rc rd r r r Ú configureë sÔ
"
"
" "
"
" zDictConfigurator.configurec
C sÆ d|krr|d }y| |¡}W q tk
rn } z2dt|ƒkr>‚ | d¡|d< ||d< | |¡}W d d }~X Y qÂX nP| dd ¡}| dd ¡}| dd¡}| dd ¡}|s®tj} nt|ƒ} | |||ƒ}|S ) Nz()z'format'r) rI r, r- r. r/ )rª rš r$ r r1 r
r2 r" )
rv r‡ Úfactoryry ÚterI Zdfmtr- Úcnamer4 r r r r· ‰ s& z$DictConfigurator.configure_formatterc C s. d|kr| |¡}n| dd¡}t |¡}|S )Nz()r r8 )rª r1 r
ZFilter)rv r‡ ry r r r r r¸ ¥ s
z!DictConfigurator.configure_filterc C s\ xV|D ]N}y| | jd | ¡ W q tk
rR } ztd| ƒ|‚W d d }~X Y qX qW d S )Nr² zUnable to add filter %r)Z addFilterr‡ r´ ri )rv Zfiltererr² r6 r r r r Ú add_filters® s
z DictConfigurator.add_filtersc
sˆ t ˆ ƒ}ˆ dd ¡}|r\y| jd | }W n0 tk
rZ } ztd| ƒ|‚W d d }~X Y nX ˆ dd ¡}ˆ dd ¡}dˆ kr ˆ d¡}t|ƒs˜| |¡}|}nˆ d¡} | | ¡}
t|
tj j
ƒrFdˆ krFy>| jd ˆ d } t | tj ƒsˆ
|¡ td
ƒ‚| ˆ d< W n6 tk
rB } ztd ˆ d ƒ|‚W d d }~X Y nX nZt|
tj jƒrtd ˆ krt| ˆ d ¡ˆ d < n,t|
tj jƒr d
ˆ kr | ˆ d
¡ˆ d
< |
}ˆ dd ¡} ‡ fdd„ˆ D ƒ}
y|f |
Ž}W nL tk
r } z,dt|ƒkrô‚ |
d¡|
d< |f |
Ž}W d d }~X Y nX |r.| |¡ |d k rH| t |¡¡ |rZ| ||¡ | r„x"| ¡ D ]\}}t|||ƒ qjW |S )Nr7 r zUnable to set formatter %rr; r² z()r/ r< r ztarget not configured yetz Unable to set target handler %rZmailhostZaddressr c s i | ]}t |ƒrˆ | |“qS r )rl )r£ r¤ )r‡ r r r¥ Þ s z6DictConfigurator.configure_handler..z'stream'ÚstreamZstrm)r~ r r‡ r´ ri r¦ r’ rB r
r rC r ZHandlerÚupdaterš Z SMTPHandlerr« Z
SysLogHandlerr$ rA r@ r³ rÀ r§ r¨ )rv r‡ Z config_copyr7 r r; r² r4 r½ r¿ rH Úthr© r: ry r¾ r rw r )r‡ r rº ¶ sl
"
z"DictConfigurator.configure_handlerc C s\ xV|D ]N}y| | jd | ¡ W q tk
rR } ztd| ƒ|‚W d d }~X Y qX qW d S )Nr zUnable to add handler %r)r] r‡ r´ ri )rv rU r rJ r r r r Ú add_handlersõ s
z DictConfigurator.add_handlersFc C s† | dd ¡}|d k r$| t |¡¡ |s‚x |jd d … D ]}| |¡ q8W | dd ¡}|rf| ||¡ | dd ¡}|r‚| ||¡ d S )Nr; r r² )r1 r@ r
r³ r r\ rÄ rÀ )rv rU r‡ r± r; rJ r r² r r r Úcommon_logger_configý s z%DictConfigurator.common_logger_configc C s6 t |¡}| |||¡ | dd ¡}|d k r2||_d S )NrO )r
r_ rÅ r1 rO )rv r r‡ r± rU rO r r r rµ s
z!DictConfigurator.configure_loggerc C s t ¡ }| |||¡ d S )N)r
r_ rÅ )rv r‡ r± rL 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 )N)Ú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 sH y| j }| d¡}t|ƒdkrt d|¡d }| j |¡}x&t|ƒ|k rd|| |t|ƒ ¡ }q@W | jjd k r~| j |¡}|d k rø| d¡}y dd l}| |¡}t
|ƒ W nH t k
rö t
|¡}y t|ƒ W n t k
rð t ¡ Y nX Y nX | jjr| jj ¡ W n2 tk
rB } z|jtkr2‚ W d d }~X Y nX d S )Né z>Lr zutf-8)Z
connectionZrecvr0 ÚstructÚunpackÚserverÚverifyÚdecodeÚjsonÚloadsrÇ r´ ÚioÚStringIOr Ú tracebackÚ print_excÚreadyÚsetÚOSErrorÚerrnoÚ RESET_ERROR)rv ZconnÚchunkZslenrÎ rœ Úfiler r r r Úhandle> s6
z*listen..ConfigStreamHandler.handleN)r{ r| r} rÛ r r r r ÚConfigStreamHandler7 s rÜ c @ s, e Zd ZdZdedddfdd„Zdd„ ZdS )z$listen..ConfigSocketReceiverrY Z localhostNc S s> t | ||f|¡ t ¡ d| _t ¡ d| _|| _|| _d S )Nr rY ) r rˆ r
r Úabortr ÚtimeoutrÔ rÌ )rv ZhostÚportr» rÔ rÌ r r r rˆ l s z-listen..ConfigSocketReceiver.__init__c S sd dd l }d}xJ|sV| | j ¡ gg g | j¡\}}}|r>| ¡ t ¡ | j}t ¡ qW | ¡ d S )Nr )
ÚselectZsocketÚfilenorÞ Zhandle_requestr
r rÝ r Z server_close)rv rà rÝ ZrdZwrZexr r r Úserve_until_stoppedv s z8listen..ConfigSocketReceiver.serve_until_stopped)r{ r| r} Zallow_reuse_addressÚDEFAULT_LOGGING_CONFIG_PORTrˆ râ r r r r ÚConfigSocketReceivere s rä c s& e Zd Z‡‡ fdd„Zdd„ Z‡ ZS )zlisten..Serverc s4 t ˆ | ƒ ¡ || _|| _|| _|| _t ¡ | _d S )N) Úsuperrˆ ÚrcvrÚhdlrrß rÌ Ú threadingZEventrÔ )rv 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 rY ) ræ rß rç rÔ rÌ Zserver_addressrÕ r
r Ú _listenerr râ )rv 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 d t ¡ X d S )NrY )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
rV r r r ÚIrg rl Úobjectrm r~ rq rZ rr rƒ rs r„ r¯ rÆ rÇ rî rï r r r r Ú sF
"%W!
9z