Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_context.cpython-39.pyc
Ðазад
a a�h�. � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZmZ zd dlm Z W n e yf d dl m Z Y n0 zd dl m Z W n e y� dZ Y n0 d dl mZ d dlZd dlmZmZmZmZmZmZ G dd� dej�ZG d d � d ej�ZG d d � d e�ZdS ) � N)�Thread�Event)�Queue)�mock)�mark)�BaseZMQTestCase� have_gevent� GreenTest� skip_green�PYPY�SkipTestc s e Zd ZdZ� fdd�Z� ZS )�KwargTestSocketNc s( |� dd �| _tt| �j|i |�� d S )N� test_kwarg)�pop�test_kwarg_value�superr �__init__)�self�args�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/test_context.pyr s zKwargTestSocket.__init__)�__name__� __module__� __qualname__r r � __classcell__r r r r r s r c @ s e Zd ZeZdS )�KwargTestContextN)r r r r Z _socket_classr r r r r # s r c @ s e Zd Zdd� Zdd� Zejedu dd�dd � �Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zejej�d �d!d�d"d#� �Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z!ejej�d �d8d�d9d:� �Z"dS );� TestContextc C sX | � � }| �t|| j �� ~| � � }| �t|| j �� ~| � � }| �t|| j �� ~d S �N)�Context�assert_� isinstance)r �c1�c2�c3r r r � test_init) s zTestContext.test_initc C sD | � � }| �dt|�v � t�� dkr8| �dt|�v � |�� d S )N�socket�� Z IO_THREADS)r! � assertTrue�dir�zmq�zmq_version_info�term�r �ctxr r r �test_dir4 s zTestContext.test_dirNzrequires unittest.mock)�reasonc C s t j| jd�}d S )N)�spec)r ZMock�context)r �mr r r � test_mockable; s zTestContext.test_mockablec C s | � � }|�� | �|j� d S r )r! r/ r" �closed�r �cr r r � test_term@ s zTestContext.test_termc C s8 | � � �}W d � n1 s 0 Y | �|j� d S r )r! r" r8 r9 r r r �test_context_managerE s z TestContext.test_context_managerc C s | � tj| jd� d S )N���)�assertRaisesErrnor- �EINVALr! �r r r r �test_fail_initJ s zTestContext.test_fail_initc C sN | � tjtj�\}}|�tjd� |jddd� |�� |�� | j� � d S )Nr s helloF)�copy) �create_bound_pairr- ZROUTER�DEALER� setsockopt�LINGER�send�closer5 r/ )r �rep�reqr r r �test_term_hangM s zTestContext.test_term_hangc C sn | j �� }| j jdd�}| �||u � |�� | j �� }| j �� }| �||u � | �|j� | �||u � d S )N� )Z io_threads)r! �instancer+ r/ � assertFalser8 )r r1 r% r& Zc4r r r � test_instanceU s zTestContext.test_instancec C sd | j �� G dd� dtj�}|�� }tj�� }|�� |�� t|�tju sPJ �t|�|u s`J �d S )Nc @ s e Zd ZdS )z<TestContext.test_instance_subclass_first.<locals>.SubContextN�r r r r r r r � SubContextb s rQ �r5 r/ r- r! rM �type)r rQ �sctxr1 r r r � test_instance_subclass_first` s z(TestContext.test_instance_subclass_firstc C s� | j �� G dd� dtj�}G dd� dtj�}tj�� }|�� }|�� }|�� |�� |�� t|�tju srJ �t|�tju s�J �t|�|u s�J �d S )Nc @ s e Zd ZdS )zDTestContext.test_instance_subclass_second.<locals>.SubContextInheritNrP r r r r �SubContextInheritm s rV c @ s e Zd ZdZdS )zFTestContext.test_instance_subclass_second.<locals>.SubContextNoInheritN)r r r Z _instancer r r r �SubContextNoInherito s rW rR )r rV rW r1 rT Zsctx2r r r � test_instance_subclass_secondk s z)TestContext.test_instance_subclass_secondc s� | j �� t� �G � fdd�d| j�� � �fdd��d}�fdd�t|�D �}dd� |D � � �� }t|� �srJ �t|�D ] }�jd d �}||u szJ �qz|�� d d� |D � d S ) Nc s e Zd Z�� fdd�Z� ZS )z9TestContext.test_instance_threadsafe.<locals>.SlowContextc s$ t �d� t� | �j|i |�� d S )N� )�time�sleepr r )r �a�kw)� SlowContextr r r r � s zBTestContext.test_instance_threadsafe.<locals>.SlowContext.__init__)r r r r r r )r^ r r r^ � s r^ c s �� � �� � d S r )�putrM r )r^ �qr r �f� s z/TestContext.test_instance_threadsafe.<locals>.f� c s g | ]}t � d ��qS )��target)r ��.0�i)ra r r � <listcomp>� � z8TestContext.test_instance_threadsafe.<locals>.<listcomp>c S s g | ] }|� � �qS r )�start�rf �tr r r rh � ri � ��timeoutc S s g | ]}|j d d��qS )rm rn )�joinrk r r r rh � ri )r5 r/ r r! �rangerM r# �get)r �N�threadsr1 rg Z thread_ctxr )r^ ra r` r �test_instance_threadsafe| s z$TestContext.test_instance_threadsafec C sn d}t � �P}|jtj|d�� }| �|j|u � W d � n1 sB0 Y W d � n1 s`0 Y d S )Nztesting one two three)r )r r( r- rD r+ r )r r r1 r( r r r �test_socket_passes_kwargs� s z%TestContext.test_socket_passes_kwargsc sP | � � � td�D ]2}� fdd�td�D �}dd� |D � t�d� q� �� dS )z9opening and closing many sockets shouldn't cause problemsrb c s g | ]}� � tj��qS r �r( r- �REPre �r1 r r rh � ri z1TestContext.test_many_sockets.<locals>.<listcomp>�A c S s g | ] }|� � �qS r �rH �rf �sr r r rh � ri �{�G�z�?N)r! rq rZ r[ r/ )r rg �socketsr ry r �test_many_sockets� s z TestContext.test_many_socketsc C sx | � � }d|_| �|jd� |�tj�}| �|jd� | �|�tj�d� |�� d|_ |�tj�}|�� |� � dS )z*setting socket options with ctx attributesrm ri N) r! �linger� assertEqualr( r- �REQ� getsockoptrF rH � subscriber/ �r r1 r} r r r � test_sockopts� s zTestContext.test_sockopts�winzSegfaults on Windowsc sb | � � � � fdd�td�D �}dd� |ddd� D � � �� t�d� |D ]}| �|j� qLdS )z$Context.destroy should close socketsc s g | ]}� � tj��qS r rw re ry r r rh � ri z,TestContext.test_destroy.<locals>.<listcomp>rz c S s g | ] }|� � �qS r r{ r| r r r rh � ri NrL r~ )r! rq �destroyrZ r[ r+ r8 )r r r} r ry r � test_destroy� s zTestContext.test_destroyc C s^ | � tjtj�\}}|�d� t�d� | jjdd� t�d� ||fD ]}| � |j � qHdS )z4Context.destroy should set linger on closing sockets� hir~ r )r� N) rC r- r� rx rG rZ r[ r5 r� r+ r8 )r rJ rI r} r r r �test_destroy_linger� s z TestContext.test_destroy_lingerc C sx | � � }|�tj�}| �|j� t|jd�}|�� |j dd� | � |� � d� |� � |j dd� | �|� � d� dS )z Context.term won't close socketsrc g�������?rn zContext should be waitingzContext should have closedN) r! r( r- r� rN r8 r r/ rj rp r+ �is_aliverH )r r1 r} rl r r r �test_term_noclose� s z TestContext.test_term_noclosec sJ t r td��� fdd�}t|d�}|�� |jdd� � �|�� d� dS ) z+test close&term by garbage collection alonezGC doesn't work c s � fdd�} | � t �� d S )Nc s � � � } | �tj�}d S r )r! r( r- �PUSH)r1 r} r@ r r �inner� s z/TestContext.test_gc.<locals>.gcf.<locals>.inner)�gcZcollect)r� r@ r r �gcf� s z TestContext.test_gc.<locals>.gcfrc rY rn z1Garbage collection should have cleaned up contextN)r r r rj rp rN r� )r r� rl r r@ r �test_gc� s zTestContext.test_gcc s, G � fdd�dt �� � �fdd�}|� dS )z6ctx.destroy should succeed when cyclic ref prevents gcc s" e Zd Zddd�Z� fdd�ZdS )z8TestContext.test_cyclic_destroy.<locals>.CyclicReferenceNc S s || _ d S r )�parent)r r� r r r r � s zATestContext.test_cyclic_destroy.<locals>.CyclicReference.__init__c s || _ � | �| _d S r )�sock�child)r r� ��CyclicReferencer r �crash� s z>TestContext.test_cyclic_destroy.<locals>.CyclicReference.crash)N)r r r r r� r r� r r r� � s r� c s0 �� � } | �tj�}� � }|�|� | �� d S r )r! r( r- �PULLr� r� )r1 r� r: �r� r r r � crash_zmq� s z2TestContext.test_cyclic_destroy.<locals>.crash_zmqN)�object)r r� r r� r �test_cyclic_destroy� s z TestContext.test_cyclic_destroyc s� �� � � t� ���� � ��fdd�}t|d�}|�� ��d� ����� d� t� d� � � � |j dd� �� |� � d� d S ) z/ctx.term should not crash active threads (#139)c s� � � tj�} | �d� ��� z\z | �� W nB tjyn } z(��|jtj � W Y d }~W | � � d S d }~0 0 W | � � n | � � 0 �� d� d S )N�tcp://127.0.0.1z,recv should have been interrupted with ETERM) r( r- rx �bind_to_random_port�set�recvZZMQErrorr� �errnoZETERMrH Zfail)r} �e�r1 Zevtr r r �block s �z+TestContext.test_term_thread.<locals>.blockrc rY zsync event never firedr~ rn z%term should have interrupted s.recv()N)r! r �clearr rj �waitr+ �is_setrZ r[ r/ rp rN r� )r r� rl r r� r �test_term_thread s z TestContext.test_term_threadc C sF | � � }|�tj�}|�d� |�� |�� |js8J �|jsBJ �d S )Nr� )r! r( r- �PUBr� rH r� r8 r� r r r �test_destroy_no_sockets# s z#TestContext.test_destroy_no_socketsc C sj t �� dk rtd��| �� }|�t jd� | �|�t j�d� d|_| �|jd� | �|�t j�d� d S )Nr) z context options require libzmq 3rL �d ) r- r. r r! r� Z MAX_SOCKETSr� rr Z max_socketsr0 r r r � test_ctx_opts, s zTestContext.test_ctx_optsc C s� | � � }t�|�}t�|�}t�|�}| �|j� | �|j� | �|j|j� | �|j|j� | �|j|j� |�tj �}|� � |� � d S r ) r! rB �deepcopyr" Z_shadowr� � underlyingr( r- r� rH r/ )r r$ r% Zc2br& r} r r r � test_copy6 s zTestContext.test_copyc C s� | � � }| j �|j�}| �|j|j� |�tj�}|�� ~| �|j � |�tj�}| j �|j�}|�tj�}|�� |�� |� � | � tj |jtj� ~d S r ) r! Zshadowr� r� r( r- r� rH rN r8 r/ r> ZEFAULT)r r1 �ctx2r} �s2r r r � test_shadowD s zTestContext.test_shadowc C s� zddl m}m}m} W n ty2 td��Y n0 |�� }|�|tj�}|� |d� | j � |�}|� tj �}|�d� |�|d� | �|�}| �|d� |�� d S )Nr )�zctx�zsocket�zstrzRequires pyczmqz inproc://ar� )Zpyczmqr� r� r� � Exceptionr �newr- r� �bindr! Z shadow_pyczmqr( r� �connectrG r� r� rH ) r r� r� r� r1 r\ r� �bZrcvdr r r �test_shadow_pyczmqU s z TestContext.test_shadow_pyczmqzNo fork on Windowsc C s� | j �� }t|�}t�� \}}t�|d�}t�� }|dkr�| j �� }t�|d�}t|�}|�� |�t |�d � |� � |� � t� d� n t� |� |� � } |� � | s�J �t| �|ks�J �|�� d S )N�rr �w� )r! rM �id�os�pipe�fdopen�forkr/ �write�str�flushrH �_exit�readline�int) r r1 Z parent_ctx_idZr_fdZw_fd�readerZ child_pid�writerZ child_ctx_idZ child_id_sr r r �test_fork_instancef s( z TestContext.test_fork_instance)#r r r r' r2 r Zskipifr r7 r; r< rA rK rO rU rX ru rv r� r� �sys�platform� startswithr� r� r� r� r� r� r� r� r� r� r� r� r r r r r ' sF � �r ) rB r� r� r� rZ � threadingr r �queuer � ImportErrorZunittestr Zpytestr r- Z zmq.testsr r r r r r ZSocketr r! r r ZTestContextGreenr r r r �<module> s, ^
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка