3
\Ќ �
@ 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*dd�Zdd� 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)�ThreadingTCPServer�StreamRequestHandleriF# Tc
C s� dd l }t| |j�r| }n*|j|�}t| d�r:|j| � n
|j| � t|�}tj � z t
� t ||�}t |||� W d tj
� X d S )Nr �readline)� configparser�
isinstanceZRawConfigParserZ ConfigParser�hasattrZ read_file�read�_create_formatters�logging� _acquireLock�_clearExistingHandlers�_install_handlers�_install_loggers� _releaseLock)ZfnameZdefaults�disable_existing_loggersr �cp�
formatters�handlers� r �&/usr/lib64/python3.6/logging/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 )�split�pop�
__import__�getattr�AttributeError)�name�used�found�nr 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 �} | r�t| �}||||�}
|
||< q4W |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 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
j��r|jd
d�} t | ��r|j|
| f� |
||< q8W x |D ]\}
}
|
j||
� �q$W |S ) Nr r' r( z
handler_%sr/ � formatter� �args�level�target)r0 r r& r1 �eval�varsr
r � NameErrorr! �setLevel� setFormatter�
issubclassr �
MemoryHandler�appendZ setTarget)r r �hlistr Zfixups�hand�section�klass�fmtr8 �hr9 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
�root�manager�
loggerDictZNOTSETr9 r � propagate�disabled)�existing�
child_loggers�disable_existingrJ �log�loggerr r r �_handle_existing_loggers� s
rT 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 ||
� q�W t|j j
j� �} | j� g } �x>|D �]4}| d
| }|d }
|jd d
d�}tj|
�}|
| k�r�| j|
�d
}|
d }t |�}t | �}x<||k �r�| | d |� |k�rt| j| | � |d
7 }�qFW | j|
� d|k�r�|d }|j|� x"|jd d � D ]}|j|� �q�W ||_d|_|d } t | �r�| j d�} t
| �} x | D ]}
|j ||
� �q W q�W t| | |� d S )N�loggersr' r( c S s | j � S )N)r" )r# r r r r$ � s z"_install_loggers..rJ Z logger_rootr9 r z logger_%s�qualnamerM � )r+ r r )r �listr% �remover
rJ r> r �
removeHandlerr0 r& �
addHandlerrK rL r' �sortZgetint� getLogger�indexrB rM rN rT )r r rQ ZllistrE rJ rR r9 rH rC rD rO rP ZqnrM rS �i�prefixed�pflen� num_existingr r r r � sd
r c C s. t jj� t jt 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 j| �}|std| ��dS )Nz!Not a valid Python identifier: %rT)�
IDENTIFIER�match�
ValueError)�s�mr r r � valid_ident s
rj c @ s e Zd Zddd�Zdd� ZdS )�ConvertingMixinTc C sB | j j|�}||k r>|r || |< t|�tttfkr>| |_||_|S )N)� configurator�convert�type�ConvertingDict�ConvertingList�ConvertingTuple�parent�key)�selfrs �value�replace�resultr r r �convert_with_key$ s
z ConvertingMixin.convert_with_keyc C s0 | j j|�}||k r,t|�tttfkr,| |_|S )N)rl rm rn ro rp rq rr )rt ru rw r r r rm 0 s
zConvertingMixin.convertN)T)�__name__�
__module__� __qualname__rx rm r r r r rk ! s
rk c @ s( e Zd Zdd� Zddd�Zd dd�ZdS )
ro c C s t j| |�}| j||�S )N)�dict� __getitem__rx )rt rs ru r r r r} E s zConvertingDict.__getitem__Nc C s t j| ||�}| j||�S )N)r| r1 rx )rt rs �defaultru r r r r1 I s zConvertingDict.getc C s t j| ||�}| j||dd�S )NF)rv )r| r rx )rt rs r~ ru r r r r M s zConvertingDict.pop)N)N)ry rz r{ r} r1 r r r r r ro B s
ro c @ s e Zd Zdd� Zddd�ZdS ) rp c C s t j| |�}| j||�S )N)rX r} rx )rt rs ru r r r r} S s zConvertingList.__getitem__rW c C s t j| |�}| j|�S )N)rX r rm )rt �idxru r r r r W s zConvertingList.popN�����)r� )ry rz r{ r} r r r r r rp Q s rp c @ s e Zd Zdd� ZdS )rq c C s t j| |�}| j||dd�S )NF)rv )�tupler} rx )rt rs ru r r r r} ] s zConvertingTuple.__getitem__N)ry rz r{ r} r r r r rq [ s rq c @ s� e Zd Zejd�Zejd�Zejd�Zejd�Zejd�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)ro �configrl )rt 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 rW zCannot resolve %r: %s) r r �importerr r � ImportError�sys�exc_inforg � __cause__�
__traceback__) rt rh r r r Zfrag�e�tb�vr r r �resolvez s"
zBaseConfigurator.resolvec C s
| j |�S )N)r� )rt ru 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_PATTERNrf rg �endr� �groups� DOT_PATTERN�
INDEX_PATTERN�
DIGIT_PATTERN�int� TypeError)rt ru �restri �dr r r r r r� � s2
z BaseConfigurator.cfg_convertc C s� t |t� r&t |t�r&t|�}| |_n�t |t� rLt |t�rLt|�}| |_n|t |t� rrt |t�rrt|�}| |_nVt |t�r�| j j
|�}|r�|j � }|d }| j j
|d �}|r�|d }t| |�}||�}|S )N�prefix�suffix)r ro r| rl rp rX rq r� �str�CONVERT_PATTERNrf � groupdict�value_convertersr1 r )rt ru ri r� r� Z converterr� r r r rm � 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|� | f�qS r )rj )�.0�k)r� r r �
� s z5BaseConfigurator.configure_custom..)r �callabler� r| �items�setattr)rt r� r3 �props�kwargsrw r ru r )r� r �configure_custom� s
z!BaseConfigurator.configure_customc C s t |t�rt|�}|S )N)r rX r� )rt ru r r r �as_tuple� s
zBaseConfigurator.as_tupleN)ry rz r{ �re�compiler� r� r� r� r� r� � staticmethodr r� r� r� r� r� rm r� r� r r r r r� b 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 ��|jdd�}i }tj� �z�|�r�|jd|�}x�|D ]�}|tjkr�td| ��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 �} | �r�y| 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 �q�W |jd|�}xZ|D ]R}y| j|| �||< W n4 t k
�r� } ztd|| f ��W Y d d } ~ X nX �q � _checkLevel� Exception�configure_logger�configure_rootr �configure_formatter�configure_filter�sorted�configure_handlerr r� rB rJ rX rK rL r' r\ r^ r0 rY rT r )rt r� r� Z
EMPTY_DICTr r �handlerZhandler_configr9 r� rU rJ rQ r r� ZdeferredrO rP r_ r` ra rb r r r � configure� s�
"
$
$
$ $
$
$ zDictConfigurator.configurec
C s� d|krr|d }y| j |�}W q� tk
rn } z4dt|�kr>� |jd�|d< ||d< | j |�}W Y d d }~X q�X nP|jdd �}|jdd �}|jdd�}|jdd �}|s�tj} nt|�} | |||�}|S ) Nz()z'format'r) rG r, r- r. r/ )r� r� r� r r1 r
r2 r! )
rt r� �factoryrw �terG Zdfmtr- �cnamer3 r r r r� � s& z$DictConfigurator.configure_formatterc C s. d|kr| j |�}n|jdd�}tj|�}|S )Nz()r r7 )r� r1 r
ZFilter)rt r� rw 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� rg )rt Zfiltererr� r5 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
�o�d� k�rHy>| jd � d } t | tj ��s� j
|� td
��| � d< W n8 tk
�rD } ztd � d |f ��W Y d d }~X nX nZt|
tj j��rvd � k�rv| j� d �� d < n,t|
tj j��r�d
� k�r�| j� d
�� d
< |
}� jdd �} t � fdd�� D ��}
y|f |
�}W nL tk
�r" } z.dt|�k�r�� |
jd�|
d< |f |
�}W Y d d }~X nX |�r4|j|� |d k �rN|jtj|�� |�r`| j||� | �r�x"| j� D ]\}}t|||� �qpW |S )Nr6 r z Unable to set formatter %r: %sr9 r� z()r/ r: r ztarget not configured yetz#Unable to set target handler %r: %sZmailhostZaddressr c s g | ]}t |�r|� | f�qS r )rj )r� r� )r� r r r� � s z6DictConfigurator.configure_handler..z'stream'�streamZstrm)r| r r� r� rg r� r� r@ r
r rA r ZHandler�updater� Z SMTPHandlerr� Z
SysLogHandlerr� r? r> r� r� r� r� )rt r� Z config_copyr6 r� r9 r� r3 r� r� rF Zthr� r� rw r� r ru 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� rg )rt rS r rH r� r r r � add_handlers� s
z DictConfigurator.add_handlersFc C s� |j dd �}|d k r$|jtj|�� |s�x |jd d � D ]}|j|� q8W |j dd �}|rf| j||� |j dd �}|r�| j||� d S )Nr9 r r� )r1 r> r
r� r rZ r� r� )rt rS r� r� r9 rH 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 )NrM )r
r] r� r1 rM )rt r r� r� rS rM r r r r� s
z!DictConfigurator.configure_loggerc C s t j� }| j|||� d S )N)r
r] r� )rt r� r� rJ r r r r� s z DictConfigurator.configure_rootN)F)F)F) ry rz 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 td��G dd� dt�}G dd� dt�}G � fdd�dtj�� � ||| |�S )Nz listen() needs threading to workc @ s e Zd Zdd� ZdS )z#listen..ConfigStreamHandlerc S sH �y| j }|jd�}t|�dk�rtjd|�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 | jj�r| jjj� W n2 tk
�rB } z|jtk�r2� W Y d d }~X nX d S )N� z>Lr zutf-8)Z
connectionZrecvr0 �structZunpack�server�verify�decode�json�loadsr� r� �io�StringIOr � traceback� print_exc�ready�set�OSError�errno� RESET_ERROR)rt Zconn�chunkZslenr� r� �filer� r r r �handleB s6
z*listen..ConfigStreamHandler.handleN)ry rz r{ r� r r r r �ConfigStreamHandler; s r� c @ s, e Zd ZdZdedddfdd�Zdd� ZdS )z$listen..ConfigSocketReceiverrW Z localhostNc S s> t j| ||f|� tj� d| _tj� d| _|| _|| _d S )Nr rW ) r r� r
r �abortr �timeoutr� r� )rt �host�portr� 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 )
�selectZsocket�filenor� Zhandle_requestr
r r� r �close)rt r� r� Zrd�wrZexr r r �serve_until_stoppedz s z8listen..ConfigSocketReceiver.serve_until_stopped)ry rz r{ Zallow_reuse_address�DEFAULT_LOGGING_CONFIG_PORTr� r� r r r r �ConfigSocketReceiveri s r� c s& e Zd Z�� fdd�Zdd� Z� ZS )zlisten..Serverc s4 t � | �j� || _|| _|| _|| _tj� | _d S )N) �superr� �rcvr�hdlrr� r� � threadingZEventr� )rt 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 rW ) r� r� r� r� r� Zserver_addressr� r
r � _listenerr r� )rt r� r r r �run� s
zlisten..Server.run)ry rz r{ r� r� �
__classcell__r )r� )r� r r� � s r� )�thread�NotImplementedErrorr 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 )NrW )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
rT r r r� �Ire rj �objectrk r| ro rX rp r� rq r� r� r� r� r� r� r r r r � sN
"#W!
9|