]h
@ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z y d d l Z d d l
Z
Wn e k
r d Z Yn Xd d l m
Z
m Z d Z e j Z d a d d d d Z d d Z d d
Z d d Z d
d Z d d Z d d Z e j d e j Z d d Z Gd d d e Z Gd d d e e Z! Gd d d e" e Z# Gd d d e$ e Z% Gd d d e Z& Gd d! d! e& Z' e' Z( d" d# Z) e d d$ d% Z* d& d' Z+ d S)( N)ThreadingTCPServerStreamRequestHandleriF# Tc
C s d d l } t | | j r' | } n; | j | } t | d rU | j | n
| j | t | } t j z@ t j
j t j d d =t
| | } t | | | Wd t j Xd S)Nr readline) configparser
isinstanceZRawConfigParser ConfigParserhasattrZ read_fileread_create_formatterslogging _acquireLock _handlersclear _handlerList_install_handlers_install_loggers _releaseLock)Zfnamedefaultsdisable_existing_loggersr cp
formattershandlers r +/opt/alt/python35/lib64/python3.5/config.py
fileConfig8 s
r c C s | j d } | j d } t | } x] | D]U } | d | } y t | | } Wq1 t k
r t | t | | } Yq1 Xq1 W| S)N.r )splitpop
__import__getattrAttributeError)nameusedfoundnr r r _resolveZ s
r% c C s t d d | 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 | s i S| j d } t | } i } x | D] } d | } | j | d d d d d } | j | d d d d d } | j | d
d d d d } t j } | | j d } | r t | } | | | | }
|
| |
r c C sd t j } xT | D]L } | j j | } | | k rS t j | _ g | _ d | _ q | | _ q Wd S)NT) r rootmanager
loggerDictNOTSETr@ r propagatedisabled)existing
child_loggersdisable_existingrQ logloggerr r r _handle_existing_loggers s
r\ c C s | d d } | j d } t t d d | } | j d | d } t j } | } d | k r | d } | j | x( | j d d D] } | j | q W| d } t | r | j d } t
| } x | D] }
| j | |
q Wt | j j
j } | j g } x| D]} | d
| } | d }
| j d d
d } t j |
} |
| k r| j |
d } |
d } t | } t | } xE | | k r| | d | | k r| j | | | d 7} qW| j |
d | k r)| d } | j | x( | j d d D] } | j | q=W| | _ d | _ | d } t | r.| j d } t
| } x | D] }
| j | |
qWq.Wt | | | d S)Nloggersr+ r, c S s
| j S)N)r& )r' r r r r( s z"_install_loggers..rQ Z logger_rootr@ r z logger_%squalnamerU r/ r r )r listr) remover rQ rE r
removeHandlerr4 r*
addHandlerrR rS r+ sortZgetint getLoggerindexrI rU rV r\ )r r rY ZllistrL rQ rZ r@ rO rJ rK rW rX ZqnrU r[ iprefixedpflen num_existingr r r r sd
r z^[a-z_][a-z0-9_]*$c C s) t j | } | s% t d | d S)Nz!Not a valid Python identifier: %rT)
IDENTIFIERmatch
ValueError)smr r r valid_ident s rp c @ s+ e Z d Z d d d Z d d Z d S)ConvertingMixinTc C s_ | j j | } | | k r[ | r. | | | [a-z]+)://(?P.*)$z ^\s*(\w+)\s*z^\.\s*(\w+)\s*z^\[\s*(\w+)\s*\]\s*z^\d+$ext ext_convertZcfg cfg_convertc C s t | | _ | | j _ d S)N)ru configrr )rz r r r r __init__n s zBaseConfigurator.__init__c C s | j d } | j d } yz | j | } x` | D]X } | d | 7} y t | | } Wq7 t k
r | j | t | | } Yq7 Xq7 W| SWn] t k
r t j d d \ } } t d | | f } | | | _ | _
| Yn Xd S)Nr r r_ zCannot resolve %r: %s) r r importerr r ImportErrorsysexc_inform __cause__
__traceback__) rz rn r! r" r# Zfragetbvr r r resolver s"
zBaseConfigurator.resolvec C s
| j | S)N)r )rz r{ r r r r s z BaseConfigurator.ext_convertc C sY | } | j j | } | d k r7 t d | n | | j d } | j | j d } x | rT| j j | } | r | | j d } n | j j | } | r | j d } | j j | s | | } n9 y t | } | | } Wn t
k
r| | } Yn X| r;| | j d } qg t d | | f qg W| S)NzUnable to convert %rr zUnable to convert %r at %r) WORD_PATTERNrl rm endr groups DOT_PATTERN
INDEX_PATTERN
DIGIT_PATTERNint TypeError)rz r{ restro dr r$ r r r r s2
z BaseConfigurator.cfg_convertc C s& t | t r7 t | t r7 t | } | | _ n t | t rn t | t rn t | } | | _ n t | t r t | t r t | } | | _ n} t | t r"| j j
| } | r"| j } | d } | j j
| d } | r"| d } t | | } | | } | S)Nprefixsuffix)r ru r rr rv r` rw r strCONVERT_PATTERNrl groupdictvalue_convertersr5 r )rz r{ ro r r converterr r r r rs s*
zBaseConfigurator.convertc s j d } t | s* | j | } j d d } t f d d D } | | } | r x* | j D] \ } } t | | | qz W| S)Nz()r c s, g | ]" } t | r | | f q Sr )rp ).0k)r r r
s z5BaseConfigurator.configure_custom..)r callabler r itemssetattr)rz r r: propskwargsr} r! r{ r )r r configure_custom s z!BaseConfigurator.configure_customc C s t | t r t | } | S)N)r r` r )rz r{ r r r as_tuple s zBaseConfigurator.as_tupleN)r r r recompiler r r r r r staticmethodr r r r r r rs r r r r r r r Z s " r c @ s e Z d Z d d Z d d Z d d Z d d Z d d
Z d d Z d
d d Z d
d d Z
d
d d Z d S)DictConfiguratorc C s< | j } d | k r! t d | d d k rE t d | d | j d d } i } t j z| r | j d | } x | D] } | t j k r t d | q yI t j | } | | } | j d d } | r | j t j | Wq t k
r7} z t d
| | f WYd d } ~ Xq Xq W| j d | }
xg |
D]_ } y | j
| |
| d WqUt k
r} z t d
| | f WYd d } ~ XqUXqUW| j d d } | r)y | j | d Wq)t k
r} z t d | WYd d } ~ Xq)Xn
| j d d } t j j t j
d d =| j d | }
xg |
D]_ } y | j |
| |
| )r r5 r Filter)rz r r} r! r r r r s
z!DictConfigurator.configure_filterc C so xh | D]` } y | j | j d | Wq t k
rf } z t d | | f WYd d } ~ Xq Xq Wd S)Nr zUnable to add filter %r: %s) addFilterr r rm )rz Zfiltererr r< r r r r add_filters s
z DictConfigurator.add_filtersc / sD t } j d d } | rw y | j d | } Wn; t k
rv } z t d | | f WYd d } ~ Xn X j d d } j d d } d k r j d } t | s | j | } | } nK j d } | j | }
t |
t j j
rd k ryN | j d d } t | t j s\ j
| t d
| d .z'stream'streamZstrm)r r r r rm r r rG r r rH r Handlerupdater Z SMTPHandlerr Z
SysLogHandlerr rF rE r r r r )rz r Z config_copyr= r r@ r r: r r rM thr r r} r r! r{ r )r r r sl #
*
z"DictConfigurator.configure_handlerc C so xh | D]` } y | j | j d | Wq t k
rf } z t d | | f WYd d } ~ Xq Xq Wd S)Nr z Unable to add handler %r: %s)rc r r rm )rz r[ r rO r r r r add_handlers s
z DictConfigurator.add_handlersFc C s | j d d } | d k r4 | j t j | | s x( | j d d D] } | j | qN W| j d d } | r | j | | | j d d } | r | j | | d S)Nr@ r r )r5 rE r r r rb r r )rz r[ r r r@ rO r r r r r common_logger_config s z%DictConfigurator.common_logger_configc C sM t j | } | j | | | | j d d } | d k rI | | _ d S)NrU )r re r r5 rU )rz r! r r r[ rU r r r r
s
z!DictConfigurator.configure_loggerc C s# t j } | j | | | d S)N)r re r )rz r r rQ r r r r s z DictConfigurator.configure_rootN) 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 t d Gd d d t } Gd d d t } G f d d d t j | | | | S)Nz listen() needs threading to workc @ s e Z d Z d d Z d S)z#listen..ConfigStreamHandlerc S s ya| j } | j d } t | d k r`t j d | d } | j j | } x3 t | | k r | | j | t | } qX W| j j d k r | j j | } | d k rD| j d } y) d d l } | j | } t
| WnN t k
rCt j
| } y t | Wn t k
r>t j Yn XYn X| j j r`| j j j Wn7 t k
r} z | j t k r WYd d } ~ Xn Xd S)N z>Lr zutf-8)
connectionrecvr4 structunpackserververifydecodejsonloadsr r ioStringIOr traceback print_excreadysetOSErrorerrno RESET_ERROR)rz connchunkZslenr r filer r r r handle; s6 !
z*listen..ConfigStreamHandler.handleN)r r r r r r r r ConfigStreamHandler4 s r c @ s= e Z d Z d Z d e d d d d d Z d d Z d S)z$listen..ConfigSocketReceiverr_ localhostNc S sU t j | | | f | t j d | _ t j d | _ | | _ | | _ d S)Nr r_ ) r r r r abortr timeoutr r )rz hostportr r r r r r r i s
z-listen..ConfigSocketReceiver.__init__c S s d d l } d } xg | s{ | j | j j g g g | j \ } } } | r[ | j t j | j } t j q W| j j d S)Nr )
selectsocketfilenor Zhandle_requestr r r r close)rz r r Zrdwrexr r r serve_until_stoppeds s
z8listen..ConfigSocketReceiver.serve_until_stopped)r r r Zallow_reuse_addressDEFAULT_LOGGING_CONFIG_PORTr r r r r r ConfigSocketReceiverb s r c s1 e Z d Z f d d Z d d Z S)zlisten..Serverc sJ t | j | | _ | | _ | | _ | | _ t j | _ d S)N) superr rcvrhdlrr r threadingEventr )rz r r r r )Server __class__r r r s z listen..Server.__init__c S s | j d | j d | j d | j d | j } | j d k rO | j d | _ | j j t j | a t j
| j d S)Nr r r r r r_ ) r r r r r Zserver_addressr r r _listenerr r )rz r r r r run s
zlisten..Server.run)r r r r r r )r )r r r s r )threadNotImplementedErrorr r r Thread)r r r r r )r r listen s . r c
C s5 t j z t r" d t _ d a Wd t j Xd S)Nr_ )r r r r r r r r r
stopListening s
r ),r r r Zlogging.handlersr r r r _threadr r r socketserverr r r Z
ECONNRESETr r r r% r* r
r r\ r r Irk rp objectrq r ru r` rv r rw r r r r r r r r r r sH
" # V !
9 |