Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_socket.cpython-39.pyc
Ðазад
a a�h�T � @ s, d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZzd dl m Z W n e yn dZ Y n0 d dl Z d dl m Z d dlZd dlmZmZmZmZmZ d dlmZ e�� �� dkZe�� �� �d�Ze ej � d��Z er�d nd Z G d d � d e�Z!e�r(e�s(d dl"Z"G d d� dee!�Z#dS )� N)�mock)�mark)�BaseZMQTestCase�SkipTest� have_gevent� GreenTest� skip_pypy)�unicode�pypy�windowsZTRAVIS_PYTHON_VERSION�� �d c @ sd e Zd Zdd� Zdd� Zdd� Zejedu dd �d d � �Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zed d!� �Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z d0d1� Z d2d3� Z eje d4d �d5d6� �Z d7d8� Z!d9d:� Z"d;d<� Z#d=d>� Z$d?d@� Z%dAdB� Z&eje'�r4e(�pBe)j*dCk �pBe dDd �ej+dEdF� ��Z,dGdH� Z-dS )I� TestSocketc C sX | � � }|�tj�}| �tj|jd� | �tj|jd� | �tj|jd� |� � ~d S )Nzftl://aztcp://) �Context�socket�zmq�PUB�assertRaisesErrno�EPROTONOSUPPORT�bind�connect�EINVAL�close��self�ctx�s� 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_socket.py� test_create% s zTestSocket.test_createc C s� d}| � � ��}|�tj���}|�|� |�tj��>}|�|� d}|�|� | �|�}| � ||� W d � n1 sv0 Y | � |j d� W d � n1 s�0 Y | � |j d� W d � n1 s�0 Y | � |j d� d S )N� inproc://a� hiT) r r r �PUSHr �PULLr �send�recv� assertEqual�closed)r �urlr �a�b�msg�rcvdr r r �test_context_manager/ s *,,z TestSocket.test_context_managerc C sp | � � }|�tj�}| �dt|�v � | �dt|�v � | �dt|�v � | �dt|�v � |�� |�� d S )Nr$ �IDENTITY�AFFINITY�FD)r r r r � assertTrue�dirr �termr r r r �test_dir> s zTestSocket.test_dirNzrequires unittest.mock��reasonc C s$ | � tj�}tj|d�}|�� d S )N)�spec)r r �SUBr ZMockr )r r �mr r r � test_mockableH s zTestSocket.test_mockablec C s | � tj�}|�td��}d S )Nztcp://*)r r r �bind_to_random_portr )r r �pr r r �test_bind_unicodeN s z TestSocket.test_bind_unicodec C s | � tj�}|�td�� d S )N�tcp://127.0.0.1:5555)r r r r r �r r r r r �test_connect_unicodeR s z TestSocket.test_connect_unicodec C s� | � � }|�tj�}z|�d� W n6 tjyX } z | �|jtj� W Y d }~n d }~0 0 z|�d� W n6 tjy� } z | �|jtj � W Y d }~n d }~0 0 d S )Nztcp:*zrand://*) r r r r r; �ZMQErrorr& �errnor r )r r �c�er r r �test_bind_to_random_portV s &z#TestSocket.test_bind_to_random_portc C s< | j �tj�}| j�|� d}||_| �|�tj �|� d S )Ns identity ) �contextr r r# �sockets�append�identityr& �getr. )r r �identr r r � test_identitye s zTestSocket.test_identityc C sP d}t tur|�d�}| �tjtj�\}}| �|j|j� | �|j |j � | � t |j tj |� | � t |j tj|� |�tj|d� | � t |j tj|� |�tj |� | � t |jtj� | �tj|jtj � |�tj�}|�d�}|�tjd�}| �||� t�d� |�|tj� |j|d dd� | �||� � � | �|d |j dd�� dS ) z2test setting/getting sockopts with unicode stringsu tést�utf8�utf16皙�����?� zlatin-1��encodingN)�strr �decode�create_bound_pairr r r8 r& � send_unicode� recv_unicode� assertRaises� TypeError� setsockopt� SUBSCRIBEr. Zsetsockopt_unicoder/ Zgetsockopt_unicoder r � getsockopt�time�sleepZSNDMORE)r Ztopicr< r ZidentbZidentuZidentu2r r r �test_unicode_sockoptsl s, z TestSocket.test_unicode_sockoptsc C s t �� }|dk rd}nd}| �t jt j�\}}|�t jd� | �|�t j�d� |�t jd� | �|�t j�d� | �|j |� d|_ | �|j d� | �|�t j �t j � | � t j |jt j d� | �|�t j�|j� | �|�t j�t j� | �|�t j�|j� | �|�t j�t j� g }i }t j}|jD ]$}t||�} t| t��r,||| < �q,t jj�t jj�D ]�} || } | �d��r��qdz|�| �} W n: t j�y� } z |�d| | f � W Y d } ~ n"d } ~ 0 0 | d k�rd|�d | � �qd|�r| �d � d g| �� d S )ztest integer sockopts)� r r r ���� � )�ROUTERZXPUBZTCPZFAILZREQ_ZCURVE_Z PROBE_ROUTERZ IPC_FILTERZGSSAPIZSTREAM_ZVMCI_BUFFER_SIZEZVMCI_BUFFER_MIN_SIZEZVMCI_BUFFER_MAX_SIZEZVMCI_CONNECT_TIMEOUTz getsockopt(zmq.%s) raised '%s'.Nl zNgetsockopt(zmq.%s) returned a ridiculous value. It is probably the wrong type.� � ) r �zmq_version_inforU r r8 rZ �LINGERr& r\ �hwmZEVENTS�POLLOUTr r ZTYPE� socket_type� constants�__all__�getattr� isinstance�intZ int_sockopts�unionZint64_sockopts� startswithrA rH �fail�join)r �vZ default_hwmr< r �errorsZbackrefrl �name�value�opt�sopt�nrD r r r �test_int_sockopts� sN ( � z TestSocket.test_int_sockoptsc C sz | j �tj�}| j�|� |�tjd� | �tj |jdd� | �tj |j d� | � t |jdd� | �tj |jtj d� dS )z=Test that appropriate errors are raised on bad socket optionsr i' � � 5r! N)rF r r r rG rH rZ rh r r r\ rX rY r[ r? r r r �test_bad_sockopts� s z TestSocket.test_bad_sockoptsc C s@ | j �tj�}| j�|� |�tjd� | �|� tj�d� dS )z test set/getsockopt roundtrip.rb N) rF r r r rG rH rZ rh r& r\ )r r< r r r �test_sockopt_roundtrip� s z!TestSocket.test_sockopt_roundtripc C s� | � tjtj�\}}| j�||g� d}ttur:|�d�}| jt |j |dd� | jt |j |dd� |� |� |� � }| � ||�d�� | � |�d�|� |j |dd� |jdd�}| � ||� dS ) z test sending unicode objectsu çπ§rM F��copyTrN rQ N)rU r �PAIRrG �extendrS r rT rX rY r$ rV r% r& �encoderW )r r) r* �ur r r r �test_send_unicode� s z TestSocket.test_send_unicodec C s` | � tjtj�\}}| j�||g� | �t|jddg� |�dg� | �|�}| � |dg� dS )z*check type on all frames in send_multipart� ar} � bN) rU r r� rG r� rX rY �send_multipart�recv_multipartr& )r r) r* r, r r r � test_send_multipart_check_type� s z)TestSocket.test_send_multipart_check_typec C s� d}t � � }|�d� |�� d }d||f }|�� t�d� | j� tj�}| j� tj �}| j � ||g� |� |� t�d� |j dddd �}t|tj�s�J �|tju s�J �|js�J �d |_|jdd gddd �}t|tj�s�J �|jr�J �|�|� | �|�} td �D ] } |j�r �q(t�d� �q| �|jd� | �| dg� | �|�} td �D ] } |j�rh �qvt�d� �qV| �|jd� | �| dd g� tjd ddd �} | �| jjd� |j | dd�}|j | dd�}| �| jjd� | �|jd� | �|jd� | �|�} | �| jjd� | �| d g� | �|�} | �| jjd� | �| d g� | �|jd� | �|jd� | j} ~ td �D ] } |j�r� �q�t�d� �qx| �|jd� | �|jd� tjddd�} | jt|j | ddd � dS )zJtest the MessageTracker object for tracking when zmq is done with a bufferztcp://127.0.0.1)z 127.0.0.1r � z%s:%irO s somethingFT)r� �trackr s else� s againr� )r� N)r r � getsocknamer r] r^ rF r r" r# rG r� r r$ ro ZMessageTrackerZ_FINISHED_TRACKER�doneZcopy_thresholdr� r� �ranger& �Frame�trackerrX � ValueError) r �addr�sock�portZifacer) r* �p1�p2r+ �ir9 �pmr r r � test_tracker� sx zTestSocket.test_trackerc C s~ | � � }|�tj�}|�� | �tj|jd� | �tj|jd� | �tj|j tj d� | �tj|j d� | �tj|j � ~d S )N� s asdf) r r r r r r �ENOTSOCKr r rZ r[ r$ r% r r r r � test_close0 s zTestSocket.test_closec C s` | j �tj�}| j�|� d}||_| �||j� | �||�tj �� | �|j |�tj �� dS )z*set setting/getting sockopts as attributesr� N) rF r r �DEALERrG rH �lingerr& r\ rh �fdr0 )r r r� r r r � test_attr; s zTestSocket.test_attrc C sn | j �tj�}| j�|� z d|_W n ty6 Y n 0 | �d� z |j W n ty^ Y n 0 | �d� d S )NZfooz-bad setattr should have raised AttributeErrorz-bad getattr should have raised AttributeError) rF r r r� rG rH �apple�AttributeErrorrs r? r r r � test_bad_attrE s zTestSocket.test_bad_attrc sh G � fdd�dt j�� � | jt j�}| j�|� | �|jd� d|_| �|jd� |j}| �|d� dS )z subclasses can assign attributesc s" e Zd ZdZ�� fdd�Z� ZS )z#TestSocket.test_subclass.<locals>.SNc s d| _ t� | �j|i |�� d S )Nra )r) �super�__init__)r r) �kw)�S� __class__r r r� Y s z,TestSocket.test_subclass.<locals>.S.__init__)�__name__� __module__� __qualname__r) r� � __classcell__r �r� )r� r r� W s r� ra r� N)r �SocketrF �REPrG rH r& r) )r r r) r r� r � test_subclassU s zTestSocket.test_subclassc C sX | � � \}}d}td�D ]}|�|� qt�d� td�D ]}| �| �|�|g� q:d S )Nr! r` rO )rU r� r$ r] r^ r& r� )r r) r* r+ r� r r r �test_recv_multiparte s z TestSocket.test_recv_multipartc C s> | � � }|�tj�}|�� t�d� |�� | �|j � dS )z,s.close() after ctx.destroy() should be fineg{�G�z�?N) r r r r� �destroyr] r^ r r1 r' r r r r �test_close_after_destroyn s z#TestSocket.test_close_after_destroyc C s� | � � \}}t�� }|�t�}| �|d� |�ttj�}| �|tj� d}|�|� |�t�}| �|tj� | � |�}|�t�}| �|d� | �||� d S )Nr r! ) rU r] �poll� POLL_TIMEOUTr& r rj r$ �POLLINr% )r r) r* ZticZevtr+ Zmsg2r r r � test_pollx s zTestSocket.test_pollc C sD t jdkrtd��dt j }| �t jdk|� | �t jdk |� dS )z$IPC_PATH_MAX_LEN is a sensible valuer �IPC_PATH_MAX_LEN undefinedz)Surprising value for IPC_PATH_MAX_LEN: %s� i N)r �IPC_PATH_MAX_LENr r1 )r r+ r r r �test_ipc_path_max_length� s z#TestSocket.test_ipc_path_max_lengthc C s� t jdkrtd��| j�t j�}| j�|� z |�d� dt jd �� W n< t j y� } z"| � t t j�|j v � W Y d }~n d }~0 0 d S )Nr r� � ipc://{0}r) r� )r r� r rF r r rG rH r �formatrA r1 rS �strerror)r r rD r r r � test_ipc_path_max_length_msg� s z'TestSocket.test_ipc_path_max_length_msgz ipc not supported on Windows.c C s� | j �tj�}| j�|� d}t�tj�� }|� d� |�� W d � n1 sP0 Y |j j t j kslJ �t|j �}||v s�J �d|�� v s�J �dS )z3Display the ipc path in case of an ENOENT exceptionz/foo/barr� Nzno such file or directory)rF r r r rG rH �pytestZraisesrA r r� rx rB �ENOENTrS �lower)r r Z invalid_path�error� error_messager r r �/test_ipc_path_no_such_file_or_directory_message� s . z:TestSocket.test_ipc_path_no_such_file_or_directory_messagec C s� t �� d dk}t jt jt jt jt jfD ]|}| j�|�}d|_ | � |j d� |r�z| � |j d� W n t yt Y n0 z| � |j d� W n t y� Y n0 |�� q(d S )Nr r` r )r rg r rd r8 �REQr� rF r ri r& Zsndhwmr� Zrcvhwmr )r Zzmq3�styper r r r �test_hwm� s zTestSocket.test_hwmc C sd | � tj�}t�|�}t�|�}| �|j� | �|j� | �|j|j� | �|j|j� |� � d S )N) r r r r� �deepcopyZassert_Z_shadowr& � underlyingr )r r ZscopyZsdcopyr r r � test_copy� s zTestSocket.test_copyc C sZ | � tjtj�\}}ttfD ]8}t|��d�}||�}|�|� |� � }||ks J �q d S )N�ascii) rU r r" r# � memoryview� bytearrayrS r� r$ r% )r r) r* Z buffer_type�rawbytesr+ �recvdr r r �test_send_buffer� s zTestSocket.test_send_bufferc C s� | � tj�}|�d� tj�|j�}| �|j|j� | � tj�}tj�|j�}| � |j|j� | �|j|j� |� d� d}|� |� | � |�}| �||� d S )Nr> r! ) r r r" r r� �shadowr� r& r# ZassertNotEqualr r$ r% )r r< r� r �s2�sentr, r r r � test_shadow� s zTestSocket.test_shadowc C s� zddl m}m} W n ty. td��Y n0 |�� }|�|tj�}|�|tj�}tj � |�}tj � |�}|� d� |� d� |� d� | �|�}| �|d� d S )Nr )�zctx�zsocketzRequires pyczmqr r! )Zpyczmqr� r� � Exceptionr �newr r" r# r� r� r r r$ r% r& ) r r� r� r �ca�cbr) r* r, r r r �test_shadow_pyczmq� s z TestSocket.test_shadow_pyczmqc C s� | � tjtj�\}}|�d� d|_t�� }|�|tj� td�D ] }|� d� |� d�}|rB qdqB| � |� |� d� | � |�}| � |d� |� d� |� d� |� d�}| � |g � d S )N�prefixrC r s canary� s prefixmessager )rU r r r8 � subscribeZPoller�registerr� r� r$ r� r% r& Z unsubscribe)r Zpub�subr< r� �eventsr+ r r r �test_subscribe_method� s$ z TestSocket.test_subscribe_methodl z"only run on 64b and not on Travis.c C s� t �d�}d}z || }W n0 tyJ } ztd| ��W Y d }~n d }~0 0 | �� \}}z |j|dd� |jdd�}W n0 ty� } ztd| ��W Y d }~n d }~0 0 tjdk r�|nt |�}t |�} t | �|ks�J �| d |ks�J �| d |ks�J �d S ) Nr� l zNot enough memory: %sFr� )r` r ra ) �os�urandom� MemoryErrorr rU r$ r% �sys� version_info�ordr� �len) r rC �N�bufrD r) r* r, �byte�viewr r r �test_large_send s" " "zTestSocket.test_large_sendc C s� | � tjtj�\}}dd� }dd� }dddd�i}|�||� |�|�}|d |d ks\J �|d shJ �|�||� |�|�}|d |d ks�J �|d r�J �d S ) Nc S s8 g }|� | �dg �� t�| d ��d�}|�|� |S )N� identities�contentrM )r� rJ �json�dumpsr� rH )r+ �framesr� r r r � serialize' s z3TestSocket.test_custom_serialize.<locals>.serializec S s* | d d� }t �| d �d��}||d�S )Nra rM )r� r� )r� �loadsrT )r� r� r� r r r � deserialize. s �z5TestSocket.test_custom_serialize.<locals>.deserializer� r} �bee)r) r* r� )rU r r� rd Zsend_serializedZrecv_serialized)r r) r* r� r� r+ r� �r2r r r �test_custom_serialize% s �� z TestSocket.test_custom_serialize).r� r� r� r r- r4 r �skipifr r: r= r@ rE rL 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 � on_travisr� �maxsizeZlarger� r� r r r r r # sZ 5 F ��� r c @ s\ e Zd ZejZejZdd� Zej e e d� dd�dd� �Z ej e e d� d d�d d � �Z d S ) �TestSocketGreenc sN | � � \� }t�d� fdd��}t�d�}|�� | �tj|j� |�� d S )Ng �?c s � � d�S )Nr! )r$ r �r) r r �<lambda>P r� z.TestSocketGreen.test_timeout.<locals>.<lambda>rO )rU �geventZ spawn_later�Timeout�startrX r% �kill)r r* �g�timeoutr r r � test_timeoutN s z TestSocketGreen.test_timeoutZRCVTIMEOzrequires RCVTIMEOr5 c C sn | j �tj�}tjdd��}d|_W d � n1 s60 Y |�� | �t |�d� | �|d j t � d S )NT��recordr} r� r ) rF r r r� �warnings�catch_warningsZrcvtimeor r& r� �category� UserWarning�r r �wr r r �test_warn_set_timeoV s $z#TestSocketGreen.test_warn_set_timeoZSNDTIMEOzrequires SNDTIMEOc C sn | j �tj�}tjdd��}|j W d � n1 s60 Y |�� | �t |�d� | �|d j t � d S )NTr r� r ) rF r r r� r r Zsndtimeor r& r� r r r r r r �test_warn_get_timeo` s $z#TestSocketGreen.test_warn_get_timeoN)r� r� r� r Z skip_greenr� r� r r r� �hasattrr r r r r r r r J s r )$r� rB r� r� �platformr] r r r� Zunittestr � ImportErrorr� r r Z zmq.testsr r r r r Zzmq.utils.strtypesr �python_implementationr� r rr r �bool�environrJ r r� r r r r r r r �<module> s: (
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка