Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cherrypy/test/__pycache__/test_bus.cpython-39.pyc
Ðазад
a v�h�& � @ s� d Z ddlZddlZddlZddlZddlZddlZddlm Z e e� d��oVej dkZ dZejdd� �Zejd d � �Zejd d � �Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zejj e d d �d d � �Z d!d"� Z d#d$� Z d%d&� Z dS )'z Publish-subscribe bus tests.� N)�wspbus�CI�darwinz Listener %d on channel %s: %s.c C s t �� S )zReturn a wspbus instance.)r ZBus� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cherrypy/test/test_bus.py�bus s r c C s G dd� d�}|| �S )z&Return an instance of bus log tracker.c @ s e Zd ZdZg Zdd� ZdS )z log_tracker.<locals>.LogTrackerzBus log tracker.c s � fdd�}|� d|� d S )Nc s � j �| � d S �N)� log_entries�append)�msg�level��selfr r �logit" s z7log_tracker.<locals>.LogTracker.__init__.<locals>.logit�log)� subscribe)r r r r r r �__init__! s z(log_tracker.<locals>.LogTracker.__init__N)�__name__� __module__� __qualname__�__doc__r r r r r r � LogTracker s r r )r r r r r � log_tracker s r c C s G dd� d�} | � S )z+Return an instance of bus response tracker.c @ s e Zd ZdZg Zdd� ZdS )zlistener.<locals>.Listnerz!Bus handler return value tracker.c s d� ��fdd� }|S )z%Return an argument tracking listener.Nc s �j �t�� | f � d S r )� responsesr r ��arg��channel�indexr r r �listener3 s z8listener.<locals>.Listner.get_listener.<locals>.listener)Nr )r r r r r r r � get_listener1 s z&listener.<locals>.Listner.get_listenerN)r r r r r r r r r r �Listner, s r! r )r! r r r r ) s r c s� g }| j D ]0� tg d��D ] \}}| �� |�� |�|� qq | j D ]L� | �� � |�� fdd�dD �� | j� dd� |�� fdd�dD �� qB|j|ks�J �dS ) z<Test that built-in channels trigger corresponding listeners.)�d �2 r �3 c s g | ]}t |� d f �qS r �r ��.0�i�r r r � <listcomp>H � z)test_builtin_channels.<locals>.<listcomp>)� � � r ��5 r c s g | ]}t |� d f �qS )r/ r% r& r) r r r* J r+ N)� listeners� enumerater r �publish�extendr )r r �expectedr �priorityr r) r �test_builtin_channels: s � r6 c s� g }d}|D ]0� t g d��D ] \}}| �� |�� |�|� q q |D ]J� | �� d� |�� fdd�dD �� | �� � |�� fdd�dD �� qB|j|ks�J �dS ) z8Test that custom pub-sub channels work as built-in ones.)ZhughZlouisZdewey)N� �< �( �ah soc 3 s | ]}t |� d f V qdS )r: Nr% r& r) r r � <genexpr>^ r+ z'test_custom_channels.<locals>.<genexpr>)r- r. r r, c 3 s | ]}t |� d f V qd S r r% r& r) r r r; ` r+ N)r1 r r r2 r3 r )r r r4 Zcustom_listenersr r5 r r) r �test_custom_channelsO s � r< c C s� g }dd� | j D �}|D ],}| �||�|d�� | j|dd� dd� q|D ]P}t�tj�� | �|d� W d � n1 s|0 Y |�t d|df � qJ|j |ks�J �d S ) z6Test that unhandled exceptions raise channel failures.c S s g | ]}|d kr|�qS )r r )r' �cr r r r* h r+ z(test_listener_errors.<locals>.<listcomp>r- c S s d S r r r r r r �<lambda>m r+ z&test_listener_errors.<locals>.<lambda>� )r5 �{ N) r0 r r �pytestZraisesr ZChannelFailuresr2 r r r )r r r4 Zchannelsr r r r �test_listener_errorse s *rB c C s� d}t |�D ]}| �d|�d|�� q | �� zTt|j�tdd� t |�D ��ksTJ �| j| jjksfJ �|j ddgksxJ �W | � � n | � � 0 dS )z1Test that bus start sequence calls all listeners.r. �startc s s | ]}t |d df V qdS )rC Nr% r& r r r r; � r+ z test_start.<locals>.<genexpr>z Bus STARTINGz Bus STARTEDN) �ranger r rC �setr �state�states�STARTEDr �exit�r r r �numr r r r � test_startw s ��rL c C sz d}t |�D ]}| �d|�d|�� q | �� t|j�tdd� t |�D ��ksRJ �| j| jjksdJ �|j ddgksvJ �dS )z0Test that bus stop sequence calls all listeners.r. �stopc s s | ]}t |d df V qdS �rM Nr% r& r r r r; � r+ z test_stop.<locals>.<genexpr>� Bus STOPPING� Bus STOPPEDN) rD r r rM rE r rF rG �STOPPEDr rJ r r r � test_stop� s �rR c C sf d}t |�D ]}| �d|�d|�� q | �� t|j�tdd� t |�D ��ksRJ �|jdgksbJ �dS )z4Test that bus graceful state triggers all listeners.r. �gracefulc s s | ]}t |d df V qdS )rS Nr% r& r r r r; � r+ z test_graceful.<locals>.<genexpr>z Bus gracefulN)rD r r rS rE r r rJ r r r � test_graceful� s ��rT c C s� d}t |�D ],}| �d|�d|�� | �d|�d|�� q | �� t|j�tdd� t |�D �dd� t |�D � �ksxJ �| j| jjks�J �|j g d�ks�J �dS ) z'Test that bus exit sequence is correct.r. rM rI c S s g | ]}t |d df �qS rN r% r& r r r r* � r+ z test_exit.<locals>.<listcomp>c S s g | ]}t |d df �qS )rI Nr% r& r r r r* � r+ )rO rP � Bus EXITING� Bus EXITEDN) rD r r rI rE r rF rG �EXITINGr rJ r r r � test_exit� s ���rX c s� � fdd�}d� j jgfd� j jgfd� j j� j jgfd� j jgfg}|D ]B\}}tj||fd��� � �|� � j |v sJJ d� j |f ��qJdS ) z%Test that bus wait awaits for states.c s t �d� t� | �� d S �N皙�����?)�time�sleep�getattr)�method�r r r �f� s ztest_wait.<locals>.frC rM rI )�target�argszState %r not in %rN) rG rH rQ ZSTARTINGrW � threading�ThreadrC �waitrF )r r` Zflowr^ rG r r_ r � test_wait� s � rf z%continuous integration on macOS fails)�reasonc sX t j�� }� �d|� � fdd�}tj|d��� � j� jj ddd� |j dksTJ �dS ) z#Test that wait publishes each tick.�mainc s t �d� � �� d S )Ng�������?)r[ r\ rC r r_ r r � set_start� s z3test_wait_publishes_periodically.<locals>.set_start�ra g{�G�z�?)�intervalr r. N) �unittestZmockZ MagicMockr rc rd rC re rG rH Z call_count)r �callbackri r r_ r � test_wait_publishes_periodically� s rn c s� � fdd�}dd� }t j|d��� t j|d��� dd� t �� D �}t|�dksVJ �� �� � j� jjkspJ �d d� t �� D �}t|�d ks�J �g d �}t|�}|j d |� |ks�J �t|j |d � �d ks�J d ��d S )z&Test that bus block waits for exiting.c s t �d� � �� d S rY )r[ r\ rI r r_ r r r` � s ztest_block.<locals>.fc S s t �d� d S )Ng�������?)r[ r\ r r r r �g� s ztest_block.<locals>.grj c S s g | ]}|j s|�qS r ��daemon�r' �tr r r r* � r+ z test_block.<locals>.<listcomp>r. c S s g | ]}|j s|�qS r rp rr r r r r* r+ r- )rO rP rU rV z)Waiting for child threads to terminate...Nz=No more than one extra log line with the thread name expected) rc rd rC r1 �len�blockrF rG rW r )r r r` ro �threadsZexpected_bus_messagesZ bus_msg_numr r_ r � test_block� s �rw c s� z|g � � fdd�}� fdd�}| � d|� | �|dddi� t�d � | j| jjksXJ �� d d dddifgksrJ �W | �� n | �� 0 d S ) z&Test that callback fires on bus start.c s � � d| |f� d S )Nr` �r )rb �kwargs��eventsr r r` s z#test_start_with_callback.<locals>.fc s � � d� d S )Nro rx r rz r r ro s z#test_start_with_callback.<locals>.grC )r- r. � �foo�barrZ ro r` N)r Zstart_with_callbackr[ r\ rF rG rH rI )r r` ro r rz r �test_start_with_callback s r c C s� |j g ksJ �g }dgd dg D ]&}| �|� |�|� |j |ks"J �q"zt W nF ty� | jddd� |j d }d|v r�d |v s�J d | ��Y n 0 t�d � d S ) z-Test that bus messages and errors are logged.z O mah darlin'r. ZClementiiiiiiiinez You are lost and gone foreverT)� traceback���� Traceback� NameErrorz;Last log message %r did not contain the expected traceback.z%NameError was not raised as expected.N)r r r r} r� rA Zfail)r r r4 Zmsg_Zlastmsgr r r �test_log1 s" �� r� )!r �os�sysrc r[ Z unittest.mockrl rA Zcherrypy.processr �bool�getenv�platformZ CI_ON_MACOSr Zfixturer r r r6 r< rB rL rR rT rX rf �markZxfailrn rw r r� r r r r �<module> s8 *
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка