3
2aЌ
@ sp d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZyd dlZ d dl
Z
W n e k
rl dZ Y nX d dl m
Z
mZ dZe jZdad*ddZdd Zd d
Zd d Zd
d Zdd Zdd Zdd Zejdej Z dd Z G 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*edfd&d'Z+d(d) Z,dS )+ N)ThreadingTCPServerStreamRequestHandleriF# Tc
C s dd l }t| |jr| }n*|j|}t| dr:|j| n
|j| t|}tj z t
t ||}t ||| W d tj
X d S )Nr readline) configparser
isinstanceZRawConfigParserZ ConfigParserhasattrZ read_fileread_create_formatterslogging _acquireLock_clearExistingHandlers_install_handlers_install_loggers _releaseLock)Zfnamedefaultsdisable_existing_loggersr cp
formattershandlers r +/opt/alt/python36/lib64/python3.6/config.py
fileConfig8 s
r c C sp | j d} | jd}t|}xN| D ]F}|d | }yt||}W q" tk
rf t| t||}Y q"X q"W |S )N.r )splitpop
__import__getattrAttributeError)nameusedfoundnr r r _resolveZ s
r" c C s t dd | S )Nc S s | j S )N)strip)xr r r i s z _strip_spaces..)map)Zalistr r r
_strip_spacesh s r' c C s | d d }t |si S |jd}t|}i }x~|D ]v}d| }| j|ddd d}| j|ddd d}| j|d dd
d}tj}| | jd } | rt| }||||}
|
||< q4W |S ) Nr keys,z formatter_%sformatT)rawfallbackdatefmtstyle%class)lenr r' getr
Formatterr" ) r flistr ZformZsectnameZfsZdfsZstlc
class_namefr r r r k s$
r c
C sD | d d }t |si S |jd}t|}i }g }x|D ]}| d| }|d }|jdd}yt|tt}W n ttfk
r t |}Y nX |d } t| tt} || }
d |kr|d } |
j
| t |r|
j || t |tj
jr|jd
d} t | r|j|
| f |
||< q8W x |D ]\}
}
|
j||
q$W |S ) Nr r( r) z
handler_%sr0 formatter argsleveltarget)r1 r r' r2 evalvarsr
r NameErrorr" setLevel setFormatter
issubclassr
MemoryHandlerappendZ setTarget)r r hlistr Zfixupshandsectionklassfmtr: hr; r< tr r r r
s>
r
c C sH t j}x<| D ]4}|jj| }||kr:t j|_g |_d|_q ||_q W d S )NT) r
rootmanager
loggerDictZNOTSETr; r propagatedisabled)existing
child_loggersdisable_existingrL logloggerr r r _handle_existing_loggers s
rV c C s, | d d }|j d}ttdd |}|jd | d }tj}|}d|kr^|d }|j| x |jd d D ]}|j| qnW |d } t | r| j d} t
| } x| D ]}
|j ||
qW t|j j
j } | j g } x>|D ]4}| d
| }|d }
|jd d
d}tj|
}|
| kr| j|
d
}|
d }t |}t | }x<||k r| | d | |krt| j| | |d
7 }qFW | j|
d|kr|d }|j| x"|jd d D ]}|j| qW ||_d|_|d } t | r| j d} t
| } x | D ]}
|j ||
q W qW t| | | d S )Nloggersr( r) c S s | j S )N)r# )r$ r r r r% s z"_install_loggers..rL Z logger_rootr; r z logger_%squalnamerO )r, r r )r listr& remover
rL r@ r
removeHandlerr1 r'
addHandlerrM rN r( sortZgetint getLoggerindexrD rO rP rV )r r rS ZllistrG rL rT r; rJ rE rF rQ rR ZqnrO rU iprefixedpflen num_existingr r r r sd
r c C s. t jj t jt jd d t jd d = d S )N)r
_handlersclearZshutdownZ _handlerListr r r r r s
r z^[a-z_][a-z0-9_]*$c C s t j| }|std| dS )Nz!Not a valid Python identifier: %rT)
IDENTIFIERmatch
ValueError)smr r r valid_ident s
rl c @ s e Zd ZdddZdd ZdS )ConvertingMixinTc C sB | j j|}||k r>|r || |< t|tttfkr>| |_||_|S )N) configuratorconverttypeConvertingDictConvertingListConvertingTupleparentkey)selfru valuereplaceresultr r r convert_with_key$ s
z ConvertingMixin.convert_with_keyc C s0 | j j|}||k r,t|tttfkr,| |_|S )N)rn ro rp rq rr rs rt )rv rw ry r r r ro 0 s
zConvertingMixin.convertN)T)__name__
__module__ __qualname__rz ro r r r r rm ! s
rm c @ s( e Zd Zdd ZdddZd ddZdS )
rq c C s t j| |}| j||S )N)dict __getitem__rz )rv ru rw r r r r E s zConvertingDict.__getitem__Nc C s t j| ||}| j||S )N)r~ r2 rz )rv ru defaultrw r r r r2 I s zConvertingDict.getc C s t j| ||}| j||ddS )NF)rx )r~ r rz )rv ru r rw r r r r M s zConvertingDict.pop)N)N)r{ r| r} r r2 r r r r r rq B s
rq c @ s e Zd Zdd ZdddZdS ) rr c C s t j| |}| j||S )N)rZ r rz )rv ru rw r r r r S s zConvertingList.__getitem__rY c C s t j| |}| j|S )N)rZ r ro )rv idxrw r r r r W s zConvertingList.popN)r )r{ r| r} r r r r r r rr Q s rr c @ s e Zd Zdd ZdS )rs c C s t j| |}| 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 [ s rs c @ s e Zd ZejdZejdZejdZejdZejdZ dddZ
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__v s
zBaseConfigurator.__init__c C s |j d}|jd}y`| j|}xP|D ]H}|d| 7 }yt||}W q& tk
rl | j| t||}Y q&X q&W |S tk
r tj dd \}}td||f }|| |_ |_
|Y nX d S )Nr r rY zCannot resolve %r: %s) r r importerr r ImportErrorsysexc_infori __cause__
__traceback__) rv rj r r r Zfragetbvr r r resolvez s"
zBaseConfigurator.resolvec C s
| j |S )N)r )rv rw r r r r s z BaseConfigurator.ext_convertc C s |}| j j|}|d kr&td| n||j d }| j|j d }x|r| jj|}|rp||j d }nd| jj|}|r|j d }| jj|s|| }n2yt |}|| }W n t
k
r || }Y nX |r||j 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_PATTERNint TypeError)rv rw restrk dr r! r r r r s2
z BaseConfigurator.cfg_convertc C s t |t r&t |tr&t|}| |_nt |t rLt |trLt|}| |_n|t |t rrt |trrt|}| |_nVt |tr| j j
|}|r|j }|d }| j j
|d }|r|d }t| |}||}|S )Nprefixsuffix)r rq r~ rn rr rZ rs r strCONVERT_PATTERNrh groupdictvalue_convertersr2 r )rv rw rk r r Z converterr r r r ro s*
zBaseConfigurator.convertc sr j d}t|s | j|} j dd }t fdd D }|f |}|rnx |j D ]\}}t||| qVW |S )Nz()r c s g | ]}t |r| | fqS r )rl ).0k)r r r
s z5BaseConfigurator.configure_custom..)r callabler r~ itemssetattr)rv r r5 propskwargsry r rw r )r r configure_custom s
z!BaseConfigurator.configure_customc C s t |trt|}|S )N)r rZ r )rv rw r r r as_tuple s
zBaseConfigurator.as_tupleN)r{ r| r} recompiler r r r r r staticmethodr r r r r r ro r r r r r r r b s
" r c @ sZ e Zd Zdd Zdd Zdd Zdd Zd d
Zd d ZdddZ dddZ
dddZ dS )DictConfiguratorc C s | j }d|krtd|d dkr2td|d |jdd}i }tj z|r|jd|}x|D ]}|tjkrtd| qfy6tj| }|| }|jd d }|r|jtj| W qf t k
r } ztd
|| f W Y d d } ~ X qfX qfW |jd |}
xZ|
D ]R}y| j
||
| d W n4 t k
rP } ztd
|| f W Y d d } ~ X nX qW |jdd } | ry| j | d W n0 t k
r } ztd| W Y d d } ~ X nX n:|jdd } t |jd|}
xZ|
D ]R}y| j
|
| |
|< W n4 t k
r" } ztd|| f W Y d d } ~ X nX qW |jd|}xZ|D ]R}y| j|| ||< W n4 t k
r } ztd|| f W Y d d } ~ X nX q |jd|d< ||d< | j |}W Y d d }~X qX nP|jdd }|jdd }|jdd}|jdd }|stj} nt|} | |||}|S ) Nz()z'format'r* rI r- r. r/ r0 )r r r r r2 r
r3 r" )
rv r factoryry terI Zdfmtr. cnamer5 r r r r s& z$DictConfigurator.configure_formatterc C s. d|kr| j |}n|jdd}tj|}|S )Nz()r r9 )r r2 r
ZFilter)rv r ry r r r r r s
z!DictConfigurator.configure_filterc C s^ xX|D ]P}y|j | jd | W q tk
rT } ztd||f W Y d d }~X qX qW d S )Nr zUnable to add filter %r: %s)Z addFilterr r ri )rv Zfiltererr r7 r r r r add_filters s
z DictConfigurator.add_filtersc / s t } jdd }|r^y| jd | }W n2 tk
r\ } ztd||f W Y d d }~X nX jdd } jdd }d kr jd}t|s| j|}|}n jd} | j| }
t|
tj j
od krHy>| jd d } t | tj s j
| td
| d< W n8 tk
rD } ztd d |f W Y d d }~X nX nZt|
tj jrvd krv| j d d < n,t|
tj jrd
kr| j d
d
< |
} jdd } t fdd D }
y|f |
}W nL tk
r" } z.dt|kr |
jd|
d< |f |
}W Y d d }~X nX |r4|j| |d k rN|jtj| |r`| j|| | rx"| j D ]\}}t||| qpW |S )Nr8 r z Unable to set formatter %r: %sr; r z()r0 r< r ztarget not configured yetz#Unable to set target handler %r: %sZmailhostZaddressr c s g | ]}t |r| | fqS 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 ZHandlerupdater Z SMTPHandlerr Z
SysLogHandlerr rA r@ r r r r )rv r Z config_copyr8 r r; r r5 r r rH thr r ry r r rw r )r r r sl
$
z"DictConfigurator.configure_handlerc C s^ xX|D ]P}y|j | jd | W q tk
rT } ztd||f W Y d d }~X qX qW d S )Nr z Unable to add handler %r: %s)r] r r ri )rv rU r rJ r r r r add_handlers s
z DictConfigurator.add_handlersFc C s |j dd }|d k r$|jtj| |sx |jd d D ]}|j| q8W |j dd }|rf| j|| |j dd }|r| j|| d S )Nr; r r )r2 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 j|}| j||| |jdd }|d k r2||_d S )NrO )r
r_ r r2 rO )rv r r r rU rO r r r r s
z!DictConfigurator.configure_loggerc C s t j }| j||| 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 | j d S )N)dictConfigClassr )r r r r
dictConfig s r c sP t s tdG dd dt}G dd dt}G fdddtj ||| |S )Nz listen() needs threading to workc @ s e Zd Zdd ZdS )z#listen..ConfigStreamHandlerc S sH y| j }|jd}t|dkrtjd|d }| j j|}x&t||k rd||j|t| }q@W | jjd k r~| jj|}|d k r|jd}y dd l}|j |}t
| W nH t k
r t j
|}y t| W n t k
r tj Y nX Y nX | jjr| jjj W n2 tk
rB } z|jtkr2 W Y d d }~X nX d S )N z>Lr zutf-8)Z
connectionZrecvr1 structunpackserververifydecodejsonloadsr r ioStringIOr traceback print_excreadysetOSErrorerrno RESET_ERROR)rv ZconnchunkZslenr r filer r r r handleB s6
z*listen..ConfigStreamHandler.handleN)r{ r| r} r r r r r ConfigStreamHandler; s r c @ s, e Zd ZdZdedddfddZdd ZdS )z$listen..ConfigSocketReceiverrY Z localhostNc S s> t j| ||f| tj d| _tj d| _|| _|| _d S )Nr rY ) r r r
r abortr timeoutr r )rv hostportr r r r r r r p s z-listen..ConfigSocketReceiver.__init__c S sf dd l }d}xJ|sV|j | jj gg g | j\}}}|r>| j tj | j}tj qW | jj d S )Nr )
selectZsocketfilenor Zhandle_requestr
r r r close)rv r r ZrdwrZexr r r serve_until_stoppedz s z8listen..ConfigSocketReceiver.serve_until_stopped)r{ r| r} Zallow_reuse_addressDEFAULT_LOGGING_CONFIG_PORTr r r r r r ConfigSocketReceiveri s r c s& e Zd Z fddZdd Z ZS )zlisten..Serverc s4 t | j || _|| _|| _|| _tj | _d S )N) superr rcvrhdlrr 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 | _| jj tj |a tj
|j 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 )threadNotImplementedErrorr r r ZThread)r r r r r )r r listen% s . r c
C s* t j ztrdt_d aW d t j 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 _threadr 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 sN
"#W!
9|