|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/test/__pycache__/ |
U
>��g�� � @ s& d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlmZmZ ddlmZ ddlZddl Z ddl Z ddl Z ddl Z ddl Z ddl!Z!ddl"m#Z#m$Z$ ddl%Z%ddl&m'Z'm(Z( ddl)m*Z*m+Z+m,Z,m-Z- z ddl.Z.ddl/Z/ddl0Z0W n" e1k
�r~ d Z. Z/Z0Y nX z ddl2Z2W n e1k
�r� Y nX G dd � d e j3�Z4G d
d � d e4�Z5G d d
� d
e4�Z6dZ7dZ8dZ9dZ:dZ;dZ<dZ=dZ>dZ?dZ@eAe@e7d �ZBe7de8de9de:d e;d e<d e=d e>d e?d!e@d"i
ZCG d#d$� d$ejD�ZEG d%d&� d&ejD�ZFG d'd(� d(e4�ZGG d)d*� d*e4�ZHG d+d,� d,eI�ZJG d-d.� d.ejK�ZLG d/d0� d0eI�ZMG d1d2� d2e4�ZNG d3d4� d4e%jO�ZPG d5d6� d6eI�ZQG d7d8� d8eQe#�ZRG d9d:� d:eQe,�ZSG d;d<� d<eQe*�ZTeUed=��rBG d>d?� d?eS�ZVG d@dA� dAeT�ZWG dBdC� dCe4�ZXG dDdE� dEe4�ZYG dFdG� dGejZ�Z[G dHdI� dIe4�Z\G dJdK� dKe4�Z]dLdM� Z^e �_eUed=�dN�G dOdP� dPe]��Z`G dQdR� dRe4�Zae �_eUed=�dN�G dSdT� dTea��ZbG dUdV� dVe4�Zce �_eUed=�dN�G dWdX� dXec��Zde �_ejedY�G dZd[� d[ec��ZfG d\d]� d]e4�ZgG d^d_� d_e4�ZhG d`da� dae4�ZiG dbdc� dce4�Zjd�ddde�ZkG dfdg� dg�Zldhdi� ZmG djdk� dkejK�ZnG dldm� dme4�ZoG dndo� doe4�ZpG dpdq� dqe4�ZqG drds� dsejr�ZsG dtdu� due4�ZtG dvdw� dwe4�ZueUejvdx��rFddlwZwddylxmyZy G dzd{� d{e4�Zze�{d�Z|G d|d}� d}ej}�Z~e~� ZG d~d� de j3�Z�G d�d�� d�ej��Z�G d�d�� d�e j3�Z�G d�d�� d�e4�Z�G d�d�� d�e4�Z�G d�d�� d��Z�G d�d�� d�ej��Z�G d�d�� d�e4�Z�G d�d�� d�e4�Z�G d�d�� d�e4�Z�G d�d�� d�e j3�Z�G d�d�� d�e j3�Z�G d�d�� d�e4�Z�G d�d�� d�e4�Z�G d�d�� d�e��Z�G d�d�� d�e��Z�G d�d�� d�e��Z�d�d�� Z�d�d�d�d�d�d�e�d�d�d��ffD ](\Z�Z�e�e�fd�d��Z�e�e�d�e� e�� �q�e �_e.d��G d�d�� d�e4��Z�G d�d�� d�e j3�Z�e��d�d��d�d�� �Z�e�d�k�r"e�� dS )�zoTest harness for the logging module. Run all tests.
Copyright (C) 2001-2017 Vinay Sajip. All Rights Reserved.
� N)�assert_python_ok�assert_python_failure)�support)�
HTTPServer�BaseHTTPRequestHandler)�urlparse�parse_qs)�ThreadingUDPServer�DatagramRequestHandler�ThreadingTCPServer�StreamRequestHandlerc @ s> e Zd ZdZdZdZdZdd� Zdd� Zdd
d �Z d d
� Z
d S )�BaseTestz Base class for logging tests.z&%(name)s -> %(levelname)s: %(message)sz^([\w.]+) -> (\w+): (\d+)$r c C s� t �� | _t�� jj}t�� zntj �
� | _ tj dd� | _
|�
� | _}tj�
� | _tj�
� | _i | _}|D ]}t|| dd�||< qpW 5 t�� X t�d�| _t�d�| _t�d�| _| j�� | _t�� | _ | j� tj � t� | j �| _ t�!| j"�| _#| j �$| j#� | j�%� �r2| jj&| jj& }t'd| ��| j�%� �rZ| jj&| jj& }t'd| ��| j�(| j � | �)| j�%� � | �)| j�%� � dS )zxSetup the default logging stream to an internal StringIO instance,
so that we can examine log output as we want.N�disabledu «×»u ĿÖG� zUnexpected handlers: %s)*r Zthreading_setup�_threading_key�logging� getLogger�manager�
loggerDict� _acquireLock� _releaseLock� _handlers�copy�saved_handlers� _handlerList�saved_handler_list�
saved_loggers� _nameToLevel�saved_name_to_level� _levelToName�saved_level_to_name�
logger_states�getattr�logger1�logger2� root_logger�getEffectiveLevel�original_logging_level�io�StringIO�stream�setLevel�DEBUG�
StreamHandler� root_hdlr� Formatter�
log_format�root_formatter� setFormatter� hasHandlers�handlers�AssertionError�
addHandler�
assertTrue)�selfZ logger_dictr r! �nameZhlist� r: �0/opt/cppython/lib/python3.8/test/test_logging.py�setUpN sD
�
zBaseTest.setUpc C s0 | j �� | j�| j� | jjrB| jjd }| j�|� |�� q| j�| j� t� � z�tj � � tj �
| j� tj� � tj�
| j� tj� � tj�
| j� | jtjdd�< t�� j}d|_|j}|� � |�
| j� | j}| jD ] }|| dk r�|| | j| _q�W 5 t�
� X | � � t j | j � dS )zJRemove our logging stream, and restore the original logging
level.r N) r* �closer% �
removeHandlerr. r4 r+ r' r r r r �clear�updater r r r r r r r r �disabler r r! r Z
doCleanupsr Zthreading_cleanupr )r8 �hr r r! r9 r: r: r; �tearDownx s8
zBaseTest.tearDownNc C s� |p| j }t�|p| j�}|�� �� }| �t|�t|�� t||�D ]8\}}|� |�}|sh| �
d| � | �t |� � �|� qD|�
� }|r�| �
d| � dS )z�Match the collected log lines against the regular expression
self.expected_log_pat, and compare the extracted group values to
the expected_values list of tuples.z*Log line does not match expected pattern:
z'Remaining output at end of log stream:
N)r* �re�compile�expected_log_pat�getvalue�
splitlines� assertEqual�len�zip�search�fail�tuple�groups�read) r8 Zexpected_valuesr* �patZ actual_lines�actual�expected�match�sr: r: r; �assert_log_lines� s
�zBaseTest.assert_log_linesc C s | j d7 _ d| j S )zMGenerate a message consisting solely of an auto-incrementing
integer.� z%d)� message_num�r8 r: r: r; � next_message� s zBaseTest.next_message)NN) �__name__�
__module__� __qualname__�__doc__r0 rF rX r< rC rV rZ r: r: r: r; r
F s *"
r
c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )�BuiltinLevelsTestz*Test builtin levels and their inheritance.c
C s4 | j }t�d�}|�tj� t�t�d�i �}|�tj� t�d�}|�tj� |�tj |� � |�
|� � |�tj |� � |�
|� � |� |� � |� |� � |�tj |� � |�
|� � |� |� � |� |� � |�
|� � |� |� � |� |� � |�
|� � |�
|� � | �dddddd d
d d d
dg � d S )N�ERR�INF�DEB)r` �CRITICAL�1)r` �ERROR�2)ra rc �3)ra re �4)ra �WARNING�5)ra �INFO�6)rb rc �7)rb re �8)rb ri �9)rb rk �10)rb r, �11)rZ r r r+ re �
LoggerAdapterrk r, �logrc �error�warning�info�debugrV )r8 �mr` ra rb r: r: r; � test_flat� sF
�zBuiltinLevelsTest.test_flatc C s� | j }t�d�}|�tj� t�d�}|�tj� |�tj|� � |�|� � |� |� � |�
|� � |� |� � | � ddg� d S )Nra �INF.ERR)rz rc rd )rz re rf �
rZ r r r+ rk re rs rc rt ru rv rw rV )r8 rx ra �INF_ERRr: r: r; �test_nested_explicit� s
�z&BuiltinLevelsTest.test_nested_explicitc C s� | j }t�d�}|�tj� t�d�}|�tj� t�d�}t�d�}t�d�}|�tj|� � |�|� � |� |� � |�
|� � |�tj|� � |�|� � |� |� � |� |� � |�
|� � |� |� � | � dddd d
d g� d S ) Nra rz � INF.UNDEF�
INF.ERR.UNDEF�UNDEF)r~ rc rd )r~ re rf )r~ ri rg )r~ rk rh )r rc rj )r re rl r{ )r8 rx ra r| Z INF_UNDEFZ
INF_ERR_UNDEFr� r: r: r; �test_nested_inherited� s4
�z'BuiltinLevelsTest.test_nested_inheritedc C s� | j }t�d�}t�d�}t�d�}|�tj� |�tj|� � |�|� � |�tj|� � |�|� � |�|� � |�|� � | � ddddg� d S )Nra �INF.BADPARENT.UNDEF�
INF.BADPARENT)r� rc rd )r� rk rf )r� rc rg )r� rk rh )
rZ r r r+ rk rs �FATALrv rw rV )r8 rx ra Z
GRANDCHILDZCHILDr: r: r; � test_nested_with_virtual_parent s"
�z1BuiltinLevelsTest.test_nested_with_virtual_parentc C s, | � t�d�tj� | � t�tj�d� dS )z&See issue #22386 for more information.rk N)rI r � getLevelNamerk rY r: r: r; �test_regression_223869 s z'BuiltinLevelsTest.test_regression_22386c C s t �d�}| �|t j� d S )Nr� )r r� rI r� )r8 �fatalr: r: r; �test_issue27935> s
z!BuiltinLevelsTest.test_issue27935c C s` t �t jd� | �t jt jd� | �t �t j�d� | �t �t j�d� | �t �d�t j� dS )z&See issue #29220 for more information.r rk �NOTSETN)r � addLevelNamerk �
addCleanuprI r� r� rY r: r: r; �test_regression_29220B s
z'BuiltinLevelsTest.test_regression_29220N) r[ r\ r] r^ ry r} r� r� r� r� r� r: r: r: r; r_ � s /#r_ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �BasicFilterTestz Test the bundled Filter class.c C s� t �d�}| jjd }z||�|� t �d�}t �d�}t �d�}t �d�}|�| �� � |�| �� � |�| �� � |�| �� � | � ddg� W 5 |�|� X d S )N� spam.eggsr �spam�spam.eggs.fish�spam.bakedbeans�r� rk rf �r� rk rg )
r �Filterr% r4 � removeFilter� addFilterr rv rZ rV )r8 Zfilter_�handlerr� � spam_eggs�spam_eggs_fish�spam_bakedbeansr: r: r; � test_filterN s"
�
zBasicFilterTest.test_filterc C s� dd� }| j jd }z||�|� t�d�}t�d�}t�d�}t�d�}|�| �� � |�| �� � |�| �� � |�| �� � | �dd g� W 5 |�|� X d S )
Nc S s& | j �d�}d�|d d� �}|dkS )N�.� r� )r9 �split�join)�record�parts�prefixr: r: r; �
filterfuncj s z8BasicFilterTest.test_callable_filter.<locals>.filterfuncr r� r� r� r� r� r� ) r% r4 r� r� r r rv rZ rV )r8 r� r� r� r� r� r� r: r: r; �test_callable_filterf s"
�
z$BasicFilterTest.test_callable_filterc C s* t �� }t �ddi�}| �|�|�� d S )Nr9 r� )r r� �
makeLogRecordr7 �filter)r8 �f�rr: r: r; �test_empty_filter� s z!BasicFilterTest.test_empty_filterN)r[ r\ r] r^ r� r� r� r: r: r: r; r� J s r� �x �w �v �u �t �s �r �q �p �o rW �Silent�Taciturn�Terse�Effusive�Sociable�Verbose� TalkativeZ Garrulous�
Chatterbox�Boringc @ s e Zd ZdZdd� ZdS )�GarrulousFilterz)A filter which blocks garrulous messages.c C s
|j tkS �N)�levelno� GARRULOUS�r8 r� r: r: r; r� � s zGarrulousFilter.filterN�r[ r\ r] r^ r� r: r: r: r; r� � s r� c @ s e Zd ZdZdd� ZdS )�VerySpecificFilterz5A filter which blocks sociable and taciturn messages.c C s |j ttfkS r� )r� �SOCIABLE�TACITURNr� r: r: r; r� � s zVerySpecificFilter.filterNr� r: r: r: r; r� � s r� c @ s< e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
S )�CustomLevelsAndFiltersTestz@Test various filtering possibilities with custom logging levels.�^[\w.]+ -> (\w+): (\d+)$c C s, t �| � t�� D ]\}}t�||� qd S r� )r
r< �my_logging_levels�itemsr r� )r8 �k�vr: r: r; r< � s
z CustomLevelsAndFiltersTest.setUpc C s t D ]}|�|| �� � qd S r� )� LEVEL_RANGErs rZ )r8 �loggerZlvlr: r: r; �log_at_all_levels� s z,CustomLevelsAndFiltersTest.log_at_all_levelsc C s2 | j �t� | �| j � | �ddddddg� d S )N�r� rj �r� rl �r� rm �r� rn �r� ro �r� rp )r% r+ �VERBOSEr� rV rY r: r: r; �test_logger_filter� s �z-CustomLevelsAndFiltersTest.test_logger_filterc C sR | j jd �t� z$| �| j � | �dddddg� W 5 | j jd �tj� X d S )Nr r� r� r� r� r� )r% r4 r+ r� r r� r� rV rY r: r: r; �test_handler_filter� s �
z.CustomLevelsAndFiltersTest.test_handler_filterc
C s� | j jd }d }t� }|�|� zj| �| j � dddddddd d
g }| �|� t� }| j �|� | �| j � | �|d d d
ddddg � W 5 |r�| j �|� |�|� X d S )Nr )r� rd )r� rf )r� rh r� r� r� r� r� r� )r� rq )r� Z12)r� Z14)r� Z15)r� Z17)r� Z18)r� Z20)r% r4 r� r� r� r� rV r� )r8 r� Zspecific_filterZgarrZ first_linesr: r: r; �test_specific_filters� s@
�
� z0CustomLevelsAndFiltersTest.test_specific_filtersN)
r[ r\ r] r^ rF r< r� r� r� r� r: r: r: r; r� � s r� c @ sZ e Zd Zdd� Zdd� Zdd� Ze�ej dkd�d d
� �Z
e�e ed � d �d
d� �Z dS )� HandlerTestc C sD t �� }d|_| �|jd� d|_| �|jd� | �t|jd � d S )N�genericZanothergeneric)r �Handlerr9 rI � assertRaises�NotImplementedError�emit�r8 rB r: r: r; � test_name s zHandlerTest.test_namec
C s� t jdk�rZdD ]�}t�� \}}t�|� |s8t�|� tjj |dd�}|r�|j
|j }}| � |d� | � |d� t�
ddi�}|�|� t�|� | �tj�|�� |�|� | �tj�|�� n | � |j
d� | � |j d� |�� |rt�|� qt jdk�r
d }nd
}z4tj�|�}| � |j|j� | �|j� |�� W n tk
�rX Y nX d D ]@} | d k�r�| �ttjjd
d| � ntj�d
d| �}|�� �q^tj�d�}t�
i �}| �|� |�� |�� tj�d�}| �|� |�� |�� d S )N��linux�darwin)TFT��delay����msgZTestr� z/var/run/syslogz/dev/log)�GET�POST�PUTr� � localhostz/logr rW ) �sys�platform�tempfile�mkstemp�osr= �unlinkr r4 �WatchedFileHandler�dev�inorI r� �handle� assertFalse�path�existsr7 �
SysLogHandlerZfacilityZLOG_USERZ
unixsocket�OSErrorr� �
ValueError� HTTPHandlerZBufferingHandlerZ shouldFlush)
r8 Zexisting�fd�fnrB r� r� r� Zsockname�methodr: r: r; �test_builtin_handlers s`
�
z!HandlerTest.test_builtin_handlersc C s� t �� \}}t�|� t�|� t�|�}tj|dfftj j
|dfftj j |dfff}t j
dkrv|tj j|dfff7 }|D ]4\}}||� }| �tj�|�� |�� t�|� qzdS )zs
Test that Path objects are accepted as filename arguments to handlers.
See Issue #27493.
�w�arB r� N)r� r� r� r= r� �pathlib�Pathr � FileHandlerr4 �RotatingFileHandler�TimedRotatingFileHandlerr� r� r� r7 r� r� )r8 r� r� ZpfnZcases�cls�argsrB r: r: r; �test_path_objectsU s
�
z HandlerTest.test_path_objects�ntz/WatchedFileHandler not appropriate for Windows.c
s& � fdd�}d}d}d � _ d � _dD ]�}t�dd�\}}t�|� tj|||fd�}d|_|� � t
j j ||d �}t
�
d
�} |�| � znt|�D ]`}
t�d � t
�d d
i�} zt�� � _ |�| � W q� tk
r� td� j� j f � � Y q�X q�W 5 |�� |�� tj�|��r t�|� X q$d S )Nc sV t |�D ]H}zt�| � t�� � _W n tk
r8 Y nX t�dt�dd� � qd S )Ng����Mbp?r � ) �ranger� r� �time�
deletion_timer� �sleep�random�randint)ZfnameZtries�_rY r: r; � remove_loopo s
z*HandlerTest.test_race.<locals>.remove_loopi� �FT�.logztest_logging-3-��targetr
Tr� z'%(asctime)s: %(levelname)s: %(message)s�{�G�zt?r� ZtestingzDeleted at %s, opened at %s)Z handle_timer r� r� r� r= � threading�Thread�daemon�startr r4 r� r/ r2 r� r� r� r� r r r r� r� � Exception�print) r8 r Z del_countZ log_countr� r� r� ZremoverrB r� r r� r: rY r; � test_racel s@
��zHandlerTest.test_race�forkzTest requires os.fork().c s� G dd� dt j�}| �tt j�d� |� �| ��jjj� d�_ | �
tt j�d� | �
tt j �d� t � d�}|�
�� |�t j� t�� �t�� � � ��fdd�}tj|d d
�}|�� ��� t�� }|dkr�z|�d � W 5 t�d� X n�|�d � � �� |�� t� � }|� d
� t� |tj �\}}||k�r<�q`t� � | dk�rR�q`t� d� �q|� d� ||k�r�t�!|t"j#� t� |d�\}}| �$d� | j|ddd� dS )z>Ensure child logging locks are not held; bpo-6721 & bpo-36533.c s$ e Zd Z� fdd�Zdd� Z� ZS )zAHandlerTest.test_post_fork_child_no_deadlock.<locals>._OurHandlerc s" t � �� tjtdd�d�| _d S )Nz /dev/nullZwt�r* )�super�__init__r r- �open� sub_handlerrY �� __class__r: r; r% � s
�zJHandlerTest.test_post_fork_child_no_deadlock.<locals>._OurHandler.__init__c S s, | j �� z| j �|� W 5 | j �� X d S r� )r' �acquire�releaser� r� r: r: r; r� � s
zFHandlerTest.test_post_fork_child_no_deadlock.<locals>._OurHandler.emit�r[ r\ r] r% r� �
__classcell__r: r: r( r; � _OurHandler� s r. r z*because we need at least one for this testrW � test_post_fork_child_no_deadlockc sF t �� z.��� z��� � �d� W 5 ��� X W 5 t �� X d S )N� �?)r r r r* r+ �set�waitr: �Z+fork_happened__release_locks_and_end_threadZlocks_held__ready_to_forkZrefed_hr: r; �lock_holder_thread_fn� s
zKHandlerTest.test_post_fork_child_no_deadlock.<locals>.lock_holder_thread_fnz,test_post_fork_child_no_deadlock lock holder)r r9 z#Child process did not deadlock. \o/z&Parent process returned from fork. \o/zWaiting for child process.� g�������?z
Done waiting.zchild process deadlocked.zchild process error�r� N)%r r� rI rJ r r� r' r* r= r9 �
assertGreater� _at_fork_reinit_lock_weaksetr r6 r+ r, r �Eventr r r2 r� r" �_exitrv r1 r� r � monotonicrw �waitpid�WNOHANGr �kill�signal�SIGKILLrM ) r8 r. Z test_loggerr4 Zlock_holder_thread�pidZ
start_timeZ
waited_pid�statusr: r3 r; r/ � sR
�
z,HandlerTest.test_post_fork_child_no_deadlockN)
r[ r\ r] r� r r �unittestZskipIfr� r9 r! �hasattrr/ r: r: r: r; r� s 6
0r� c @ s e Zd Zdd� ZdS )� BadStreamc C s t d��d S )N�deliberate mistake)� RuntimeError�r8 �datar: r: r; �write� s zBadStream.writeN)r[ r\ r] rJ r: r: r: r; rE � s rE c @ s e Zd Zdd� ZdS )�TestStreamHandlerc C s
|| _ d S r� )� error_recordr� r: r: r; � handleError� s z TestStreamHandler.handleErrorN)r[ r\ r] rM r: r: r: r; rK � s rK c @ s e Zd ZejZdZdS )�StreamWithIntNamer� N)r[ r\ r] r r� �levelr9 r: r: r: r; rN � s rN c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�StreamHandlerTestc C s� t t� �}t�i �}tj}z�|�|� | �|j|� t�t� �}t �
� �$}|�|� d}| � ||� � � W 5 Q R X dt_t �
� � }|�|� | �
d|� � � W 5 Q R X W 5 |t_X d S )Nz"
RuntimeError: deliberate mistake
Fr )rK rE r r� �raiseExceptionsr� �assertIsrL r- r �captured_stderr�assertInrG rI )r8 rB r� Z old_raise�stderrr� r: r: r; �test_error_handling s
z%StreamHandlerTest.test_error_handlingc C sV t �� }t�� }|�|�}| �|tj� |�|�}| �||� |�|�}| �|� dS )z3
Test setting the handler's stream
N) r r- r( r) � setStreamrR r� rU � assertIsNone)r8 rB r* �oldrR r: r: r; �test_stream_setting s
z%StreamHandlerTest.test_stream_settingc C s t �t� �}| �t|�d� d S )Nz<StreamHandler 2 (NOTSET)>)r r- rN rI �reprr� r: r: r; �'test_can_represent_stream_with_int_name% s z9StreamHandlerTest.test_can_represent_stream_with_int_nameN)r[ r\ r] rV rZ r\ r: r: r: r; rP s rP c @ s: e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d d �Zd
S )�TestSMTPServera
This class implements a test SMTP server.
:param addr: A (host, port) tuple which the server listens on.
You can specify a port value of zero: the server's
*port* attribute will hold the actual port number
used, which can be used in client connections.
:param handler: A callable which will be called to process
incoming messages. The handler will be passed
the client address tuple, who the message is from,
a list of recipients and the message data.
:param poll_interval: The interval, in seconds, used in the underlying
:func:`select` or :func:`poll` call by
:func:`asyncore.loop`.
:param sockmap: A dictionary which will be used to hold
:class:`asyncore.dispatcher` instances used by
:func:`asyncore.loop`. This avoids changing the
:mod:`asyncore` module's global state.
c C sB t jj| |d |dd� | j�� d | _|| _d | _d| _|| _ d S )NT)�mapZ decode_datarW F)
�smtpd�
SMTPServerr% �socket� getsockname�port�_handler�_thread�_quit�
poll_interval)r8 �addrr� rg �sockmapr: r: r; r% A s �zTestSMTPServer.__init__c C s | � ||||� dS )aI
Delegates to the handler passed in to the server's constructor.
Typically, this will be a test case method.
:param peer: The client (host, port) tuple.
:param mailfrom: The address of the sender.
:param rcpttos: The addresses of the recipients.
:param data: The message.
N)rd )r8 �peer�mailfrom�rcpttosrI r: r: r; �process_messageJ s
z TestSMTPServer.process_messagec C s0 t j| j| jfd� | _}|�d� |�� dS )zG
Start the server running on a separate daemon thread.
r TN�r r �
serve_foreverrg re � setDaemonr �r8 �tr: r: r; r V s
�
zTestSMTPServer.startc C s | j stj|| jdd� q dS )a*
Run the :mod:`asyncore` loop until normal termination
conditions arise.
:param poll_interval: The interval, in seconds, used in the underlying
:func:`select` or :func:`poll` call by
:func:`asyncore.loop`.
rW )r^ �countN)rf �asyncoreZloop�_map�r8 rg r: r: r; ro _ s z TestSMTPServer.serve_foreverNc C s6 d| _ t�| j|� d| _| �� tj| jdd� dS )z�
Stop the thread by closing the server instance.
Wait for the server thread to terminate.
:param timeout: How long to wait for the server thread
to terminate.
TN)r^ Z
ignore_all)rf r � join_threadre r= rt Z close_allru �r8 �timeoutr: r: r; �stopj s
zTestSMTPServer.stop)N) r[ r\ r] r^ r% rm r ro rz r: r: r: r; r] , s r] c s: e Zd ZdZdd� Zdd� Z� fdd�Zd d d
�Z� ZS ) � ControlMixina
This mixin is used to start a server on a separate thread, and
shut it down programmatically. Request handling is simplified - instead
of needing to derive a suitable RequestHandler subclass, you just
provide a callable which will be passed each received request to be
processed.
:param handler: A handler callable which will be called with a
single parameter - the request - in order to
process the request. This handler is called on the
server thread, effectively meaning that requests are
processed serially. While not quite Web scale ;-),
this should be fine for testing applications.
:param poll_interval: The polling interval in seconds.
c C s d | _ || _|| _t�� | _d S r� )re rg rd r r9 �ready)r8 r� rg r: r: r; r% � s zControlMixin.__init__c C s0 t j| j| jfd� | _}|�d� |�� dS )zI
Create a daemon thread to run the server, and start it.
r TNrn rq r: r: r; r � s
�
zControlMixin.startc s | j �� tt| ��|� dS )z^
Run the server. Set the ready flag before entering the
service loop.
N)r| r1 r$ r{ ro rv r( r: r; ro � s
zControlMixin.serve_foreverNc C s< | � � | jdk r&t�| j|� d| _| �� | j�� dS )z�
Tell the server thread to stop, and wait for it to do so.
:param timeout: How long to wait for the server thread
to terminate.
N)�shutdownre r rw � server_closer| r? rx r: r: r; rz � s
zControlMixin.stop)N) r[ r\ r] r^ r% r ro rz r- r: r: r( r; r{ y s
r{ c @ s" e Zd ZdZd dd�Zdd� ZdS )
�TestHTTPServera�
An HTTP server which is controllable using :class:`ControlMixin`.
:param addr: A tuple with the IP address and port to listen on.
:param handler: A handler callable which will be called with a
single parameter - the request - in order to
process the request.
:param poll_interval: The polling interval in seconds.
:param log: Pass ``True`` to enable log messages.
r0 FNc s< G � �fdd�dt �� t�| |� � t�| ||� || _d S )Nc s2 e Zd Zddd�Zdd� Z�� �fdd�Z� ZS ) z=TestHTTPServer.__init__.<locals>.DelegatingHTTPRequestHandlerNc S s |� d�r| jS t|��d S )NZdo_)�
startswith�process_request�AttributeError)r8 r9 �defaultr: r: r; � __getattr__� s
zITestHTTPServer.__init__.<locals>.DelegatingHTTPRequestHandler.__getattr__c S s | j �| � d S r� ��serverrd rY r: r: r; r� � s zMTestHTTPServer.__init__.<locals>.DelegatingHTTPRequestHandler.process_requestc s �rt � | �j|f|�� d S r� )r$ � log_message)r8 �formatr
)� DelegatingHTTPRequestHandlerr) rs r: r; r� � s ���zITestHTTPServer.__init__.<locals>.DelegatingHTTPRequestHandler.log_message)N)r[ r\ r] r� r� r� r- r: �r� rs r( r; r� � s
r� )r r r% r{ �sslctx)r8 rh r� rg rs r� r: r� r; r% � s
zTestHTTPServer.__init__c
C sf z(| j �� \}}| jr&| jj|dd�}W n4 tk
r\ } ztj�d| � � W 5 d }~X Y nX ||fS )NT)Z server_sidezGot an error:
%s
)ra �acceptr� Z wrap_socketr� r� rU rJ )r8 �sockrh �er: r: r; � get_request� s zTestHTTPServer.get_request)r0 FN)r[ r\ r] r^ r% r� r: r: r: r; r � s
�
r c s. e Zd ZdZdZddd�Z� fdd�Z� ZS ) �
TestTCPServera�
A TCP server which is controllable using :class:`ControlMixin`.
:param addr: A tuple with the IP address and port to listen on.
:param handler: A handler callable which will be called with a single
parameter - the request - in order to process the request.
:param poll_interval: The polling interval in seconds.
:bind_and_activate: If True (the default), binds the server and starts it
listening. If False, you need to call
:meth:`server_bind` and :meth:`server_activate` at
some later time before calling :meth:`start`, so that
the server will set up the socket and listen on it.
Tr0 c C s2 G dd� dt �}t�| |||� t�| ||� d S )Nc @ s e Zd Zdd� ZdS )z;TestTCPServer.__init__.<locals>.DelegatingTCPRequestHandlerc S s | j �| � d S r� r� rY r: r: r; r� � s zBTestTCPServer.__init__.<locals>.DelegatingTCPRequestHandler.handleN)r[ r\ r] r� r: r: r: r; �DelegatingTCPRequestHandler� s r� )r r r% r{ )r8 rh r� rg �bind_and_activater� r: r: r; r% � s
�zTestTCPServer.__init__c s" t t| ��� | j�� d | _d S �NrW )r$ r� � server_bindra rb rc rY r( r: r; r� � s zTestTCPServer.server_bind)r0 T)r[ r\ r] r^ Zallow_reuse_addressr% r� r- r: r: r( r; r� � s �
r� c s6 e Zd ZdZd
dd�Z� fdd�Z� fdd �Z� ZS ) �
TestUDPServera0
A UDP server which is controllable using :class:`ControlMixin`.
:param addr: A tuple with the IP address and port to listen on.
:param handler: A handler callable which will be called with a
single parameter - the request - in order to
process the request.
:param poll_interval: The polling interval for shutdown requests,
in seconds.
:bind_and_activate: If True (the default), binds the server and
starts it listening. If False, you need to
call :meth:`server_bind` and
:meth:`server_activate` at some later time
before calling :meth:`start`, so that the server will
set up the socket and listen on it.
r0 Tc s< G � fdd�dt �� t�| |� |� t�| ||� d| _d S )Nc s& e Zd Zdd� Z�� fdd�Z� ZS )z;TestUDPServer.__init__.<locals>.DelegatingUDPRequestHandlerc S s | j �| � d S r� r� rY r: r: r; r� s zBTestUDPServer.__init__.<locals>.DelegatingUDPRequestHandler.handlec sD | j �� }|r@zt� | ��� W n tk
r> | jjs:� Y nX d S r� )ZwfilerG r$ �finishr� r� �_closedrH )�DelegatingUDPRequestHandlerr) r: r; r� s
zBTestUDPServer.__init__.<locals>.DelegatingUDPRequestHandler.finish)r[ r\ r] r� r� r- r: �r� r( r; r� s r� F)r
r r% r{ r� )r8 rh r� rg r� r: r� r; r% s �zTestUDPServer.__init__c s" t t| ��� | j�� d | _d S r� )r$ r� r� ra rb rc rY r( r: r; r� s zTestUDPServer.server_bindc s t t| ��� d| _d S )NT)r$ r� r~ r� rY r( r: r; r~ ! s zTestUDPServer.server_close)r0 T)r[ r\ r] r^ r% r� r~ r- r: r: r( r; r� � s �
r� �AF_UNIXc @ s e Zd ZejZdS )�TestUnixStreamServerN�r[ r\ r] ra r� �address_familyr: r: r: r; r� & s r� c @ s e Zd ZejZdS )�TestUnixDatagramServerNr� r: r: r: r; r� ) s r� c @ s e Zd ZdZdd� Zdd� ZdS )�SMTPHandlerTestg N@c
C s
i }t tjdf| jd|�}|�� tj|jf}tjj|ddd| j d�}| �
|j dg� g | _ t�
ddi�}t�� | _|�|� | j�| j � |�� | �| j�� � | �
t| j �d � | j d \}}}} | �
|d� | �
|dg� | �d
| � | �| �d �� |�� d S ) Nr ���MbP?�meZyouZLog)ry r� u Hello ✓rW z
Subject: Log
u
Hello ✓)r] r ZHOSTrm r rc r r4 Z SMTPHandler�TIMEOUTrI Ztoaddrs�messagesr� r r9 �handledr� r2 rz r7 �is_setrJ rT �endswithr= )
r8 ri r� rh rB r� rj rk rl rI r: r: r; �
test_basic2 s0 � �
zSMTPHandlerTest.test_basicc G s | j �|� | j�� d S r� )r� �appendr� r1 )r8 r
r: r: r; rm J s z SMTPHandlerTest.process_messageN)r[ r\ r] r� r� rm r: r: r: r; r� . s r� c @ s< e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
S )�MemoryHandlerTestz Tests for the MemoryHandler.r� c C sF t �| � tj�dtj| j�| _t�d�| _ d| j _
| j � | j� d S )N�
Zmemr ) r
r< r r4 �
MemoryHandlerri r. �mem_hdlrr �
mem_logger� propagater6 rY r: r: r; r< U s
� zMemoryHandlerTest.setUpc C s | j �� t�| � d S r� )r� r= r
rC rY r: r: r; rC ] s
zMemoryHandlerTest.tearDownc C s� | j �| �� � | �g � | j �| �� � | �g � | j �| �� � dddg}| �|� dD ]b}td�D ]}| j �| �� � qh| �|� | j �| �� � |dd� t||d �D � }| �|� q\| j �| �� � | �|� d S ) N�r, rd �rk rf )ri rg )r
� � c S s g | ]}d t |�f�qS )r, )�str)�.0�ir: r: r; �
<listcomp>w s z0MemoryHandlerTest.test_flush.<locals>.<listcomp>r� )r� rw rZ rV rv ru r )r8 �lines�nr� r: r: r; �
test_flusha s&
�
z MemoryHandlerTest.test_flushc C s� | j �| �� � | �g � | j �| �� � | �g � | j �| j� | j�� ddg}| �|� tj �
dtj | j d�| _| j �
| j� | j �| �� � | �|� | j �| �� � | �|� | j �| j� | j�� | �|� dS )zO
Test that the flush-on-close configuration works as expected.
r� r� r� FN)r� rw rZ rV rv r> r� r= r r4 r� ri r. r6 )r8 r� r: r: r; �test_flush_on_close} s,
�
�
z%MemoryHandlerTest.test_flush_on_closec
C sv G dd� d�}|| j �}z@| j �|� td�D ]&}t�d� | j� d� | j�
d� q.W 5 |jD ]}t�|� q`X d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )zZMemoryHandlerTest.test_race_between_set_target_and_flush.<locals>.MockRaceConditionHandlerc S s || _ g | _d S r� )r� �threads)r8 r� r: r: r; r% � s zcMemoryHandlerTest.test_race_between_set_target_and_flush.<locals>.MockRaceConditionHandler.__init__c S s | j �d � d S r� )r� � setTargetrY r: r: r; � removeTarget� s zgMemoryHandlerTest.test_race_between_set_target_and_flush.<locals>.MockRaceConditionHandler.removeTargetc S s& t j| jd�}| j�|� |�� d S )N)r )r r r� r� r� r )r8 r� �threadr: r: r; r� � s zaMemoryHandlerTest.test_race_between_set_target_and_flush.<locals>.MockRaceConditionHandler.handleN)r[ r\ r] r% r� r� r: r: r: r; �MockRaceConditionHandler� s r� r� r z not flushedZflushed) r� r� r rw r� r r r r� rv ru )r8 r� r r� r r: r: r; �&test_race_between_set_target_and_flush� s
z8MemoryHandlerTest.test_race_between_set_target_and_flushN)
r[ r\ r] r^ rF r< rC r� r� r� r: r: r: r; r� N s r� c @ s e Zd ZdZdd� ZdS )�ExceptionFormatterz A special exception formatter.c C s d|d j S )Nz
Got a [%s]r )r[ )r8 �eir: r: r; �formatException� s z"ExceptionFormatter.formatExceptionN)r[ r\ r] r^ r� r: r: r: r; r� � s r� c @ s� e Zd ZdZejZdZdZdZdZ e�
dd�Z e�
dd �Z d
e d Z
e�
d d
�ZdZdZdZdZdd� Zdd� Zdd� Zefdd�Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Z d&d'� Z d(d)� Z d*d+� Z d,S )-�ConfigFileTestz5Reading logging config from a .ini-style config file.�^(\w+) \+\+ (\w+)$aN
[loggers]
keys=root
[handlers]
keys=hand1
[formatters]
keys=form1
[logger_root]
level=WARNING
handlers=hand1
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stdout,)
[formatter_form1]
format=%(levelname)s ++ %(message)s
datefmt=
a�
[loggers]
keys=root,parser
[handlers]
keys=hand1
[formatters]
keys=form1
[logger_root]
level=WARNING
handlers=
[logger_parser]
level=DEBUG
handlers=hand1
propagate=1
qualname=compiler.parser
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stdout,)
[formatter_form1]
format=%(levelname)s ++ %(message)s
datefmt=
a�
[loggers]
keys=root,parser
[handlers]
keys=hand1
[formatters]
keys=form1
[logger_root]
level=WARNING
handlers=hand1
[logger_parser]
level=DEBUG
handlers=
propagate=1
qualname=compiler.parser
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stdout,)
[formatter_form1]
format=%(levelname)s ++ %(message)s
datefmt=
z
sys.stdoutz
sys.stboutzformatter=form1zformatter=misspelled_namea
[loggers]
keys=root
[handlers]
keys=hand1
[formatters]
keys=form1
[logger_root]
level=NOTSET
handlers=hand1
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stdout,)
[formatter_form1]
class=zS.ExceptionFormatter
format=%(levelname)s:%(name)s:%(message)s
datefmt=
zclass=StreamHandlerzclass=logging.StreamHandlerag
[loggers]
keys=root,parser
[handlers]
keys=hand1, hand2
[formatters]
keys=form1, form2
[logger_root]
level=WARNING
handlers=
[logger_parser]
level=DEBUG
handlers=hand1
propagate=1
qualname=compiler.parser
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stdout,)
[handler_hand2]
class=StreamHandler
level=NOTSET
formatter=form1
args=(sys.stderr,)
[formatter_form1]
format=%(levelname)s ++ %(message)s
datefmt=
[formatter_form2]
format=%(message)s
datefmt=
a%
[loggers]
keys=root,parser,compiler
[handlers]
keys=hand1
[formatters]
keys=form1
[logger_root]
level=WARNING
handlers=hand1
[logger_compiler]
level=DEBUG
handlers=
propagate=1
qualname=compiler
[logger_parser]
level=DEBUG
handlers=
propagate=1
qualname=compiler.parser
[handler_hand1]
class=StreamHandler
level=NOTSET
formatter=form1
kwargs={'stream': sys.stdout,}
[formatter_form1]
format=%(levelname)s ++ %(message)s
datefmt=
z�
[loggers]
keys=root
[handlers]
keys=file
[formatters]
keys=
[logger_root]
level=DEBUG
handlers=file
[handler_file]
class=FileHandler
level=DEBUG
args=("{tempfile}",)
z�
[loggers]
keys=root
[handlers]
keys=screen
[formatters]
keys=
[logger_root]
level=DEBUG
handlers=screen
[handler_screen]
level=DEBUG
class=StreamHandler
args=(sys.stdout,)
formatter=
c K s$ t �t�|��}tjj|f|� d S r� )r( r) �textwrap�dedentr �config�
fileConfig)r8 �conf�kwargs�filer: r: r; � apply_config� s zConfigFileTest.apply_configc C sb t �� �P}| �| j� t�� }|�| �� � |�| �� � | j dg|d� | � g � W 5 Q R X d S �N�re rf r# �
r �captured_stdoutr� �config0r r rv rZ rt rV �r8 �outputr� r: r: r; �test_config0_ok� s
��z ConfigFileTest.test_config0_okc C s� t �� �t}t�t�| j��}t�� }|� |� t
j � |� t
�
� }|�| �� � |�| �� � | jdg|d� | �g � W 5 Q R X d S r� )r r� r( r) r� r� r� � configparser� ConfigParserZ read_filer r� r� r rv rZ rt rV )r8 r� r� Zcpr� r: r: r; �test_config0_using_cp_ok� s
��z'ConfigFileTest.test_config0_using_cp_okc C sd t �� �R}| �|� t�d�}|�| �� � |�| �� � | jddg|d� | �g � W 5 Q R X d S �N�compiler.parser�rk rd r� r# � r r� r� r r rv rZ rt rV �r8 r� r� r� r: r: r; �test_config1_ok� s
��z ConfigFileTest.test_config1_okc C s | � t| j| j� d S r� �r� r r� �config2rY r: r: r; �test_config2_failure� s z#ConfigFileTest.test_config2_failurec C s | � t| j| j� d S r� �r� r r� �config3rY r: r: r; �test_config3_failure� s z#ConfigFileTest.test_config3_failurec C s| t �� �j}| �| j� t�� }z
t� �W n tk
rF t�d� Y nX tj �
d� | � |� � d� | �
g � W 5 Q R X d S �Nz just testingr z-ERROR:root:just testing
Got a [RuntimeError]
)r r� r� �config4r r rG � exceptionr� �stdout�seekrI rG rV r� r: r: r; �test_config4_ok� s
�z ConfigFileTest.test_config4_okc C s | j | jd� d S �N)r� �r� �config5rY r: r: r; �test_config5_ok s z ConfigFileTest.test_config5_okc C s | j | jd� d S r� )r� �config6rY r: r: r; �test_config6_ok s z ConfigFileTest.test_config6_okc C s& t �� �n}| �| j� t�d�}t�d�}|�| �� � |�| �� � |� | �� � | j
dddg|d� | �
g � W 5 Q R X t �� ��}| �| j � t�d�}| � |j
� |�| �� � |�| �� � t�d�}|�| �� � |�| �� � |� | �� � | j
dd d
d g|d� | �
g � W 5 Q R X d S � Nr� zcompiler-hyphenatedr� r� )rc rg r# �compiler.lexer)rk rh )re rj )rk rl )re rm )r r� r� �config1ar r rv rZ rt �criticalrV �config7r� r �r8 r� r� Z
hyphenatedr: r: r; �test_config7_ok sD
��
��z ConfigFileTest.test_config7_okc C s� dd� }| � � �X t�dd�\}}t�|� tjdkrB|�dd�}| jj|d�}| � |� | � |� W 5 Q R X t
j j d }| �
|||� d S )
Nc S s | � � t�|� d S r� �r= r� �remove��h1r� r: r: r; �cleanup9 s z/ConfigFileTest.test_config8_ok.<locals>.cleanupr �test_logging-X-r �\z\\)r� r )�check_no_resource_warningr� r� r� r= r9 �replace�config8r� r� r �rootr4 r� )r8 r� r� r� r r� r: r: r; �test_config8_ok7 s
z ConfigFileTest.test_config8_okc C sZ | � | j� t�d�}| �|j� | � | j� | �|j� | j | jdd� | �|j� d S )NZsome_pristine_loggerF)�disable_existing_loggers)r� � disable_testr r r� r r7 �r8 r� r: r: r; �test_logger_disablingN s
z$ConfigFileTest.test_logger_disablingc
C sx t �d��� }tjddd�\}}zFt�||�d�� t� |� t
j j |t
dddd d
d d �id
�d� W 5 t�|� X dS )z.bpo-33802 defaults should not get interpolatedat
[formatters]
keys=default
[formatter_default]
[handlers]
keys=console
[handler_console]
class=logging.StreamHandler
args=tuple()
[loggers]
keys=root
[logger_root]
formatter=default
handlers=console
�
test_logging_z.ini�r� �suffix�asciirW Fr� z5%(asctime)s [%(process)d] [%(levelname)s] %(message)sz[%Y-%m-%d %H:%M:%S %z]zlogging.Formatter)r� �datefmt�class)�versionr �
formatters)�defaultsN)r� r� �stripr� r� r� r� rJ �encoder= r r� r� �dict)r8 Zinir� r� r: r: r; �!test_defaults_do_no_interpolationW s&
����
z0ConfigFileTest.test_defaults_do_no_interpolationN) r[ r\ r] r^ r r� rF r� �config1r� r r� r� r� r� r� r� r r r� r� r� r� r� r� r� r� r� r� r r r r: r: r: r; r� � s> �� *& + r� c @ s@ e Zd ZdZeZdZdd� Zdd� Zdd� Z d d
� Z
d d � Z d
S )�SocketHandlerTestz Test for SocketHandler objects.�r� r c
C s� t �| � d | _ | _| _z$| �| j| jd� | _}|�� W n. t k
rn } z|| _W Y �dS d}~X Y nX |j
� � t j
j}t|jt�r�|d|j�| _n||jd�| _d| _| j�| jj
d � | j�| j� t�d�| _dS )ztSet up a TCP server to receive log messages, and a SocketHandler
pointing to that server's address and port.N�{�G�z�?r� r r )r
r< r� � sock_hdlr�server_exception� server_class�address�
handle_socketr r� r| r2 r r4 Z
SocketHandler�
isinstance�server_addressrN rc �
log_outputr% r> r6 r � Semaphorer� �r8 r� r� Zhclsr: r: r; r< � s(
�
zSocketHandlerTest.setUpc C sF z4| jr | j�| j� | j�� | jr2| j�d� W 5 t �| � X dS )zShutdown the TCP server.� @N)r
rC r r% r> r= r� rz rY r: r: r; rC � s
zSocketHandlerTest.tearDownc C s� |j }|�d�}t|�dk r q�t�d|�d }|�|�}t|�|k r\||�|t|� � }q8t�|�}t�|�}| j |j
d 7 _ | j � � qd S )Nr
�>Lr �
)
�
connection�recvrJ �struct�unpack�pickle�loadsr r� r r� r� r+ )r8 �request�conn�chunk�slen�objr� r: r: r; r � s
z SocketHandlerTest.handle_socketc C sV | j r| �| j � t�d�}|�d� | j�� |�d� | j�� | �| j d� d S )NZtcpr� �eggs�
spam
eggs
)
r �skipTestr r rt r� r* rw rI r r r: r: r; � test_output� s
z SocketHandlerTest.test_outputc C s� | j r| �| j � d| j_| j�d� z td��W n tk
rR | j�d� Y nX | j� d� t
�
� }| � | jj |� t
�
| jj | d � | j� d� d S )Ng @r# zDeliberate mistakez
Never sentzNever sent, eitherr� zNor this)r r3 r Z
retryStartr� rz rG r% r� rt r r7 Z retryTimer )r8 �nowr: r: r; �
test_noserver� s z SocketHandlerTest.test_noserverN) r[ r\ r] r^ r� r r r< rC r r4 r6 r: r: r: r; r � s r c C s* t jddd�\} }t�| � t�|� |S )Nr z.sockr )r� r� r� r= r� )r� r� r: r: r; �_get_temp_domain_socket� s
r7 zUnix sockets requiredc @ s. e Zd ZdZeed�reZdd� Zdd� Z dS )�UnixSocketHandlerTestz)Test for SocketHandler with unix sockets.r� c C s t � | _t�| � d S r� )r7 r r r< rY r: r: r; r< � s zUnixSocketHandlerTest.setUpc C s t �| � t�| j� d S r� )r rC r r� r rY r: r: r; rC � s
z UnixSocketHandlerTest.tearDownN)
r[ r\ r] r^ rD ra r� r r< rC r: r: r: r; r8 � s
r8 c @ s8 e Zd ZdZeZdZdd� Zdd� Zdd� Z d d
� Z
d S ) �DatagramHandlerTestzTest for DatagramHandler.r c
C s� t �| � d | _ | _| _z$| �| j| jd� | _}|�� W n. t k
rn } z|| _W Y �dS d}~X Y nX |j
� � t j
j}t|jt�r�|d|j�| _n||jd�| _d| _| j�| jj
d � | j�| j� t�� | _dS )zvSet up a UDP server to receive log messages, and a DatagramHandler
pointing to that server's address and port.Nr r� r r )r
r< r� r r r r �handle_datagramr r� r| r2 r r4 ZDatagramHandlerr r rN rc r r% r> r6 r r9 r� r" r: r: r; r< � s(
�
zDatagramHandlerTest.setUpc C sF z4| jr| j�d� | jr2| j�| j� | j�� W 5 t �| � X dS )zShutdown the UDP server.r# N)r
rC r� rz r r% r> r= rY r: r: r; rC s z DatagramHandlerTest.tearDownc C sT t �dd�}|jt|�d � }t�|�}t�|�}| j|j d 7 _| j
� � d S )Nr$ r r% ) r( �pack�packetrJ r* r+ r r� r r� r� r1 )r8 r, r/ r< r0 r� r: r: r; r: ! s
z#DatagramHandlerTest.handle_datagramc C s` | j r| �| j � t�d�}|�d� | j�� | j�� |�d� | j�� | �| j d� d S )NZudpr� r1 r2 )
r r3 r r rt r� r2 r? rI r r r: r: r; r4 ) s
z DatagramHandlerTest.test_outputN� r[ r\ r] r^ r� r r r< rC r: r4 r: r: r: r; r9 � s r9 c @ s. e Zd ZdZeed�reZdd� Zdd� Z dS )�UnixDatagramHandlerTestz,Test for DatagramHandler using Unix sockets.r� c C s t � | _t�| � d S r� )r7 r r9 r< rY r: r: r; r< = s z UnixDatagramHandlerTest.setUpc C s t �| � t�| j� d S r� )r9 rC r r� r rY r: r: r; rC B s
z UnixDatagramHandlerTest.tearDownN�
r[ r\ r] r^ rD ra r� r r< rC r: r: r: r; r> 5 s
r> c @ s8 e Zd ZdZeZdZdd� Zdd� Zdd� Z d d
� Z
d S ) �SysLogHandlerTestz!Test for SysLogHandler using UDP.r c
C s� t �| � d | _ | _| _z$| �| j| jd� | _}|�� W n. t k
rn } z|| _W Y �dS d}~X Y nX |j
� � t j
j}t|jt�r�||jd |jf�| _n ||j�| _d| _| j�| jj
d � | j�| j� t�� | _dS )ztSet up a UDP server to receive log messages, and a SysLogHandler
pointing to that server's address and port.Nr r r )r
r< r� �sl_hdlrr r r r: r r� r| r2 r r4 r� r r rN rc r r% r> r6 r r9 r� r" r: r: r; r< M s(
�
zSysLogHandlerTest.setUpc C sF z4| jr| j�d� | jr2| j�| j� | j�� W 5 t �| � X dS )zShutdown the server.r# N)r
rC r� rz rA r% r> r= rY r: r: r; rC g s zSysLogHandlerTest.tearDownc C s |j | _| j�� d S r� )r< r r� r1 )r8 r, r: r: r; r: r s z!SysLogHandlerTest.handle_datagramc C s� | j r| �| j � t�d�}|�d� | j�� | �| jd� | j� � d| j
_ |�d� | j�� | �| jd� | j� � d| j
_ |�d� | j�� | �| jd� d S )NZslh� späms
<11>späm Fs <11>spämu häm-s <11>häm-späm)
r r3 r r rt r� r2 rI r r? rA Z
append_nul�identr r: r: r; r4 v s
z SysLogHandlerTest.test_outputNr= r: r: r: r; r@ F s r@ c @ s. e Zd ZdZeed�reZdd� Zdd� Z dS )�UnixSysLogHandlerTestz)Test for SysLogHandler with Unix sockets.r� c C s t � | _t�| � d S r� )r7 r r@ r< rY r: r: r; r< � s zUnixSysLogHandlerTest.setUpc C s t �| � t�| j� d S r� )r@ rC r r� r rY r: r: r; rC � s
z UnixSysLogHandlerTest.tearDownNr? r: r: r: r; rD � s
rD z$IPv6 support required for this test.c s4 e Zd ZdZeZdZ� fdd�Z� fdd�Z� Z S )�IPv6SysLogHandlerTestz&Test for SysLogHandler with IPv6 host.)z::1r c s t j| j_tt| ��� d S r� )ra �AF_INET6r r� r$ rE r< rY r( r: r; r< � s
zIPv6SysLogHandlerTest.setUpc s t j| j_tt| ��� d S r� )ra �AF_INETr r� r$ rE rC rY r( r: r; rC � s
z IPv6SysLogHandlerTest.tearDown)
r[ r\ r] r^ r� r r r< rC r- r: r: r( r; rE � s
rE c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �HTTPHandlerTestzTest for HTTPHandler.c C s t �| � t�� | _dS )ztSet up an HTTP server to receive log messages, and a HTTPHandler
pointing to that server's address and port.N)r
r< r r9 r� rY r: r: r; r< � s
zHTTPHandlerTest.setUpc C sr |j | _ t|j�| _| j dkrRz t|jd �}|j�|�| _W n d | _Y nX |� d� |�
� | j � � d S )Nr� zContent-Length�� )
�commandr r� �log_data�intZheadersZrfilerP � post_dataZ
send_responseZ end_headersr� r1 )r8 r, Zrlenr: r: r; �handle_request� s
z HTTPHandlerTest.handle_requestc C s� t �d�}| j}|�| jjd � dD �]�}d}|r�z dd l}W n tk
rX d }Y q�X tj� t
�}tj� |d�}|� |j
�}|�|� |j|d�} nd }d } t|| jd|d� | _}
|
�� |
j�� d |
j } |o�|} t jj| d
| | d d �| _d | _|�| j� d
D ]�}
|
| j_| j � � d}|� |� | j �� | � | jjd
� | � | j |
� |
dk�rnt!| jj"�}nt!| j#�$d��}| � |d dg� | � |d dg� | � |d |g� �q
| j�%d� | j�| j� | j�&� q&d S )NZhttpr r r z keycert.pem)Zcafiler )r� z localhost:%dz/frob)�foo�bar)�secure�contextZ credentials)r� r� rB r� �utf-8r9 �funcNamer4 r� r# )'r r r% r> r4 �ssl� ImportErrorr� r� �dirname�__file__r� Z
SSLContextZPROTOCOL_TLS_SERVERZload_cert_chainZcreate_default_contextr rN r� r r| r2 Z server_portr� Zh_hdlrrK r6 r r� r? rt rI rJ r ZqueryrM �decoderz r= )r8 r� r% rQ rh rU r� �hereZlocalhost_certrR r� �hostZ
secure_clientr r� �dr: r: r; r4 � sb
�
�
zHTTPHandlerTest.test_outputN)r[ r\ r] r^ r< rN r4 r: r: r: r; rH � s
rH c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �
MemoryTestz*Test memory persistence of logger objects.c C s t �| � i | _dS )z8Create a dict to remember potentially destroyed objects.N)r
r< �
_survivorsrY r: r: r; r< � s
zMemoryTest.setUpc G s. |D ]$}t |�t|�f}t�|�| j|< qdS )zKWatch the given objects for survival, by creating weakrefs to
them.N)�idr[ �weakref�refr^ )r8 r
r0 �keyr: r: r; �_watch_for_survival s z MemoryTest._watch_for_survivalc C s\ t �� g }| j�� D ] \\}}}|� dkr|�|� q|rX| �dt|�d�|�f � dS )z;Assert that all objects watched for survival have survived.Nz;%d objects should have survived but have been destroyed: %sz, )�gcZcollectr^ r� r� rM rJ r� )r8 ZdeadZid_�repr_ra r: r: r; �_assertTruesurvival s
�z MemoryTest._assertTruesurvivalc C s� | j �tj� t�d�}| �|� |�tj� | j �| �� � |�| �� � | � dg� ~| �
� t�d�}|�| �� � | � ddg� d S )NrO )rO r, rf )rO r, rg ) r% r+ r rk r rc r, rw rZ rV rf )r8 rO rP r: r: r; �test_persistent_loggers s"
�
�z"MemoryTest.test_persistent_loggersN)r[ r\ r] r^ r< rc rf rg r: r: r: r; r] � s
r] c @ s e Zd Zdd� Zdd� ZdS )� EncodingTestc C s� t �d�}t�dd�\}}t�|� d}zpt j |dd�}|�
|� z|� |� W 5 |� |� |�� X t
|dd�}z| �|�� �� |� W 5 |�� X W 5 tj�|�r�t�|� X d S )N�testr ztest_logging-1-u foorS )�encoding)r r r� r� r� r= r� �isfiler� r r6 r> ru r& rI rP �rstrip)r8 rs r� r� rI r� r� r: r: r; �test_encoding_plain_file- s"
z%EncodingTest.test_encoding_plain_filec C s� t �d�}d}t�d�}d|_t�� }||d�}t �|�}|�|� z|� |� W 5 |� |� |�
� X |� � }| �
|d� d S )Nri u до свидания�cp1251�stricts �� �������
)r r �codecs� getwriterrj r( �BytesIOr- r6 r> r= ru rG rI )r8 rs �messageZ writer_classr* �writerr� rU r: r: r; � test_encoding_cyrillic_unicodeG s
z+EncodingTest.test_encoding_cyrillic_unicodeN)r[ r\ r] rm ru r: r: r: r; rh , s rh c @ s e Zd Zdd� Zdd� ZdS )� WarningsTestc C s� t �� �� t�d� | �tjd� t jdtd� t�� }t� |�}t�
d�}|� |� t � d� |�
|� |�� }|�� | �|�d�d� t�� }t �d td
d |d � |�� }|�� | �|d
� W 5 Q R X d S )NTF�always)�category� py.warningszI'm warning you...z UserWarning: I'm warning you...
r �Explicit�dummy.py�* z
Dummy linez0dummy.py:42: UserWarning: Explicit
Dummy line
)�warnings�catch_warningsr �captureWarningsr� �filterwarnings� UserWarningr( r) r- r r6 �warnr> rG r= r7 �find� showwarningrI )r8 r* rB r� rU Za_filer: r: r; �
test_warnings_ s.
��zWarningsTest.test_warningsc C s~ t �� �l t�d� | �tjd� t�d�}| �|jg � t �dt dd� | �t
|j�d� | � |jd tj � W 5 Q R X d S ) NTFry rz r{ r| rW r )
r} r~ r r r� r rI r4 r� r� rJ �assertIsInstance� NullHandlerr r: r: r; �test_warnings_no_handlersw s
z&WarningsTest.test_warnings_no_handlersN)r[ r\ r] r� r� r: r: r: r; rv ] s rv c C s t �| |�S r� )r r/ )r� r r: r: r; �
formatFunc� s r� c @ s e Zd Zddd�ZdS )�myCustomFormatterNc C s d S r� r: )r8 �fmtr r: r: r; r% � s zmyCustomFormatter.__init__)N)r[ r\ r] r% r: r: r: r; r� � s r� c C s t �� S r� )r r- r: r: r: r; � handlerFunc� s r� c @ s e Zd ZdS )�
CustomHandlerN�r[ r\ r] r: r: r: r; r� � s r� c
@ s e Zd ZdZejZdZddddiidddd d
d �id dgd
�d�Zddddiidddd d
d �idddgd
�idd id�Zddddiidddd d
d �idddiid dgd
�d�Z ddddiidddd dd �idddgd
�idd id�Z
ddddiiddddd
d �idddgd
�idd id�Z ddddiidddd d
d �idddgd
�iddid�Z ddddiidddd d
d �idddgd
�idd id�Z
dde d dd�idddd d
d �id dgd
�d�Zdedd�e d dd�edd�d�ddd d
d �d eid �d dgd
�d�Zddddiide d dd d
d �idddgd
�idd id�Zddddiide d dd d
d d �idddgd
�idd id�Zddddiidddd d
d �id!ddgd
�idd id�Zdd"dddiidddd d
d �iddgd
�i d#�dd id$�Zdd%dddiidddd d
d �iddgd
�i d#�dd id$�Zddddiidddd d
d �idd dgd
�idd id�Zdd%ddd iiddd&iid'�Zdd%ddd&iiddd&iid'�Zddddiid(d)diidddd d
d(gd*�iddd(gd+�id dgd
�d,�Zddddiidddd d
d �id-dd.idddgd
�idd id/�Z dddiidddd d
d �id-dd.idddgd
�idd id0�Z d1dddiidddd d
d �id-dd.idddgd
�idd id/�Z ddddiidddd d
d2d3d4�d5�id dgd
�d�Z dd6d7d8d9�iddd6d:�d;d<d6d=dd>�d?�d@ddAgdBdC�idD�Z dde d dd"dE�idddd d
d �idFddgdBdC�idD�Z!dde d dd"dG�idddd d
d �idFddgdBdC�idD�Z"dde dH dd"dG�idddd d
d �idFddgdBdC�idD�Z#ddedd"dE�idddd d
d �idFddgdBdC�idD�Z$dIdJ� Z%dKdL� Z&efdMdN�Z'dOdP� Z(dQdR� Z)dSdT� Z*dUdV� Z+dWdX� Z,dYdZ� Z-d[d\� Z.d]d^� Z/d_d`� Z0dadb� Z1dcdd� Z2dedf� Z3dgdh� Z4didj� Z5dkdl� Z6dmdn� Z7dodp� Z8dqdr� Z9d�dtdu�Z:dvdw� Z;dxdy� Z<dzd{� Z=d|d}� Z>d~d� Z?d�d�� Z@d�d�� ZAd�d�� ZBd�d�� ZCd�d�� ZDd�d�� ZEd�d�� ZFdsS )��ConfigDictTestz)Reading logging config from a dictionary.r� rW �form1r� z %(levelname)s ++ %(message)s�hand1zlogging.StreamHandlerr� zext://sys.stdout)r
� formatterrO r* ri �rO r4 )r r r4 r r� r, rO )r r r4 �loggersr zext://sys.stdboutZNTOSETZWRANINGZmisspelled_namez.ExceptionFormatterz"%(levelname)s:%(name)s:%(message)s)�()r� z .formatFunc)r� Zform2Zform3r� )r� Zhand2z.CustomHandlerzinvalid parameter name)r
r� rO r* ro r� F)�compilerr� )r r r r4 r� r Trk )r Z incrementalr4 r� Zfilt1r9 )r
r� rO r* �filters)rO r� )r r r� r4 r� r zcfg://true_formattersz cfg://handler_configs[hand1])r �true_formatters�handler_configsr r4 r� r )r� r� r r4 r� r r� rP �!
)rO �
terminator)r
r� rO r* r� �mySimpleFormatterz1%(asctime)s (%(name)s) %(levelname)s: %(message)s�$)r� �style)r
rO r� z logging.handlers.MemoryHandler� �
fileGlobal)r
Zcapacityr� r rO )r� � bufferGlobal�mymoduler� �true)rO r4 r� )r r r4 r� )r� r� �validate� my_test_logger_custom_formatter)r
r� r� z.myCustomFormatterc C s t j�|� d S r� )r r� Z
dictConfig)r8 r� r: r: r; r� x s zConfigDictTest.apply_configc C sb t �� �P}| �| j� t�� }|�| �� � |�| �� � | j dg|d� | � g � W 5 Q R X d S r� r� r� r: r: r; r� { s
��z ConfigDictTest.test_config0_okc C sd t �� �R}| �|� t�d�}|�| �� � |�| �� � | jddg|d� | �g � W 5 Q R X d S r� r� r� r: r: r; r� � s
��z ConfigDictTest.test_config1_okc C s | � t| j| j� d S r� r� rY r: r: r; r� � s z#ConfigDictTest.test_config2_failurec C s | � t| j| j� d S r� )r� r r� �config2arY r: r: r; �test_config2a_failure� s z$ConfigDictTest.test_config2a_failurec C s | � t| j| j� d S r� )r� r r� �config2brY r: r: r; �test_config2b_failure� s z$ConfigDictTest.test_config2b_failurec C s | � t| j| j� d S r� r� rY r: r: r; r� � s z#ConfigDictTest.test_config3_failurec C st t �� �b}| �| j� z
t� �W n tk
r> t�d� Y nX tj� d� | �
|� � d� | � g � W 5 Q R X d S r� )
r r� r� r� rG r r� r� r� r� rI rG rV �r8 r� r: r: r; r� � s
�z ConfigDictTest.test_config4_okc C st t �� �b}| �| j� z
t� �W n tk
r> t�d� Y nX tj� d� | �
|� � d� | � g � W 5 Q R X d S r� )
r r� r� �config4arG r r� r� r� r� rI rG rV r� r: r: r; �test_config4a_ok� s
�z ConfigDictTest.test_config4a_okc C s | j | jd� d S r� r� rY r: r: r; r� � s z ConfigDictTest.test_config5_okc C s | � t| j| j� d S r� )r� r r� r� rY r: r: r; �test_config6_failure� s z#ConfigDictTest.test_config6_failurec C s� t �� �T}| �| j� t�d�}|�| �� � |�| �� � | j ddg|d� | � g � W 5 Q R X t �� �j}| �| j
� t�d�}| � |j � t�d�}|�| �� � |�| �� � | j ddg|d� | � g � W 5 Q R X d S )Nr� r� r� r# r� �rk rg �re rh )
r r� r� r r r rv rZ rt rV r� r7 r r� r: r: r; r� � s4
��
��z ConfigDictTest.test_config7_okc C s� t �� �T}| �| j� t�d�}|�| �� � |�| �� � | j ddg|d� | � g � W 5 Q R X t �� ��}| �| j
� t�d�}| � |j � |�| �� � |�| �� � t�d�}|�| �� � |�| �� � | j dddd g|d� | � g � W 5 Q R X d S )
Nr� r� r� r# r� r� r� �rk rj �re rl )
r r� r� r r r rv rZ rt rV r r� r r� r: r: r; �test_config_8_ok� s<
��
��z ConfigDictTest.test_config_8_okc C s& t �� �n}| �| j� t�d�}t�d�}|�| �� � |�| �� � |� | �� � | j
dddg|d� | �
g � W 5 Q R X t �� ��}| �| j � t�d�}| � |j
� |�| �� � |�| �� � t�d�}|�| �� � |�| �� � |� | �� � | j
dd d
d g|d� | �
g � W 5 Q R X d S r� )r r� r� r� r r rv rZ rt r� rV �config8ar� r r� r: r: r; �test_config_8a_ok sD
��
��z ConfigDictTest.test_config_8a_okc C s� t �� ��}| �| j� t�d�}|�| �� � | jg |d� | �| j � |�| �� � | jg |d� | �| j
� |�| �� � | jdg|d� W 5 Q R X d S )Nr� r# r� ) r r� r� �config9r r rv rZ rV �config9a�config9br� r: r: r; �test_config_9_ok6 s
��z ConfigDictTest.test_config_9_okc C s� t �� ��}| �| j� t�d�}|�| �� � t�d�}|�| �� � t�d�}|�| �� � t�d�}|�| �� � | j ddg|d� W 5 Q R X d S �Nr� r� r� zcompiler.parser.codegen)ri rd r� r# )
r r� r� �config10r r ru rZ rt rV r� r: r: r; �test_config_10_okH s
��z ConfigDictTest.test_config_10_okc C s | � | j� d S r� )r� �config11rY r: r: r; �test_config11_ok[ s z ConfigDictTest.test_config11_okc C s | � t| j| j� d S r� )r� r r� �config12rY r: r: r; �test_config12_failure^ s z$ConfigDictTest.test_config12_failurec C s | � t| j| j� d S r� )r� r r� �config13rY r: r: r; �test_config13_failurea s z$ConfigDictTest.test_config13_failurec C sh t �� �V}| �| j� tjd }| �|jd� | �|jd� t� d� | �
|� � � d�� W 5 Q R X d S )Nr� rP r� Z Exclamationz
Exclamation!
)
r r� r� �config14r r rI rO r� ru r7 rG r� )r8 r� rB r: r: r; �test_config14_okd s
z ConfigDictTest.test_config14_okc C s� dd� }| � � �P t�dd�\}}t�|� ddd|d�id dgid
�}| �|� | �|� W 5 Q R X tjjd }| � |||� d S ) Nc S s | � � t�|� d S r� r� r� r: r: r; r� o s z0ConfigDictTest.test_config15_ok.<locals>.cleanupr r� rW r� zlogging.FileHandler)r
�filenamer4 �r r4 r r )
r� r� r� r� r= r� r r r4 r� )r8 r� r� r� r� r� r: r: r; �test_config15_okm s$
�� ��
z ConfigDictTest.test_config15_okNc
C s� |� d�}tj�d|�}|�� |j�� |j}|j�� z�t � t j
t j�}|�d� |�d|f� t�dt|��}|| }d}t|�} | dkr�|�||d � �}
||
7 }| |
8 } q�|�� W 5 |j�d� tj� � t
� |d� X d S )NrS r r# r� r$ )r r r� �listenr r| r2 rc r? Z
stopListeningr rw ra rG � SOCK_STREAM�
settimeout�connectr( r; rJ �sendr= ) r8 �textZverifyrr rc r� r/ rU Z sentsofar�left�sentr: r: r; �setup_via_listener� s,
z!ConfigDictTest.setup_via_listenerc C s� t �� ��}| �t�| j�� t�d�}|�| � � � t�d�}|�| � � � t�d�}|�| � � � t�d�}|�
| � � � | j ddg|d� W 5 Q R X d S r� ) r r� r� �json�dumpsr� r r ru rZ rt rV r� r: r: r; �test_listen_config_10_ok� s
��z'ConfigDictTest.test_listen_config_10_okc C sl t �� �Z}| �t�tj�� t�d�}|� | �
� � |� | �
� � | j ddg|d� | � g � W 5 Q R X d S r� )
r r� r� r� r� r� r r r rv rZ rt rV r� r: r: r; �test_listen_config_1_ok� s
��z&ConfigDictTest.test_listen_config_1_okc C sb dd� }dd� }t �d�}t�tj�}t�� �.}| �||� |� | �
� � |� | �
� � W 5 Q R X | j g |d� | j ddgd d
� t�� �6}| �|� t �d�}|� | �
� � |� | �
� � W 5 Q R X | j d d g|d� | j ddgd d
� t�� �B}| �|d d d
� |� t �d�}|� | �
� � |� | �
� � W 5 Q R X | j ddg|d� | j ddgd d
� d S )Nc S s d S r� r: ��stuffr: r: r; � verify_fail� s z6ConfigDictTest.test_listen_verify.<locals>.verify_failc S s | d d d� S )Nr� r: r� r: r: r; �verify_reverse� s z9ConfigDictTest.test_listen_verify.<locals>.verify_reverser� r# r� r� r� )rQ r� r� r� r� r� )
r r r� r� r� r r r� r� rv rZ rt rV )r8 r� r� r� Zto_sendr� r: r: r; �test_listen_verify� sb
��
����
����z!ConfigDictTest.test_listen_verifyc C s | � t| j| j� d S r� )r� r� r� � out_of_orderrY r: r: r; �test_out_of_order
s z ConfigDictTest.test_out_of_orderc C s\ t �| j�}d|d d d< | �|� t�d�jd }| �|jtj � | �|j
j tj � d S )Nz-${asctime} (${name}) ${levelname}: ${message}r r� r� r� r )
r �deepcopyr� r� r r r4 r� r r� r� �_style�StringTemplateStyle�r8 r� r� r: r: r; �#test_out_of_order_with_dollar_style
s
�z2ConfigDictTest.test_out_of_order_with_dollar_stylec C s. | � | j� t�d�jd }| �|jt� d S �Nr� r )r� � custom_formatter_class_validater r r4 r� r� r� �r8 r� r: r: r; �)test_custom_formatter_class_with_validate
s z8ConfigDictTest.test_custom_formatter_class_with_validatec C s. | � | j� t�d�jd }| �|jt� d S r� )r� � custom_formatter_class_validate2r r r4 r� r� r� r� r: r: r; �*test_custom_formatter_class_with_validate2
s z9ConfigDictTest.test_custom_formatter_class_with_validate2c C sF | j �� }d|d d d< | �|� t�d�jd }| �|jt� d S )Nr� r r� r� r� r ) r� r r� r r r4 r� r� r� r� r: r: r; �9test_custom_formatter_class_with_validate2_with_wrong_fmt
s
zHConfigDictTest.test_custom_formatter_class_with_validate2_with_wrong_fmtc C s | � t| j| j� d S r� )r� r� r� � custom_formatter_class_validate3rY r: r: r; �*test_custom_formatter_class_with_validate3%
s z9ConfigDictTest.test_custom_formatter_class_with_validate3c C s | � t| j| j� d S r� )r� r� r� � custom_formatter_with_functionrY r: r: r; �,test_custom_formatter_function_with_validate(
s z;ConfigDictTest.test_custom_formatter_function_with_validatec C s� ddddgddd�dd d
d gd gd
ddgd�}t j�|�}| �|�d�d� | �|�d�d� | �|�d�d� | �|�d�d � | �|�d�d� | �|�d�d� |�d�}| �|�d�dddg� | �t|jd� | �t|jd � | �t|jd � d S ) N)rW r� � r �b�cr� r� )r\ r� )�g)rB r� �jr� �lrx r� �oz cfg://alist�p)ZatupleZalistZadictZnest1Znest2Znest3zcfg://atuple[1]r� zcfg://alist[1]zcfg://nest1[1][0]rB zcfg://nest2[1][1]z
cfg://adict.dzcfg://adict[f]z cfg://nest3rW z cfg://nosuchzcfg://!zcfg://adict[2]) r r� ZBaseConfiguratorrI �convert�popr� �KeyErrorr� )r8 r\ Zbcr� r: r: r; �test_baseconfig+
s& �
z ConfigDictTest.test_baseconfigc s� ddl m� G � fdd�dtj�}� dddg�}|dd gd
�}d d ||d
�idd gd�d�}t�� �}| �|� t�d� W 5 Q R X | �|� � d� d S )Nr ��
namedtuplec s* e Zd Z� �fdd�Z� fdd�Z� ZS )z1ConfigDictTest.test_namedtuple.<locals>.MyHandlerc s t � j||� || _d S r� )r$ r% �resource)r8 r� r
r� )r) r� r: r; r% F
s z:ConfigDictTest.test_namedtuple.<locals>.MyHandler.__init__c s$ | j d| jj� �7 _ t� �|�S �N� )r� r� �typer$ r� r� r( r: r; r� J
s z6ConfigDictTest.test_namedtuple.<locals>.MyHandler.emitr, r: r� r( r; � MyHandlerE
s r� �Resourcer� �labelsZmy_typer )r� r� rW Z myhandler)r� r� rk r� r� zsome logzsome log my_type
)
� collectionsr� r r- r rS r� rv rI rG )r8 r� r� r� r� rU r: r� r; �test_namedtupleA
s ��
�
z ConfigDictTest.test_namedtuple)N)Gr[ r\ r] r^ r r� rF r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r: r: r: r; r� � s� ���� �� ���� �� �� ���� ���� ���� �� �� ���� �� �� ���� �� �� ���� �� �� ���� ������� �� ��# ���� �� �� ����
�� �� ���� �� �� ����
�� �� ����
�� �� ���� �� �� �� ��� �� ��� �� ����
����# ���� ��� ��! ���� ��� �� ���� ��� �� �����
����������!���� ��� ���� ��� ���� ��� ���� ��� !+
>
r� c @ s e Zd Zdd� Zdd� ZdS )� ManagerTestc sn g � G � fdd�dt j�}t �d �}| �t|jt� |�|� |�d�}|�d� t �d� | � � dg� d S )Nc s e Zd Zd� fdd� ZdS )z6ManagerTest.test_manager_loggerclass.<locals>.MyLoggerNc s � � |� d S r� �r� )r8 rO r� r
�exc_info�extra�Zloggedr: r; �_loge
s z;ManagerTest.test_manager_loggerclass.<locals>.MyLogger._log)NN)r[ r\ r] r r: r r: r; �MyLoggerd
s r ri zshould appear in loggedzshould not appear in logged)
r �Logger�Managerr� � TypeError�setLoggerClassrL r ru rI )r8 r �manr� r: r r; �test_manager_loggerclassa
s
z$ManagerTest.test_manager_loggerclassc C s, t �d �}t� }|�|� | �|j|� d S r� )r r
�object�setLogRecordFactoryrI �logRecordFactory)r8 r
rS r: r: r; �test_set_log_record_factoryq
s
z'ManagerTest.test_set_log_record_factoryN)r[ r\ r] r r r: r: r: r; r `
s r c @ s e Zd Zdd� ZdS )�ChildLoggerTestc C s� t �� }t �d�}t �d�}|�d�}|�d�}| �|t �d�� | �|t �d�� |�d�}|�d�}|�d�}| �|t �d�� | �|t �d�� | �||� d S ) N�abczdef.ghiZxyzzuvw.xyz�defZghi�abc.defz abc.def.ghi)r r �getChildrR )r8 r� �l1�l2�c1�c2Zc3r: r: r; �test_child_loggersx
s
z"ChildLoggerTest.test_child_loggersN)r[ r\ r] r r: r: r: r; r w
s r c @ s e Zd ZdS )�DerivedLogRecordNr� r: r: r: r; r �
s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�LogRecordFactoryTestc C sB G dd� dt j�}t�| � |t�| _| j�| j� t �� | _ d S )Nc @ s e Zd Zdd� Zdd� ZdS )z2LogRecordFactoryTest.setUp.<locals>.CheckingFilterc S s
|| _ d S r� )r )r8 r r: r: r; r% �
s z;LogRecordFactoryTest.setUp.<locals>.CheckingFilter.__init__c S s, t |�}|| jk r(d|| jf }t|��dS )Nz)Unexpected LogRecord type %s, expected %sT)r� r r )r8 r� rr r� r: r: r; r� �
s
�z9LogRecordFactoryTest.setUp.<locals>.CheckingFilter.filterN)r[ r\ r] r% r� r: r: r: r; �CheckingFilter�
s r )
r r� r
r< r r� r% r� �getLogRecordFactory� orig_factory)r8 r r: r: r; r< �
s
zLogRecordFactoryTest.setUpc C s( | j �| j� t�| � t�| j� d S r� )r% r� r� r
rC r r r! rY r: r: r; rC �
s
z LogRecordFactoryTest.tearDownc C s@ | � t| jj| �� � t�t� | j�| �� � | � dg� d S )N)r re rf )
r� r r% ru rZ r r r rt rV rY r: r: r; �test_logrecord_class�
s �
�z)LogRecordFactoryTest.test_logrecord_classN)r[ r\ r] r< rC r" r: r: r: r; r �
s r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Ze� e
e j d
�d �d d
� �Z
e� e
e j d
�d �dd� �Ze� e
e j d
�d �dd� �ZdS )�QueueHandlerTestr� c C s` t �| � t�d�| _tj�| j�| _d| _t� d�| _
d| j
_ | j
� tj
� | j
�| j� d S )Nr� ZqueF)r
r< �queue�Queuer r4 � QueueHandler�que_hdlrr9 r �
que_loggerr� r+ ri r6 rY r: r: r; r< �
s
zQueueHandlerTest.setUpc C s | j �� t�| � d S r� )r' r= r
rC rY r: r: r; rC �
s
zQueueHandlerTest.tearDownc C s� | j �| �� � | �tj| jj� | j �| �� � | �tj| jj� | �� }| j �|� | j�� }| � t
|t j �� | �
|j| j j� | �
|j|jf|d f� d S r� )r( rw rZ r� r$ �Empty�
get_nowaitrv ru r7 r r � LogRecordrI r9 r� r
)r8 r� rI r: r: r; �test_queue_handler�
s
z#QueueHandlerTest.test_queue_handlerc C sx | � � }t�tj�}d}|j| j||d�}t�| j�}| j� |� | j
� |� | j �
� }| �||j� | �||j� d S )Nz {name} -> {levelname}: {message})r9 � levelnamers )rZ r r� ri r� r9 r/ r0 r' r2 r( ru r$ r* rI r� rs )r8 r� r- Zlog_format_strZ
formatted_msgr� Z
log_recordr: r: r; �test_formatting�
s �
z QueueHandlerTest.test_formatting�
QueueListenerz5logging.handlers.QueueListener required for this testc C st t �t �� �}tj�| j|�}|�� z4| j �
| � � � | j � | � � � | j �
| � � � W 5 |�� X | �|jtjdd�� | �|jtjdd�� | �|jtjdd�� |�� t �t �� �}|�tj� tjj| j|dd�}|�� z4| j �
| � � � | j � | � � � | j �
| � � � W 5 |�� X | �|jtjdd�� | �|jtjdd�� | �|jtjd d�� |�� d S )
Nrd )r� rs rf rg T)Zrespect_handler_levelrh rj rl )r Z TestHandlerZMatcherr r4 r/ r$ r rz r( ru rZ rt r� r7 �matchesri re rc r= r+ r� )r8 r� �listenerr: r: r; �test_queue_listener�
s6
�
z$QueueHandlerTest.test_queue_listenerc
C s� t j�| j| j�}|�� z dd W n: tk
r` } z |}| jj| � � |d� W 5 d }~X Y nX |�
� | � | j �
� �� �d�d� d S )NrW r �r Z Traceback)r r4 r/ r$ r. r �ZeroDivisionErrorr( r� rZ rz rI r* rG r rs )r8 r1 r� �excr: r: r; �&test_queue_listener_with_StreamHandler�
s &z7QueueHandlerTest.test_queue_listener_with_StreamHandlerc C sd | j �| j� | j�| j� tj�| j | j �}|�
� | j� d� |� � | �
| j�� �� d� d S )Nrt zque -> ERROR: error)r' r2 r1 r( r6 r. r r4 r/ r$ r rt rz rI r* rG r )r8 r1 r: r: r; �*test_queue_listener_with_multiple_handlers
s z;QueueHandlerTest.test_queue_listener_with_multiple_handlersN)r[ r\ r] rF r< rC r, r. rC �
skipUnlessrD r r4 r2 r6 r7 r: r: r: r; r# �
s"
�
!�
�r# r/ )�patchc @ sl e Zd ZdZdZedd� �Ze�e j
j d�dd� �Z e�e j
j d�dd � �Z
ed
d � �Zd d
� Zdd� ZdS )�QueueListenerTestz~
Tests based on patch submitted for issue #27930. Ensure that
QueueListener handles all log messages.
� c C s� t �d| �}|�t j� t j�| �}|�|� t j�| �}|�� |� d� |� d� |� d� |� d� |� d� |�
� |� |� |� � dS )z�
Creates a logger with a QueueHandler that logs to a queue read by a
QueueListener. Starts the listener, logs five messages, and stops
the listener.
ztest_logger_with_id_%s�one�twoZthreeZfourZfiveN)
r r r+ r, r4 r& r6 r/ r rv rz r> r= )� log_queuerC r� r� r1 r: r: r; �
setup_and_log# s
z QueueListenerTest.setup_and_logr� c C sJ t | j�D ]$}t�� }| �|d| �� |f � q
| �|jd| j d� d S �N�%s_%sr� z&correct number of handled log messages)r �repeatr$ r% r? r_ rI �
call_count�r8 Z mock_handler� r> r: r: r; �#test_handle_called_with_queue_queue; s �z5QueueListenerTest.test_handle_called_with_queue_queuec C sb t �� t| j�D ]4}t�� }| �|d| �� |f � |�� |� � q| �
|j d| j d� d S r@ ) r �*skip_if_broken_multiprocessing_synchronizer rB �multiprocessingr% r? r_ r= rw rI rC rD r: r: r; � test_handle_called_with_mp_queueC s
�z2QueueListenerTest.test_handle_called_with_mp_queuec c s0 z| � � V qW n tjk
r* g Y S X d S r� )r* r$ r) )r> r: r: r; �get_all_from_queueP s z$QueueListenerTest.get_all_from_queuec C s� t �� t| j�D ]n}t�� }| �|d| �� |f � t| � |��}|�
� |� � g t j
jjgg}| �||ddd� |D � � qdS )a
Five messages are logged then the QueueListener is stopped. This
test then gets everything off the queue. Failure of this test
indicates that messages were not registered on the queue until
_after_ the QueueListener stopped.
rA z&Found unexpected messages in queue: %sc S s" g | ]}t |tj�r|jn|�qS r: )r r r+ r� )r� rx r: r: r; r� m s �zJQueueListenerTest.test_no_messages_in_queue_after_stop.<locals>.<listcomp>N)r rF r rB rG r% r? r_ �listrI r= rw r r4 r/ � _sentinelrT )r8 r� r$ r� rS r: r: r; �$test_no_messages_in_queue_after_stopX s ���z6QueueListenerTest.test_no_messages_in_queue_after_stopc C sF t �� }tj�|�}|�� |�� | �t�� |� � W 5 Q R X d S r� )
r$ r% r r4 r/ r rz r� r� � task_done)r8 r> r1 r: r: r; � test_calls_task_done_after_stopp s z1QueueListenerTest.test_calls_task_done_after_stopN)r[ r\ r] r^ rB � staticmethodr? r9 r r r4 r/ rE rH rI rL rN r: r: r: r; r: s
r: c @ s e Zd Zdd� ZeZdd� ZdS )�UTCc C s t S r� )�ZERO�r8 �dtr: r: r; � utcoffset~ s z
UTC.utcoffsetc C s dS )NrP r: rR r: r: r; �tzname� s z
UTC.tznameN)r[ r\ r] rT �dstrU r: r: r: r; rP } s rP c @ sV e Zd Zdd� Zddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dS )�
FormatterTestc C s0 dt jtj�ddd�dd d ddd�| _i | _d S ) Nzformatter.testr� �toz dummy.extr| zMessage with %d %s)r� Z placeholders)r9 rO �pathname�linenor �funcr� r
)r r, r� r� r� �common�variantsrY r: r: r; r< � s �
zFormatterTest.setUpNc C s, t | j�}|d k r"|�| j| � t�|�S r� )r r\ r@ r] r r� )r8 r9 �resultr: r: r; �
get_record� s
zFormatterTest.get_recordc
O sL z| j |f|�|� W n0 |k
rF } z| �||j� W 5 d }~X Y nX d S r� )r� rI rs )r8 r� rs r
r� r� r: r: r; �assert_error_message� s z"FormatterTest.assert_error_messagec C s� | � � }t�d�}| �|�|�d� t�d�}| �t|j|� | �|�� � t�d�}| � |�� � t�d�}| � |�� � t�d�}| � |�� � d S )Nz${%(message)s}z ${Message with 2 placeholders}z
%(random)s� %(asctime)sz%(asctime)-15sz%(asctime)#15s�
r_ r r/ rI r� r� r� r� �usesTimer7 �r8 r� r� r: r: r; � test_percent� s
zFormatterTest.test_percentc C s� | � � }tjddd�}| �|�|�d� tjddd�}| �t|j|� tjddd�}| �|�� � tjddd�}| � |�� � tjddd�}| � |�� � tjd dd�}| � |�� � d S )
Nz
$%{message}%$�{�r� � $%Message with 2 placeholders%$z{random}z {message}� {asctime}z{asctime!s:15}z {asctime:15}rb rd r: r: r; � test_braces� s zFormatterTest.test_bracesc C s | � � }tjddd�}| �|�|�d� tjddd�}| �|�|�d� tjddd�}| �|�|�d� tjddd�}| �t|j|� | �|�� � tjd dd�}| � |�� � tjd
dd�}| � |�� � tjddd�}| �|�� � tjd dd�}| � |�� � d S ) N�
${message}r� rg zMessage with 2 placeholdersz$messagez$$%${message}%$$rh z ${random}z
${asctime}z$asctimez ${asctime}--rb rd r: r: r; � test_dollars� s$ zFormatterTest.test_dollarsc C s t �d�}| �|jd� t �d�}| �|jd� t �d�}| �|jd� t �d�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jd dd�}| �|jd � t jd
dd�}| �|jd
� t jd dd�}| �|jd � t jd dd�}| �|jd � t jd
dd�}| �|jd
� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� t jddd�}| �|jd� | �tt jd� | �tt jd� | �tt jd� | �tt jd � | �tt jd � | �tt jd � | �tt jd � | �tt jd � | �tt jd!� | jtd"t jd#dd� | jtd$t jd%dd� | �td&� | jtt jd'dd� | jtd(t jd)dd� | jtd*t jd+dd� | jtt jd,dd� | jtt jd-dd� | jtt jd.dd� | jtt jd/dd� | jtd0t jd1dd� | jtd0t jd2dd� | jtt jd3dd� | jtt jd4dd� | jtt jd5dd� | jtt jd6dd� | jtt jd7dd� | jtt jd8dd� | jtt jd9dd� | jtt jd:dd� | jtt jd;dd� | jtd<t jd=dd� | jtd<t jd>dd� | jtd<t jd?dd� | jtd$t jd dd� | jtt jd%dd� | jtd$t jd@dd� | jtt jdAdd� d S )BNzM%(levelname)-15s - %(message) 5s - %(process)03d - %(module) - %(asctime)*.3sz1%(asctime)*s - %(asctime)*.3s - %(process)-34.33oz%(process)#+027.23Xz
%(foo)#.*gz5$%{message}%$ - {asctime!a:15} - {customfield['key']}rf rg z {process:.2f} - {custom.f:.4f}z{customfield!s:#<30}z {message!r}z {message!s}z {message!a}z{process!r:4.2}z8{process!s:<#30,.12f}- {custom:=+#30,.1d} - {module:^30}z{process!s:{w},.{p}}z {foo:12.{p}}z {foo:{w}.6}z{foo[0].bar[1].baz}z{foo[k1].bar[k2].baz}z{12[k1].bar[k2].baz}z${asctime} - $messager� z$bar $$z $bar $$$$z %(asctime)Zz %(asctime)bz %(asctime)*z
%(asctime)*3sz %(asctime)_ri rk z
%(foo)#12.3*fz %(foo)0*.8*fz+invalid field name/expression: 'name-thing'z {name-thing}zinvalid format: no fieldsra zinvalid conversion: 'Z'z{asctime!s:#30,15f}z7invalid format: expected ':' after conversion specifierz{asctime!aa:15}zbad specifier: '.2ff'z{process:.2ff}z
{process:.2Z}z{process!s:<##30,12g}z{process!s:<#30#,12g}z{process!s:{{w}},{{p}}}z,invalid format: unmatched '{' in format specz{processzprocess}z {{foo!r:4.2}z
{{foo!r:4.2}}z {foo/bar}z{foo:{{w}}.{{p}}}}z{foo!X:{{w}}.{{p}}}z{foo!a:random}z{foo!a:ran{dom}z{foo!a:ran{d}om}z
{foo.!a:d}z$invalid format: bare '$' not allowedz$bar $$$zbar $zfoo $.rO z ${asctime)r r/ rI �_fmtr� r� r` �r8 r� r: r: r; �test_format_validate� s(
� �� � � � � � � � � �z"FormatterTest.test_format_validatec C s | � ttjd d d� d S )N�x)r� r� r r/ rY r: r: r; �test_invalid_stylem s z FormatterTest.test_invalid_stylec
C s� | � � }t�dddddddt�}t�|�d ��� �|_d|_t �
d�}tj |_ | �
|�|�d � | �
|�|d
�d � |�|� | �
|jd � d S ) Ni� r
� � r� r �{ �%(asctime)s %(message)sz1993-04-21 08:03:00,123z%Y:%dz1993:21)r_ �datetime�utcr �mktimeZ
astimezoneZ timetuple�created�msecsr r/ �gmtime� converterrI �
formatTimer� �asctime)r8 r� rS r� r: r: r; � test_timep s
zFormatterTest.test_time)N) r[ r\ r] r< r_ r` re rj rl ro rq r r: r: r: r; rW � s
rW c @ s e Zd Zdd� Zdd� ZdS )�TestBufferingFormatterc C s dt |� S )Nz[(%d)�rJ �r8 �recordsr: r: r; � formatHeader s z#TestBufferingFormatter.formatHeaderc C s dt |� S )Nz(%d)]r� r� r: r: r; � formatFooter� s z#TestBufferingFormatter.formatFooterN)r[ r\ r] r� r� r: r: r: r; r� ~ s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�BufferingFormatterTestc C s" t �ddi�t �ddi�g| _d S )Nr� r< r= )r r� r� rY r: r: r; r< � s �z BufferingFormatterTest.setUpc C s2 t �� }| �d|�g �� | �d|�| j�� d S )Nr Zonetwo)r �BufferingFormatterrI r� r� rn r: r: r; � test_default� s z#BufferingFormatterTest.test_defaultc C sD t � }| �d|�| j�� t�d�}t |�}| �d|�| j�� d S )Nz[(2)onetwo(2)]z
<%(message)s>z[(2)<one><two>(2)])r� rI r� r� r r/ )r8 r� Zlfr: r: r; � test_custom� s
z"BufferingFormatterTest.test_customN)r[ r\ r] r< r� r� r: r: r: r; r� � s r� c @ s e Zd Zdd� ZdS )�
ExceptionTestc C s� | j }t� }|�|� z td��W n tjddd� Y nX |�|� |�� |jd }| � |j
� d�� | � |j
� d�� | � |j
� d�� | � |j
� d �� d S )
NrF ZfailedT��
stack_infor z#Traceback (most recent call last):
z!
RuntimeError: deliberate mistake� Stack (most recent call last):
z,logging.exception('failed', stack_info=True))r% �RecordingHandlerr6 rG r r� r> r= r� r7 �exc_textr� r� r� )r8 r� rB r: r: r; r. � s
z ExceptionTest.test_formattingN)r[ r\ r] r. r: r: r: r; r� � s r� c @ s e Zd Zdd� ZdS )�LastResortTestc C s, | j }|�| j� tj}tj}z�t�� �:}|� d� | �
|� � d� |� d� | �
|� � d� W 5 Q R X d t_t�� �$}|� d� d}| �
|� � |� W 5 Q R X t�� � }|� d� | �
|� � d� W 5 Q R X d|j
_dt_t�� � }|� d� | �
|� � d� W 5 Q R X W 5 |�| j� |t_|t_X d S )NzThis should not appearr z
Final chance!zFinal chance!
z-No handlers could be found for logger "root"
F)r% r> r. r �
lastResortrQ r6 r rS rw rI rG ru r �emittedNoHandlerWarning)r8 r Zold_lastresortZold_raise_exceptionsrU r� r: r: r; �test_last_resort� s4
z LastResortTest.test_last_resortN)r[ r\ r] r� r: r: r: r; r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� FakeHandlerc C s$ dD ]}t | || �|||�� qd S )N)r* �flushr= r+ )�setattr� record_call)r8 �
identifier�calledr r: r: r; r% � s zFakeHandler.__init__c s � ��fdd�}|S )Nc s � � d����� d S )Nz{} - {})r� r� r: �r� r� � method_namer: r; �inner� s z&FakeHandler.record_call.<locals>.innerr: )r8 r� r� r� r� r: r� r; r� � s zFakeHandler.record_callN)r[ r\ r] r% r� r: r: r: r; r� � s r� c s$ e Zd Z� fdd�Zdd� Z� ZS )r� c s t t| �j||� g | _d S r� )r$ r� r% r� )r8 r
r� r( r: r; r% � s zRecordingHandler.__init__c C s | j �|� dS )z&Keep track of all the emitted records.N)r� r� r� r: r: r; r� � s zRecordingHandler.handle)r[ r\ r] r% r� r- r: r: r( r; r� � s r� c s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Z� ZS )"� ShutdownTestz#Test suite for the shutdown method.c s. t t| ��� g | _tj}| �ttd|� d S )NrQ )r$ r� r< r� r rQ r� r� )r8 Zraise_exceptionsr( r: r; r< � s zShutdownTest.setUpc s � fdd�}|S )Nc s
� � �d S r� r: r: �rt r: r; r� � s z'ShutdownTest.raise_error.<locals>.innerr: )r8 rt r� r: r� r; � raise_error� s zShutdownTest.raise_errorc C sv t d| j�}t d| j�}t d| j�}ttjj|||g�}tjt|�d� ddddd d
d d d
dddg }| �|| j� d S )Nr rW r� �� handlerListz 2 - acquirez 2 - flushz 2 - closez 2 - releasez 1 - acquirez 1 - flushz 1 - closez 1 - releasez 0 - acquirez 0 - flushz 0 - close� 0 - release) r� r� r^ r r` ra r} rJ rI )r8 Zhandler0Zhandler1Zhandler2r4 rS r: r: r; �test_no_failure� s �z ShutdownTest.test_no_failurec C sR t d| j�}t||| �|�� tj�|�g}tjt|�d� | � d| jd � d S )Nr r� r� r� )
r� r� r� r� r r` ra r} rJ rI )r8 r rt r� r4 r: r: r; � _test_with_failure_in_method s
z)ShutdownTest._test_with_failure_in_methodc C s | � dt� d S �Nr* �r� r� rY r: r: r; � test_with_ioerror_in_acquire s z)ShutdownTest.test_with_ioerror_in_acquirec C s | � dt� d S �Nr� r� rY r: r: r; �test_with_ioerror_in_flush s z'ShutdownTest.test_with_ioerror_in_flushc C s | � dt� d S �Nr= r� rY r: r: r; �test_with_ioerror_in_close s z'ShutdownTest.test_with_ioerror_in_closec C s | � dt� d S r� �r� r� rY r: r: r; � test_with_valueerror_in_acquire s z,ShutdownTest.test_with_valueerror_in_acquirec C s | � dt� d S r� r� rY r: r: r; � test_with_valueerror_in_flush! s z*ShutdownTest.test_with_valueerror_in_flushc C s | � dt� d S r� r� rY r: r: r; � test_with_valueerror_in_close$ s z*ShutdownTest.test_with_valueerror_in_closec C s dt _| �dt� d S )NFr* �r rQ r� �
IndexErrorrY r: r: r; �.test_with_other_error_in_acquire_without_raise' s z;ShutdownTest.test_with_other_error_in_acquire_without_raisec C s dt _| �dt� d S )NFr� r� rY r: r: r; �,test_with_other_error_in_flush_without_raise+ s z9ShutdownTest.test_with_other_error_in_flush_without_raisec C s dt _| �dt� d S )NFr= r� rY r: r: r; �,test_with_other_error_in_close_without_raise/ s z9ShutdownTest.test_with_other_error_in_close_without_raisec C s dt _| �t| jdt� d S )NTr* �r rQ r� r� r� rY r: r: r; �+test_with_other_error_in_acquire_with_raise3 s
�z8ShutdownTest.test_with_other_error_in_acquire_with_raisec C s dt _| �t| jdt� d S )NTr� r� rY r: r: r; �)test_with_other_error_in_flush_with_raise8 s
�z6ShutdownTest.test_with_other_error_in_flush_with_raisec C s dt _| �t| jdt� d S )NTr= r� rY r: r: r; �)test_with_other_error_in_close_with_raise= s
�z6ShutdownTest.test_with_other_error_in_close_with_raise)r[ r\ r] r^ r< r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r- r: r: r( r; r� � s" r� c @ sx e Zd ZdZdd� Zddd�Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
ejdd� �Zdd� ZdS ) �ModuleLevelMiscTestz)Test suite for some module level methods.c C s� t jjj}| �|d� | �t j|� t �d� | �t jjjd� | �tt jd� G dd� d�}| �tt j|� � t �d� t �� | �t jjjt j � d S )Nr �S Z
doesnotexistsc @ s e Zd ZdS )z;ModuleLevelMiscTest.test_disable.<locals>._NotAnIntOrStringNr� r: r: r: r; �_NotAnIntOrStringR s r� �WARN)
r r r rA rI r� r� r� r rc )r8 � old_disabler� r: r: r; � test_disableG s
z ModuleLevelMiscTest.test_disableNc s� g � t �| td� fdd�� t� }tj�|� tt|�}|d k rN||d|� n
|d|� | �t|j �d� |j d }| �|�
� d| � |d k r�|n tt|� � �}| �|j |� | �� g � d S )N� basicConfigc s � � | |f�S r� r )r �kw�r� r: r; �<lambda>a � z/ModuleLevelMiscTest._test_log.<locals>.<lambda>z test me: %rrW r )
r r9 r r� r r6 r" rI rJ r� �
getMessage�upperr� )r8 r rO � recording�
log_methodr� Zexpected_levelr: r� r; � _test_log^ s
�
z ModuleLevelMiscTest._test_logc C s | � dtj� d S �Nrs )r� r re rY r: r: r; �test_logv s z ModuleLevelMiscTest.test_logc C s | � d� d S �Nrw �r� rY r: r: r; �
test_debugy s z ModuleLevelMiscTest.test_debugc C s | � d� d S �Nrv r� rY r: r: r; � test_info| s z ModuleLevelMiscTest.test_infoc C s | � d� d S �Nru r� rY r: r: r; � test_warning s z ModuleLevelMiscTest.test_warningc C s | � d� d S �Nrt r� rY r: r: r; �
test_error� s z ModuleLevelMiscTest.test_errorc C s | � d� d S �Nr� r� rY r: r: r; �
test_critical� s z!ModuleLevelMiscTest.test_criticalc C s^ | � ttjt� G dd� dtj�}t�|� | �t�� |� t�tj� | �t�� tj� d S )Nc @ s e Zd ZdS )z;ModuleLevelMiscTest.test_set_logger_class.<locals>.MyLoggerNr� r: r: r: r; r � s r )r� r r r r r rI �getLoggerClass)r8 r r: r: r; �test_set_logger_class� s
z)ModuleLevelMiscTest.test_set_logger_classc s� g � G � fdd�dt �� �}t �|� t �d�}| �� dg� t�� }t �|�}|�|� zh|� t j
� |�d� | �|�� �� d� |�d� |�d� |� t j� |�d� | �|�� d� W 5 |� |� |�
� t �t j � X d S )Nc s& e Zd Zdejf� �fdd� Z� ZS )z@ModuleLevelMiscTest.test_subclass_logger_cache.<locals>.MyLoggerr c s t � �||� ��d� d S )N� initialized)r$ r% r� )r8 r9 rO )r) rs r: r; r% � s zIModuleLevelMiscTest.test_subclass_logger_cache.<locals>.MyLogger.__init__)r[ r\ r] r r� r% r- r: �rs r( r; r � s r Zjust_some_loggerr� Zhellor r )r r� r r rI r( r) r- r6 r> r= r r+ r, rw rG r �truncater� rk )r8 r r� r* rB r: r� r; �test_subclass_logger_cache� s(
z.ModuleLevelMiscTest.test_subclass_logger_cachec C s8 d}t d|�\}}}|�� }| �d|� | �d|� d S )Na& if 1:
import logging
class A:
def __del__(self):
try:
raise ValueError("some error")
except Exception:
logging.exception("exception in __del__")
a = A()�-czexception in __del__zValueError: some error)r rY rT �r8 �code�rc�out�errr: r: r; �test_logging_at_shutdown� s
z,ModuleLevelMiscTest.test_logging_at_shutdownc C s8 d}t d|�\}}}|�� }| �d|� | �|d� d S )Nz�if 1:
import logging
def rec():
logging.error("foo")
rec()
rec()r� z#Cannot recover from stack overflow.rW )r rY Z assertNotInrI r� r: r: r; �test_recursion_error� s
z(ModuleLevelMiscTest.test_recursion_error)N)r[ r\ r] r^ r� r� r� r� r� r� r� r� r� r� r Zrequires_type_collectingr� r� r: r: r: r; r� C s
r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
LogRecordTestc C s6 t �i �}t|�}| �|�d�� | �|�d�� d S )Nz <LogRecord: �>)r r� r� r7 r� r� )r8 r� rU r: r: r; � test_str_rep� s
zLogRecordTest.test_str_repc C sj t � }t�� }|�|� ddi}t�d|� | �|jd j|� | �|jd j d� |�
|� |� � d S )NZlessZmorezless is %(less)sr z less is more) r� r r r6 ru rR r� r
rI rs r> r= )r8 rB r� r\ r: r: r; �
test_dict_arg� s
zLogRecordTest.test_dict_argc C s\ t �i �}| �|jd� z*dd l}t �i �}| �|j|�� j� W n tk
rV Y nX d S )N� MainProcessr )r r� rI � processNamerG �current_processr9 rV )r8 r� �mpr: r: r; �test_multiprocessing� s
z"LogRecordTest.test_multiprocessingc C s� t �i �}| j}||j� ||j� ||j� ||j� t j}t j}t j }zNdt _dt _dt _ t �i �}| j
}||j� ||j� ||j� ||j� W 5 |t _|t _|t _ X d S )NF) r r� �assertIsNotNoner� �
threadName�processr� �
logThreads� logProcesses�logMultiprocessingrX )r8 r� ZNOT_NONEZ log_threadsZ
log_processesZlog_multiprocessing�NONEr: r: r; �
test_optional� s,
zLogRecordTest.test_optionalN)r[ r\ r] r� r� r� r� r: r: r: r; r� � s
r� c s� e Zd ZdZ� fdd�Z� fdd�Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd1d#d$�Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z� ZS )2�BasicConfigTestz#Test suite for logging.basicConfig.c sV t t| ��� tjj| _tj�� | _tj d d � | _
tjj | _ | �
| j� g tj_d S r� )r$ r� r< r r r4 r r r r r rO r' r� r� rY r( r: r; r< s
zBasicConfigTest.setUpc s< t jjd d � D ]}t j�|� |�� qtt| ��� d S r� )r r r4 r> r= r$ r� rC r� r( r: r; rC s
zBasicConfigTest.tearDownc C sJ t tjd| j� tj�� tj�| j� | jtj d d �< tj�
| j � d S )Nr4 ) r� r r r4 r r? r@ r r r r+ r' rY r: r: r; r� s
zBasicConfigTest.cleanupc C s� t �� | �tt jj�d� t jjd }| �|t j� | �|jt j
� |j }| �|j j
t j� | �|j� | �|j t j� | �t jj| j� d S )NrW r )r r� rI rJ r r4 r� r- r* r� rU r� r� rm � BASIC_FORMATrX r � PercentStylerO r' )r8 r� r� r: r: r; �test_no_kwargs% s z BasicConfigTest.test_no_kwargsc C sR t �� �@}tjtjdd� t�d� tj�d� | �|� � �
� d� W 5 Q R X d S )Nrf �r* r� � Log an errorr �ERROR:root:Log an error� r r� r r� r� r� rt r� rI rG r r� r: r: r; �test_strformatstyle9 s
�z#BasicConfigTest.test_strformatstylec C sR t �� �@}tjtjdd� t�d� tj�d� | �|� � �
� d� W 5 Q R X d S )Nr� r� r� r r� r� r� r: r: r; �test_stringtemplatestyleA s
�z(BasicConfigTest.test_stringtemplatestylec C s� dd� }t jdd� | �tt jj�d� t jjd }| �|t j� t �dd�}| �|jj |jj � | �|jj
|jj
� | � |||d� d S )Nc S s | � � |� � t�|� d S r� r� �r� Zh2r� r: r: r; r� K s z.BasicConfigTest.test_filename.<locals>.cleanup�test.log)r� rW r r ) r r� rI rJ r r4 r� r r* �moder9 r� �r8 r� r� rS r: r: r; �
test_filenameI s z BasicConfigTest.test_filenamec C sV dd� }t jddd� t jjd }t �dd�}| �|jj|jj� | �|||d� d S )Nc S s | � � |� � t�|� d S r� r� r� r: r: r; r� ] s z.BasicConfigTest.test_filemode.<locals>.cleanupr �wb�r� �filemoder ) r r� r r4 r rI r* r r� r r: r: r; �
test_filemode[ s z BasicConfigTest.test_filemodec C s` t �� }| �|j� tj|d� | �ttjj �d� tjj d }| �
|tj � | �|j |� d S )Nr# rW r )
r( r) r� r= r r� rI rJ r r4 r� r- r* )r8 r* r� r: r: r; � test_streami s zBasicConfigTest.test_streamc C s. t jdd� t jjd j}| �|jjd� d S )Nz%(asctime)s - %(message)s)r� r )r r� r r4 r� rI r� rm �r8 r� r: r: r; � test_formats s zBasicConfigTest.test_formatc C s, t jdd� t jjd j}| �|jd� d S )NrP )r r )r r� r r4 r� rI r r r: r: r; � test_datefmty s z BasicConfigTest.test_datefmtc C s. t jdd� t jjd j}| �|jt j� d S )Nr� rg r )r r� r r4 r� r� r� r� r r: r: r; �
test_style s zBasicConfigTest.test_stylec C sT t jj}| �t jj|� t jdd� | �t jjd� t jdd� | �t jjd� d S )N�9 )rO �: )r r rO r� r+ r� rI )r8 � old_levelr: r: r; �
test_level� s zBasicConfigTest.test_levelc C sp | j }t�� g}tj}|ttjd|d� |ttjd|d� |ttj||d� |ttjtjd� tjd dd� d S )Nr )r� r* )r� r4 )r* r4 )Zloglevelr r )r� r r- r� rU r� r� rk )r8 r� r4 r* r: r: r; �test_incompatible� s
�
�
�z!BasicConfigTest.test_incompatiblec C s� t �� t �tj�t �� g}t �� }|d �|� t j|d� | �|d t jj d � | �|d t jj d � | �|d t jj d � | �
|d j � | �
|d j � | �|d j |� | �|d j |d j � d S )Nr� )r4 r rW ) r r- r� r� r/ r2 r� rR r r4 r� r� )r8 r4 r� r: r: r; �
test_handlers� s
� z BasicConfigTest.test_handlersc C s� t �� }t �� }t�|�g}t�|�g}tjtj|d� t�d� t�d� t�d� | � t
tj j �d� tjtj
|dd� t�d� t�d� t�d� | � t
tj j �d� | � |�� �� d� | � |�� �� d � d S )
Nr� r� rv rw rW T)rO r4 �forcezWARNING:root:warnz WARNING:root:warn
INFO:root:info)r( r) r r- r� ri ru rv rw rI rJ r r4 rk rG r )r8 Z
old_string_ioZ
new_string_ioZ old_handlersZ new_handlersr: r: r; �
test_force� s,
�
��zBasicConfigTest.test_forceNc sf g � t j�� ��fdd�}t��t d|� tt |�}|d k rH||d� n|d� ��� di fg� d S )Nc s< �� t jj}t j�d� ��t jj|� � �| |f� d S )N�d )r r rO r+ r� r� )r r� r �r� Zold_basic_configr8 r: r; �my_basic_config� s
z2BasicConfigTest._test_log.<locals>.my_basic_configr� ztest mer: )r r� r r9 r" rI )r8 r rO r r� r: r r; r� � s
zBasicConfigTest._test_logc C s | � dtj� d S r� )r� r ri rY r: r: r; r� � s zBasicConfigTest.test_logc C s | � d� d S r� r� rY r: r: r; r� � s zBasicConfigTest.test_debugc C s | � d� d S r� r� rY r: r: r; r� � s zBasicConfigTest.test_infoc C s | � d� d S r� r� rY r: r: r; r� � s z BasicConfigTest.test_warningc C s | � d� d S r� r� rY r: r: r; r� � s zBasicConfigTest.test_errorc C s | � d� d S r� r� rY r: r: r; r� � s z BasicConfigTest.test_critical)N) r[ r\ r] r^ r< rC r� r� r� r� r r r r
r r r r r r r� r� r� r� r� r� r� r- r: r: r( r; r� s0
r� c sL e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )�LoggerAdapterTestc s� t t| ��� tjd d � � t� | _tj| _| j� | j� | �
| jj | j� | �
| jj � � fdd�}| �
|� | �
tj
� tj| jd d�| _d S )Nc s � t jd d �< d S r� )r r r: �Zold_handler_listr: r; r� � s z(LoggerAdapterTest.setUp.<locals>.cleanup�r� r )r$ r r< r r r� r� r r� r6 r� r> r= r} rr �adapter)r8 r� r( r r; r< � s
zLoggerAdapterTest.setUpc
C s� d}d }z dd W n6 t k
rJ } z|}| j�|| j� W 5 d }~X Y nX | �t| jj�d� | jjd }| �|jtj � | �|j
|� | �|j | jf� | �|j |j
||jf� d S �Nztesting exception: %rrW r )r4 r r� r� rI rJ r� r� r re r� r
r r) �
__traceback__�r8 r� r5 r� r� r: r: r; �test_exception s " �z LoggerAdapterTest.test_exceptionc
C s� z dd W n& t k
r2 } z|}W 5 d }~X Y nX | jjd|d� | �t| jj�d� | jjd }| �|j|j||j f� d S )NrW r z
exc_info testr3 )
r4 r r� rI rJ r� r� r r) r )r8 r� r5 r� r: r: r; �test_exception_excinfo s �z(LoggerAdapterTest.test_exception_excinfoc C sh d}| j �|| j� | �t| jj�d� | jjd }| �|jtj� | �|j |� | �|j
| jf� d S )Nzcritical test! %rrW r ) r r� r� rI rJ r� r� r rc r� r
)r8 r� r� r: r: r; r� s z LoggerAdapterTest.test_criticalc C sD | j jjj}d| j jj_| �t| j jjd|� | �| j �d�� d S )N�! rA � )r r� r rA r� r� r� � isEnabledFor�r8 r� r: r: r; �test_is_enabled_for( s �z%LoggerAdapterTest.test_is_enabled_forc C sN | � | j�� � | jjD ]}| j�|� q| �| j�� � | �| j�� � d S r� )r7 r r3 r� r4 r> r� r� r: r: r; �test_has_handlers/ s
z#LoggerAdapterTest.test_has_handlersc C sL G dd� dt j�}d}|| jd d�}||d d�}d|_| �t|�t|�� |�t j|| j� | �t | jj
�d� | jj
d }| �|j t j� | �|j d|� �� | �|j
| jf� |j}| �|j|� | �| jj|� t� }z6||_| �|j|� | �|j|� | �| jj|� W 5 ||_X | �|j|� | �|j|� | �| jj|� d S ) Nc @ s e Zd ZdZdd� ZdS )z.LoggerAdapterTest.test_nested.<locals>.Adapter�Adapterc S s | j � d|� �|fS r� )r� )r8 r� r� r: r: r; r� < s z6LoggerAdapterTest.test_nested.<locals>.Adapter.processN)r[ r\ r] r� r� r: r: r: r; r' 9 s r' zAdapters can be nested, yo.r ZAdapterAdapterrW r zAdapter AdapterAdapter )r rr r� r� rI r[ rs rc r� rJ r� r� r� r
r rR r )r8 r' r� r Zadapter_adapterr� Z orig_managerZ temp_managerr: r: r; � test_nested8 s2 z LoggerAdapterTest.test_nested) r[ r\ r] r< r r r� r% r& r( r- r: r: r( r; r � s
r c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Z� ZS )#�
LoggerTestc sb t t| ��� t� | _tjdd�| _| j�| j� | � | jj
| j� | � | jj � | � tj � d S )NZblah�r9 )
r$ r) r< r� r� r r r� r6 r� r> r= r} rY r( r: r; r< \ s zLoggerTest.setUpc C s | � t| jjt� � d S r� )r� r r� r+ r rY r: r: r; �test_set_invalid_levele s z!LoggerTest.test_set_invalid_levelc
C s� d}d }z dd W n6 t k
rJ } z|}| j�|| j� W 5 d }~X Y nX | �t| jj�d� | jjd }| �|jtj � | �|j
|� | �|j | jf� | �|j |j
||jf� d S r )r4 r� r� r� rI rJ r� r� r re r� r
r r) r r r: r: r; r h s " �zLoggerTest.test_exceptionc C s2 t �tdd�� | �t| jjdd� W 5 Q R X d S )NrQ Trp � test message)r � swap_attrr r� r r� rs rY r: r: r; �!test_log_invalid_level_with_raisey s z,LoggerTest.test_log_invalid_level_with_raisec C s, t �tdd�� | j�dd� W 5 Q R X d S )NrQ Frp r, )r r- r r� rs rY r: r: r; � test_log_invalid_level_no_raise} s z*LoggerTest.test_log_invalid_level_no_raisec sP g � t �| tjd� fdd�� | jjdd� | �t� �d� | �d� d � d S ) N� print_stackc s � � |�� �S r� )r� rG )r� r� r� r: r; r� � r� z=LoggerTest.test_find_caller_with_stack_info.<locals>.<lambda>Tr� rW r� r )r r9 r � tracebackr� �
findCallerrI rJ rY r: r� r; � test_find_caller_with_stack_info� s
�z+LoggerTest.test_find_caller_with_stack_infoc s d���fdd���fdd�� � fdd�}�j j}|� ��|d jd � |d j}�d7 �|� ��|d jd
� ��|d j|� |d j}�d7 �|� ��|d jd � ��|d j|� |d j}�d7 �|� ��|d jd � ��|d j|� d S )
NrW c s � j jd�d� d S )Nri )�
stacklevel)r� ru r: )r8 � the_levelr: r; � innermost� s z>LoggerTest.test_find_caller_with_stacklevel.<locals>.innermostc s
� � d S r� r: r: )r6 r: r; r� � s z:LoggerTest.test_find_caller_with_stacklevel.<locals>.innerc s
� � d S r� r: r: )r� r: r; �outer� s z:LoggerTest.test_find_caller_with_stacklevel.<locals>.outerr� r6 r� r7 � test_find_caller_with_stacklevel)r� r� rI rT rZ r7 )r8 r7 r� rZ r: )r� r6 r8 r5 r; r8 � s,
z+LoggerTest.test_find_caller_with_stacklevelc
C s� d}d}d } } } } } }} t �||||||||| � }
dt|
j�� � D ]0} | di} | jt| jj|||||||| | d� qPd S )N� my record�
)rs r~ �
some value�r �sinfo) r �_logRecordFactoryrN �__dict__�keysr� r� r� �
makeRecord)
r8 r9 rO r� �lnor� r
r r[ r= �rvrb r r: r: r; �%test_make_record_with_extra_overwrite� s& � �z0LoggerTest.test_make_record_with_extra_overwritec C s\ d}d}d } } } } } }} ddi}
| j j||||||||
| d� } | �d| j� d S )Nr9 r: Z valid_keyr; r< )r� rA rT r? ) r8 r9 rO r� rB r� r
r r[ r= r r^ r: r: r; �(test_make_record_with_extra_no_overwrite� s �z3LoggerTest.test_make_record_with_extra_no_overwritec C s> | � | j�� � | jjD ]}| j�|� q| �| j�� � d S r� )r7 r� r3 r4 r> r� r� r: r: r; r& � s z LoggerTest.test_has_handlersc C s" t �d�}d|_| �|�� � d S )Nz
blah.childF)r r r� r� r3 )r8 Z child_loggerr: r: r; � test_has_handlers_no_propagate� s
z)LoggerTest.test_has_handlers_no_propagatec C s> | j jj}d| j j_| �t| j jd|� | �| j �d�� d S )N� rA � )r� r rA r� r� r� r# r$ r: r: r; r% � s
z LoggerTest.test_is_enabled_forc C s` | j j}| j jj}d| j _d| j j_| �t| j d|� | �t| j jd|� | �| j �d�� d S )NTrr r rA rH )r� r r rA r� r� r� r# )r8 Z old_disabledr� r: r: r; �#test_is_enabled_for_disabled_logger� s
z.LoggerTest.test_is_enabled_for_disabled_loggerc C s� t �� }| �|t j� | �|t �d �� | �|t �d�� | �|t �d�j� | �|t �d�j� | �|t �d�j� | �|t �d�� | �|t �d�j� d S )Nr rO �foo.bar� )r r rR r �parentZ assertIsNot)r8 r r: r: r; �test_root_logger_aliases� s z#LoggerTest.test_root_logger_aliasesc C s$ | � ttjt� | � ttjd� d S )Ns foo)r� r r r �anyrY r: r: r; �test_invalid_names� s z LoggerTest.test_invalid_namesc C sN t tjd �D ]:}dD ]0}t�|�}t�||�}t�|�}| �||� qqd S )NrW )r r rO rJ zbaz.bar)r r* �HIGHEST_PROTOCOLr r r� r+ rR )r8 �protor9 r� rU Z unpickledr: r: r; �
test_pickling� s
zLoggerTest.test_picklingc C s6 | j }t�d�}t�d�}|�tj� | �|�� tj� | �|ji � | �|� tj�� | �
|� tj �� | �|jtjdtj di� | �|ji � | �|� tj�� | �|ji � | �|� tj�� | �|jtjdi� |�tj � | �|�� tj � | �|ji � | �
|� tj�� |�tj
� | �|�� tj � | �|ji � | �|ji � | �|ji � | �
|� tj�� | �|� tj �� | �
|� tj�� | �|� tj �� | �|� tj�� t�� | �|�� tj � | �|ji � | �|ji � | �|ji � | �
|� tj �� | �
|� tj �� | �
|� tj �� d S )Nr r TF)r% r r r+ re rI r& �_cacher7 r# r� r, rc r� rA )r8 r r# r$ r: r: r; � test_caching� sH
zLoggerTest.test_caching)r[ r\ r] r< r+ r r. r/ r3 r8 rD rE r& rF r% rI rM rO rR rT r- r: r: r( r; r) Z s"
r) c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � BaseFileTestz1Base class for handler tests that write log filesc C s0 t �| � t�dd�\}| _t�|� g | _d S )Nr ztest_logging-2-)r
r< r� r� r� r� r= �rmfiles)r8 r� r: r: r; r< 2 s
zBaseFileTest.setUpc C s> | j D ]}t�|� qtj�| j�r0t�| j� t�| � d S r� )rV r� r� r� r� r� r
rC )r8 r� r: r: r; rC 8 s
zBaseFileTest.tearDownc C s* | j tj�|�d| d� | j�|� dS )z7Assert a log file is there and register it for deletionzLog file %r does not existr6 N)r7 r� r� r� rV r� )r8 r� r: r: r; �
assertLogFile? s �zBaseFileTest.assertLogFileN)r[ r\ r] r^ r< rC rW r: r: r: r; rU / s rU c @ s e Zd Zdd� ZdS )�FileHandlerTestc C sx t �| j� tj| jdd�}| �|j� | �t j� | j�� |�
t� i �� | � |j� | �
t j� | j�� |�� d S )NTr� )r� r� r� r r rX r* r� r� r� r� r� r� r7 r= )r8 �fhr: r: r; �
test_delayG s zFileHandlerTest.test_delayN)r[ r\ r] rZ r: r: r: r; rX F s rX c @ sB e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zej d d � �Z
d
S )�RotatingFileHandlerTestc
C s t �dt jdd| �� d d d �S )Nr� r� rW )r r+ r, rZ rY r: r: r; �next_recR s �z RotatingFileHandlerTest.next_recc C s. t jj| jdd�}| �|�d �� |�� d S )Nr ��maxBytes)r r4 r r� r� �shouldRolloverr= �r8 �rhr: r: r; �test_should_not_rolloverV s z0RotatingFileHandlerTest.test_should_not_rolloverc C s2 t jj| jdd�}| �|�| �� �� |�� d S )NrW r] )r r4 r r� r7 r_ r\ r= r` r: r: r; �test_should_rollover\ s z,RotatingFileHandlerTest.test_should_rolloverc C s4 t j�| j�}|�| �� � | �| j� |�� d S r� )r r4 r r� r� r\ rW r= r` r: r: r; �test_file_createda s z)RotatingFileHandlerTest.test_file_createdc C s� dd� }t jj| jddd�}||_|�| �� � | �| j� |�| �� � | �|| jd �� |�| �� � | �|| jd �� | �t j
� || jd ��� |� � d S ) Nc S s | d S )Nz.testr: r* r: r: r; �namerj s z>RotatingFileHandlerTest.test_rollover_filenames.<locals>.namerr� rW �� backupCountr^ �.1�.2�.3)
r r4 r r� re r� r\ rW r� r� r� r� r= )r8 re ra r: r: r; �test_rollover_filenamesi s � z/RotatingFileHandlerTest.test_rollover_filenamesc C s� dd� }dd� }t jj| jddd�}||_||_| �� }|�|� | �| j� | �� }|�|� || jd �}| �|� t j
}t |d ��0}|� � } t
�| �}
| �|
�d
�|j| � W 5 Q R X |�| �� � || jd �}| �|� t |d ��0}|� � } t
�| �}
| �|
�d
�|j| � W 5 Q R X |�| �� � || jd �}t |d ��0}|� � } t
�| �}
| �|
�d
�|j| � W 5 Q R X | �t j�|| jd ��� |�� d S )
Nc S s | d S )Nz.gzr: r* r: r: r; re z s z3RotatingFileHandlerTest.test_rotator.<locals>.namerc
S sX t | d��:}|�� }t�|d�}t |d��}|�|� W 5 Q R X W 5 Q R X t�| � d S )N�rbr� r )r& rP �zlib�compressrJ r� r� )�source�destZsfrI �
compressed�dfr: r: r; �rotator} s z5RotatingFileHandlerTest.test_rotator.<locals>.rotatorr� rW rf rh rl r ri rj )r r4 r r� rs re r\ r� rW r� �linesepr& rP rm �
decompressrI rY r� r� r� r� r= ) r8 re rs ra Zm1Zm2r� �newliner� rq rI r: r: r; � test_rotatorx sH �
"
"
" z$RotatingFileHandlerTest.test_rotatorN) r[ r\ r] r\ rb rc rd rk r Z
requires_zlibrw r: r: r: r; r[ Q s r[ c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
� TimedRotatingFileHandlerTestc
s� t jj| jddd�}t �d�}|�|� t �ddi�}|�|� | �| j� t �
d� t �ddi�}|�|� |� � d }t j �
� }d
}t|�D ]D}|t j|d � } | j| �d � � tj�� �}|r�| j�� � q�q�d
| }
|�s�tj�| j�\} � � fdd�t�| �D �} td|�d� tjd� td| tjd� | D ]B}
td|
� tj�| |
�}t |d��}t|� � � W 5 Q R X �q<| j ||
d� d S )N�SrW )rg ru r� ztesting - initialg�������?ztesting - after delayFi, �Zsecondsz.%Y-%m-%d_%H-%M-%Sz,No rotated files found, went back %d secondsc s g | ]}|� � �r|�qS r: )r� )r� r� �r� r: r; r� � s
z>TimedRotatingFileHandlerTest.test_rollover.<locals>.<listcomp>z
Test time: %sz%Y-%m-%d %H-%M-%S�r� z The only matching files are: %szContents of %s:r� r6 ) r r4 r r� r/ r2 r� r� rW r r r= rv r5 r � timedelta�strftimer� r� r� rV r� r� �listdirr r� rU r� r& rP r7 )r8 rY r� Zr1Zr2�foundr5 �GO_BACK�secs�prevr� Zdn�filesr� r� Ztfr: r{ r; �
test_rollover� sD �
z*TimedRotatingFileHandlerTest.test_rolloverc C sR | j }|ttjj| jddd� |ttjj| jddd� |ttjj| jddd� d S )N�XTr� �WZW7)r� r� r r4 r r� )r8 r� r: r: r; � test_invalid� s
�
�
�z)TimedRotatingFileHandlerTest.test_invalidc C sx d}t �ddd�}tjj| jdddd|d�}z<|�|�}| �||d � |�|d �}| �||d � W 5 |�� X d S )
Nr � �MIDNIGHTrW T��when�intervalrg rw �atTime� �ж i@� ) rv r r r4 r r� r= �computeRolloverrI )r8 � currentTimer� ra rR r: r: r; �"test_compute_rollover_daily_attime� s �
z?TimedRotatingFileHandlerTest.test_compute_rollover_daily_attimec C s2 t t�� �}||d }t�ddd�}t�|�j}td�D ]�}tjj| j d| ddd|d�}z�||krtd| | }n|| }|d9 }|d 7 }||7 }|� |�}||kr�t d
tj
� t d t� � | �||� ||kr�|d 7 }|� |d
�}||k�rt d
tj
� t d t� � | �||� W 5 |�
� X q:d S )N�Q r� r r5 zW%drW Tr� r� zfailed in timezone: %dzlocal vars: %si�: r� )rL r rv r{ �tm_wdayr r r4 r r� r= r� r �timezone�localsrI ) r8 r� Ztodayr� ZwdayZdayra rS rR r: r: r; �#test_compute_rollover_weekly_attime� sB �
z@TimedRotatingFileHandlerTest.test_compute_rollover_weekly_attimeN)r[ r\ r] r� r� r� r� r: r: r: r; rx � s * rx c K s t jf | �t jdd� S )NrW rz )rv r} )r� r: r: r; r� s r� )ry rW )�M�< )�Hi )�Dr� )r� r� ZW0r
� )ZdaysZhoursc C sR t jj| j|dddd�}d}|�|�}||k�r:|dk�r:z�|jrNt�|�}n
t�|�}|d }|d }|d } t jj |d
| d
| }
||
} t
d ||jf t j d � t
d
| t j d � t
d| t j d � t
d| t j d � t
d|
t j d � t
d| t j d � W n0 t
k
�r8 t
dt �� d t j d � Y nX | �||� |�� d S )NrW r T)r� r� rg rw g r� r� r
r� r� z
t: %s (%s)r| zcurrentHour: %szcurrentMinute: %szcurrentSecond: %szr: %sz
result: %sz exception in diagnostic code: %s)r r4 r r� r� rw r r{ � localtimeZ _MIDNIGHTr r� rU r r rI r= ) r8 r� �expra r� rR rr Z currentHourZ
currentMinuteZ
currentSecondr� r^ r: r: r; �test_compute_rollover sH �
��� r� ztest_compute_rollover_%sz>win32evtlog/win32evtlogutil/pywintypes required for this test.c @ s e Zd Zdd� ZdS )�NTEventLogHandlerTestc
C s d}t �d |�}t �|�}ztj�d�}W n: tjk
rd } z|jdkrRt �
d��� W 5 d }~X Y nX t� ddi�}|� |� |�
� | �|t �|�� t jt jB }d}d} t �||| �}
|
D ].}|jdkr�q�t�||�} | d kr�q�d
} q�q�d | } | j|| d � d S )
NZ ApplicationZ test_loggingr� z#Insufficient privileges to run testr� zTest Log MessageFr zTest Log Message
Tz3Record not found in event log, went back %d recordsr6 )� win32evtlogZ OpenEventLogZGetNumberOfEventLogRecordsr r4 ZNTEventLogHandler�
pywintypesrt �winerrorrC ZSkipTestr� r� r= Z
assertLessZEVENTLOG_BACKWARDS_READZEVENTLOG_SEQUENTIAL_READZ ReadEventLogZ
SourceName�win32evtlogutilZSafeFormatMessager7 ) r8 ZlogtypeZelhZnum_recsrB r� r� �flagsr� r� �eventsr� r: r: r; r� D s:
�
z NTEventLogHandlerTest.test_basicN)r[ r\ r] r� r: r: r: r; r� B s r� c @ s e Zd Zdd� ZdS )� MiscTestCasec
C s2 ddddddddd d
d d d
h
}t j| t|d� d S )Nr� r� r� � currentframer� �StrFormatStyler� �Filterer� PlaceHolderr
�
RootLoggerr r )� blacklist)r Z check__all__r )r8 r� r: r: r; � test__all__g s �zMiscTestCase.test__all__N)r[ r\ r] r� r: r: r: r; r� f s r� �LC_ALLr c ' C sv t ttttttttt t
t t t
ttttttttttttttt t t t t t!t"t#t$t%t&g'} t't(j)d�rh| �*t+� t,j-| � d S )Nr/ ).r_ r� r� r� r� r� r r9 r] rh rv r� r rW r� rP r r r# r� r� r� r r) r� rX r[ r� r� r� r@ rE rH r� rx r8 r> rD r� rD r r4 r� r: r Z run_unittest)Ztestsr: r: r; � test_mains sV �
r� �__main__)N)�r^ r Zlogging.handlersZlogging.configrp r� r rv r r* r( rd r� r� r$ r rD r? ra r( r� r� Ztest.support.script_helperr r ri r r� r r rC r} r` rt Z http.serverr r r_ Z urllib.parser r � socketserverr r
r r r� r� r� rV rm ZTestCaser
r_ r� ZSILENTr� ZTERSEZEFFUSIVEr� r� Z TALKATIVEr� Z
CHATTERBOXZBORINGr r� r� r� r� r� r� r� r rE r- rK rN rP r` r] r{ r r� r� rD r� r� r� r� r/ r� r� r r7 r8 r8 r9 r> r@ rD Z IPV6_ENABLEDrE rH r] rh rv r� r� r� r� r� r r r+ r r r# r4 rG Z
unittest.mockr9 r: r} rQ ZtzinforP rw rW r� r� r� r� r� r� r� r� r� r� r� r� r r) rU rX r[ rx r� r� r� r� r� r� r� Zrun_with_localer� r[ r: r: r: r; �<module> sp m F �
Y _,M5) / h JY@C�M41(
W#i `
w' W 5 dl V Tn� !
#