Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_message.cpython-39.pyc
Ðазад
a a�hS+ � @ s� d dl Z d dlZzd dlmZ W n ey6 dZY n0 d dlZd dlmZ d dlmZ d dl Z d dl m Z m Z m Z mZ d dlmZmZmZmZ dZer�ee�Zee�Zee�e Zdd � ZG d d � d e �ZdS ) � N)� getrefcount)�pprint)�TestCase)�BaseZMQTestCase�SkipTest� skip_pypy�PYPY)�unicode�bytes�b�u� xc C s2 t d�D ]$}t| �|d kr" dS t�d� qdS )z�wait for refcount on an object to drop to an expected value Necessary because of the zero-copy gc thread, which can take some time to receive its DECREF message. �2 � Ng�������?)�range�grc�time�sleep)�obj�rc�i� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/test_message.py�await_gc s r c @ s� e Zd Zedd� �Zdd� Zdd� Zdd� Zd d � Zed d � �Z ed d� �Z edd� �Z dd� Z edd� �Z dd� Zdd� Zdd� Zedd � �Zd d � Zd d � Zd!d"� Zed#d$� �Zd%d&� Zd'S )(� TestFramec C sl t dd�D ]\}d| t }| �t|�d� tj|dd�}| �t|�d� ~t|d� | �t|�d� ~q dS )z/Message above 30 bytes are never copied by 0MQ.� � r F��copy� N)r �x� assertEqualr �zmq�Framer ��selfr �s�mr r r � test_above_30- s zTestFrame.test_above_30c C sD t d�D ]6}d| t }t�|�}t|�}t|�}| �||� qdS )z+Test the str representations of the Frames.r r N)r r r" r# �strr r! )r% r r& r' Zm_strZm_str_br r r �test_str: s zTestFrame.test_strc C s` t dd�D ]P}d| t }t�|�}|j}| �||j� tsJ| �||u� | �||ju � q dS )z Test the Frame.bytes property.� r r N)r r r" r# r r! r �assert_)r% r r& r' r r r r � test_bytesC s zTestFrame.test_bytesc C s^ t d�}| �ttj|� td�D ]8}d| t d� }t�|�d��}| �|t|j d�� q dS )z/Test the unicode representations of the Frames.Zasdfr r � §�utf8N) r � assertRaises� TypeErrorr" r# r �encoder! r r )r% r& r r' r r r � test_unicodeP s zTestFrame.test_unicodec C s< t d�D ].}d| t }t�|�}| �t|�t|�� qdS )zTest the len of the Frames.r r N)r r r" r# r! �lenr$ r r r �test_lenY s zTestFrame.test_lenc C s4 t dd�D �]"}d| t }d}| �t|�|� tj|dd�}|d7 }| �t|�|� t�|�}|d7 }| �t|�|� |j}|t7 }| �t|�|� | �|t t |��� | �|t |�� | �||j � ~|d8 }| �t|�|� |t8 }~| �t|�|� ~|d8 }t ||� | �t|�|� | �|d� ~q dS )z-Run through a ref counting cycle with a copy.r r r Fr r+ N� r r r! r r" r# r �buffer�view_rcr r) r r �r% r r& r r' �m2�bufr r r �test_lifecycle1` s8 zTestFrame.test_lifecycle1c C sB t dd�D �]0}d| t }d}| �t|�|� tj|dd�}|d7 }| �t|�|� t�|�}|d7 }| �t|�|� |j}|t7 }| �t|�|� | �|t t |��� | �|t |�� | �||j � | �||j � ~| �t|�|� ~|t8 }|d8 }| �t|�|� ~|d8 }t ||� | �t|�|� | �|d� ~q dS )z7Run through a different ref counting cycle with a copy.r r r Fr r+ Nr6 r9 r r r �test_lifecycle2� s: zTestFrame.test_lifecycle2c C sh t jdddd�}| �|jj� t �|�}| �|j� ~td�D ]}|jrL qXt�d� q>| � |j� d S )N� asdfFT�r �track� 皙�����?) r" r# � assertFalse�tracker�done�MessageTrackerr r r � assertTrue)r% r' �pmr r r r � test_tracker� s zTestFrame.test_trackerc C sH t jddd�}| �|jd � t�|�}| �|jd � | �tt j|� d S )Nr> F)r@ )r" r# r! rD r r0 � ValueErrorrF )r% r' r: r r r �test_no_tracker� s zTestFrame.test_no_trackerc C s� t jdddd�}t jdddd�}t �||�}| �|jj� | �|j� | �t j|jd� ~t � d� | �t j|jd� | �|j� ~| � |�� d u � | � |j� d S )Nr> FTr? s whodarB ) r" r# rF rC rD rE r0 ZNotDone�waitr r rG )r% r' r: �mtr r r �test_multi_tracker� s z TestFrame.test_multi_trackerc C s t d�}t�t|��}dS )z test using a buffer as input�8 §§¶•ªº˜µ¬˚…∆˙åß∂©œ∑´†≈ç√N)r r" r# � memoryview)r% �insr' r r r �test_buffer_in� s zTestFrame.test_buffer_inc C s& | � ttjd� | � ttjt� � dS )ztest using a bad objectr N)r0 r1 r" r# �object)r% r r r �test_bad_buffer_in� s z TestFrame.test_bad_buffer_inc C sN t d�}t�|�}|j}| �t|t�� | �||ju � | �|j|ju � dS )zreceiving buffered outputrO N)r r" r# r7 rG � isinstancerP r, )r% rQ r' Zoutbr r r �test_buffer_out� s zTestFrame.test_buffer_outc C s� t jdk rtd��td�}t|�}t�|�}|j}| �|j d� | �|j |f� | �|� � |� t |�}| �|j d� | �|j |f� | �|� � |� dS )zmemoryview shape info)� z!only test memoryviews on Python 3rO r+ N) �sys� version_infor r r4 r" r# r7 r! �ndim�shape�tobytesrP )r% �data�n�fZview1Zview2r r r �test_memoryview_shape� s z TestFrame.test_memoryview_shapec C s� | � tjtj�\}}d}t�|�}| �||j� |j|dd� t�d� | �||j� |j|dd� t�d� | �||j� |j|dd� t�d� | �||j� |j|dd� t�d� | �||j� t d�D ]}|� � }| �||� q�| �||j� dS )z9ensure that a message remains intact after multiple sendss messageFr rB Tr N) �create_bound_pairr" �PAIRr# r! r �sendr r r �recv)r% �ar r& r' r �rr r r �test_multisend� s( zTestFrame.test_multisendc C st t jdd� \}}|dks2|dkr*|dks2td��d}t|�}t�|�}|j}|�� }| �||� | �|j |� dS )z test messages from memoryviewNr rW � z!memoryviews only in python >= 2.7s carrotjuice) rX rY r rP r" r# r7 r\ r! r )r% �major�minorr& �vr' r; �s2r r r �test_memoryview s zTestFrame.test_memoryviewc C s� d}| � tjtj�\}}td�D ]�}|j|dd� |jdd�}|j}|j}~td�D ]\}dd|d }|j|dd� |jdd�} |�� } | � | |� | � ||� | � | j|� qTq d S ) z$check for clobbering message bufferss@ � Fr r � ��( rA N) ra r" rb r rc rd r r7 r\ r! ) r% �null�sa�sbr r' �mbr; �ffr: r r r r �test_noncopying_recv s z TestFrame.test_noncopying_recvc sl zddl }ddlm} W n ty2 td��Y n0 tjdk rFtd��|jj� � fdd�t d �D �}| � t j t j �\}}t td d g}t d t|�d �D ]�}|d|� }|D ]L} |j|| d �} |j| dd� |jdd�} |�| | j��| j�} || | � q�|j|dt fdtfdgd �} d| d< d| d< d| d< |j| dd� |jdd�} |�| | j��| j�} || | � q�dS )z%test non-copying numpy array messagesr N)�assert_array_equalzrequires numpy)r rh z/requires new-style buffer interface (py >= 2.7)c s g | ]}� d d��qS )r r r )�.0r �Zrandr r � <listcomp>7 � z/TestFrame.test_buffer_numpy.<locals>.<listcomp>r z>i4�Br+ )�dtypeFr re r )�cZa32i g e��Az hello therer~ )�numpyZ numpy.testingrw � ImportErrorr rX rY �random�randintr ra r" rb �int�floatr4 �emptyrc rd Z frombufferr} Zreshaper[ ) r% r rw Zshapesre r Zdtypesr r[ �dt�A�msgr| r ry r �test_buffer_numpy, s6 zTestFrame.test_buffer_numpyc C s� t �d�}| �|j� | �t jt j�\}}|�ddg� | j|dd�}| �|j� t � � d dkrxt sx| �|� t j �� | j|dd�}| �|j� t � � d dkr�t s�| �|� t j �� dS ) ztest Frame.more attributes hellos his thereFr r rW N) r" r# rC �morera rb Zsend_multipartrd rG Zzmq_version_infor �getZMORE)r% �framerr rs r r r �test_frame_moreN s zTestFrame.test_frame_moreN)�__name__� __module__� __qualname__r r( r* r- r3 r5 r< r= rI rK rN rR rT rV r` rg rm rv r� r� r r r r r + s4 # # !r )r rX r r r� r r Zunittestr r" Z zmq.testsr r r r Zzmq.utils.strtypesr r r r r Zrc0rP rk r8 r r r r r r �<module> s$
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка