Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/tcpclient_test.cpython-39.pyc
Ðазад
a _�h�B � @ s d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z d dl m Z d dl m Z mZ d dlmZ d dlmZmZ d d lmZmZmZ d d lmZ d dlZejr�d d l m Z d d lm Z m Z m Z d \Z!Z"G dd� de�Z#G dd� de�Z$G dd� dej%�Z&G dd� de�Z'dS )� )�closingN��Future)� bind_sockets�Resolver)�Queue)� TCPClient� _Connector)� TCPServer)� AsyncTestCase�gen_test)� skipIfNoIPv6� refusing_port� skipIfNonUnix)� TimeoutError)�IOStream)�List�Dict�Tuple)� � c s0 e Zd Z� fdd�Zdd� Z� fdd�Z� ZS )� TestTCPServerc sH t t| ��� g | _t� | _tdd|�}| �|� |d �� d | _ d S )Nr � localhostr ) �superr �__init__�streamsr �queuer Z add_sockets� getsockname�port)�self�familyZsockets�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/tcpclient_test.pyr ) s zTestTCPServer.__init__c C s | j �|� | j�|� d S �N)r �appendr �put)r �stream�addressr# r# r$ � handle_stream1 s zTestTCPServer.handle_streamc s& t t| ��� | jD ] }|�� qd S r% )r r �stopr �close�r r( r! r# r$ r+ 5 s zTestTCPServer.stop)�__name__� __module__� __qualname__r r* r+ � __classcell__r# r# r! r$ r ( s r c s� e Zd Z� fdd�Zdd� Zdd� Z� fdd�Zd d � Zed&d d ��Z dd� Z dd� Z e dd� �Z e dd� �Zdd� Ze dd� �Zdd� Zed d � �Zd d � Zd d!� Zed"d#� �Zed$d%� �Z� ZS )'� TCPClientTestc s t t| ��� d | _t� | _d S r% )r r2 �setUp�serverr �client�r r! r# r$ r3 < s zTCPClientTest.setUpc C s0 |t jkr dtjv r | �d� t|�| _| jjS )NZTRAVISz6dual-stack servers often have port conflicts on travis)�socket� AF_UNSPEC�os�environ�skipTestr r4 r )r r r# r# r$ � start_serverA s zTCPClientTest.start_serverc C s | j d ur| j �� d | _ d S r% )r4 r+ r6 r# r# r$ � stop_serverG s zTCPClientTest.stop_serverc s$ | j �� | �� tt| ��� d S r% )r5 r, r= r r2 �tearDownr6 r! r# r$ r> L s zTCPClientTest.tearDownc C s: | j �dd� �}tdd� |D ��}tj|vr6| �d� d S )Nc S s t � �dd�S )Nr �P )r �resolver# r# r# r$ �<lambda>T � z1TCPClientTest.skipIfLocalhostV4.<locals>.<lambda>c s s | ]}|d V qdS )r Nr# )�.0�addrr# r# r$ � <genexpr>U rB z2TCPClientTest.skipIfLocalhostV4.<locals>.<genexpr>z"localhost does not resolve to ipv6)�io_loopZrun_sync�setr7 �AF_INET6r; )r �addrinfoZfamiliesr# r# r$ �skipIfLocalhostV4Q s z TCPClientTest.skipIfLocalhostV4Nc c s| | � |�}| jj||||d�V }| jj�� V }t|��2 |�d� |�d�V }| � |d� W d � n1 sn0 Y d S )N)� source_ip� source_ports hello� ) r< r5 �connectr4 r �getr �write� read_bytes� assertEqual) r r �hostrK rL r r( Z server_stream�datar# r# r$ �do_test_connectY s � z TCPClientTest.do_test_connectc C s | � tjd� d S �N� 127.0.0.1�rU r7 �AF_INETr6 r# r# r$ �test_connect_ipv4_ipv4e s z$TCPClientTest.test_connect_ipv4_ipv4c C s | � tjd� d S �Nr rX r6 r# r# r$ �test_connect_ipv4_dualh s z$TCPClientTest.test_connect_ipv4_dualc C s | � � | �tjd� d S �Nz::1)rJ rU r7 rH r6 r# r# r$ �test_connect_ipv6_ipv6k s z$TCPClientTest.test_connect_ipv6_ipv6c C s4 | � � t�� j�d�r"| �d� | �tjd� d S )NZTwistedResolverz3TwistedResolver does not support multiple addressesr ) rJ r Zconfigured_classr. �endswithr; rU r7 rH r6 r# r# r$ �test_connect_ipv6_dualp s z$TCPClientTest.test_connect_ipv6_dualc C s | � tjd� d S rV �rU r7 r8 r6 r# r# r$ �test_connect_unspec_ipv4w s z&TCPClientTest.test_connect_unspec_ipv4c C s | � � | �tjd� d S r] )rJ rU r7 r8 r6 r# r# r$ �test_connect_unspec_ipv6z s z&TCPClientTest.test_connect_unspec_ipv6c C s | � tjd� d S r[ ra r6 r# r# r$ �test_connect_unspec_dual s z&TCPClientTest.test_connect_unspec_dualc c sR t � \}}| �|� | �t�� | j�d|�V W d � n1 sD0 Y d S rV )r Z addCleanup� assertRaises�IOErrorr5 rN )r Z cleanup_funcr r# r# r$ �test_refused_ipv4� s z TCPClientTest.test_refused_ipv4c C s | j tj| jtjddd� dS )zJ Fail when trying to use the source IP Address '8.8.8.8'. rW z8.8.8.8�rK N�re r7 �errorrU rY r6 r# r# r$ �test_source_ip_fail� s �z!TCPClientTest.test_source_ip_failc C s | j tjddd� dS )zN Success when trying to use the source IP Address '127.0.0.1' rW rh NrX r6 r# r# r$ �test_source_ip_success� s z$TCPClientTest.test_source_ip_successc C s | j tj| jtjddd� dS )z8 Fail when trying to use source port 1. rW r )rL Nri r6 r# r# r$ �test_source_port_fail� s �z#TCPClientTest.test_source_port_failc c s\ d}G dd� dt �}| �t��* t|� d�jdd|d�V W d � n1 sN0 Y d S )Ng�������?c @ s e Zd Zdd� ZdS )z;TCPClientTest.test_connect_timeout.<locals>.TimeoutResolverc _ s t � S r% r )r �args�kwargsr# r# r$ r@ � s zCTCPClientTest.test_connect_timeout.<locals>.TimeoutResolver.resolveN)r. r/ r0 r@ r# r# r# r$ �TimeoutResolver� s rp )�resolverz1.2.3.4i90 )�timeout)r re r r rN )r rr rp r# r# r$ �test_connect_timeout� s �z"TCPClientTest.test_connect_timeout)NN)r. r/ r0 r3 r< r= r> rJ r rU rZ r\ r r^ r` rb rc rd rg rk rl r rm rs r1 r# r# r! r$ r2 ; s2 r2 c @ s e Zd Zdd� Zdd� ZdS )�TestConnectorSplitc C sB t �tdftdfg�\}}| �|tdftdfg� | �|g � d S )N�a�b)r �split�AF1rR �r �primaryZ secondaryr# r# r$ �test_one_family� s z"TestConnectorSplit.test_one_familyc C sZ t �tdftdftdftdfg�\}}| �|tdftdfg� | �|tdftdfg� d S �Nru rv �c�d)r rw rx �AF2rR ry r# r# r$ � test_mixed� s �z TestConnectorSplit.test_mixedN)r. r/ r0 r{ r� r# r# r# r$ rt � s rt c s� e Zd ZG dd� de�Z� fdd�Z� fdd�Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z� Z S )1� ConnectorTestc @ s e Zd Zdd� Zdd� ZdS )zConnectorTest.FakeStreamc C s d| _ d S )NF��closedr6 r# r# r$ r � s z!ConnectorTest.FakeStream.__init__c C s d| _ d S )NTr� r6 r# r# r$ r, � s z ConnectorTest.FakeStream.closeN)r. r/ r0 r r, r# r# r# r$ � FakeStream� s r� c s< t t| ��� i | _i | _tdftdftdftdfg| _d S r| )r r� r3 �connect_futuresr rx r rI r6 r! r# r$ r3 � s �zConnectorTest.setUpc s. | j �� D ]}| �|j� q tt| ��� d S r% )r �values� assertFalser� r r� r> r- r! r# r$ r> � s zConnectorTest.tearDownc C s. t �� }|| j|< t� }|| j||f< ||fS r% )r� r� r r r� )r �afrD r( �futurer# r# r$ � create_stream� s zConnectorTest.create_streamc G s | � t| j�� �t|�� d S r% )rR �sortedr� �keys)r r� r# r# r$ �assert_pending� s z ConnectorTest.assert_pendingc C sX | j �||f�}|r&|�| j| � n| j�|� |�t� � | j�| j� | � � d S r% ) r� �popZ set_resultr Z set_exceptionrf rF Z add_callbackr+ �wait)r r� rD �successr� r# r# r$ �resolve_connect� s z ConnectorTest.resolve_connectc C s |j D ]}| �|j� qd S r% )r � assertTruer� )r �connr( r# r# r$ � assert_connector_streams_closed� s z-ConnectorTest.assert_connector_streams_closedc C s, t || j�}|jd| j�� d d�}||fS )Ni )�connect_timeout)r r� �startrF �time)r rI r� r� r# r# r$ � start_connect� s zConnectorTest.start_connectc C sZ | � | j�\}}| �t| j�� �tdfg� | �tdd� | �|�� td| j d f� d S )Nru T) r� rI rR �listr� r� rx r� �resultr �r r� r� r# r# r$ �test_immediate_success� s z$ConnectorTest.test_immediate_successc C sB | � tdfg�\}}| �tdf� | �tdd� | �t|j� d S )Nru F�r� rx r� r� re rf r� r� r# r# r$ �test_immediate_failure s z$ConnectorTest.test_immediate_failurec C sr | � tdftdfg�\}}| �tdf� | �tdd� | �tdf� | �tdd� | �|�� td| jd f� d S �Nru rv FT)r� rx r� r� rR r� r r� r# r# r$ �test_one_family_second_try s z(ConnectorTest.test_one_family_second_tryc C sd | � tdftdfg�\}}| �tdf� | �tdd� | �tdf� | �tdd� | �t|j� d S )Nru rv Fr� r� r# r# r$ �"test_one_family_second_try_failure s z0ConnectorTest.test_one_family_second_try_failurec C s� | � tdftdfg�\}}| �tdf� |�� | �tdf� | �tdd� | �tdf� | �tdd� | �|�� td| jd f� d S r� )r� rx r� � on_timeoutr� rR r� r r� r# r# r$ �"test_one_family_second_try_timeout s z0ConnectorTest.test_one_family_second_try_timeoutc C s| | � | j�\}}| �tdf� | �tdd� | �tdftdf� | �tdd� | �tdd� | �|�� td| jd f� d S )Nru Frv r} T) r� rI r� rx r� r rR r� r r� r# r# r$ �#test_two_families_immediate_failure$ s z1ConnectorTest.test_two_families_immediate_failurec C s~ | � | j�\}}| �tdf� |�� | �tdftdf� | �tdd� | �|�� td| j d f� | �tdd� | �� d S )Nru r} TF) r� rI r� rx r� r r� rR r� r r� r# r# r$ �test_two_families_timeout- s z'ConnectorTest.test_two_families_timeoutc C s� | � | j�\}}| �tdf� |�� | �tdftdf� | �tdd� | �|�� td| j d f� | �tdd� | � | j � d�j � d S )Nru r} T) r� rI r� rx r� r r� rR r� r r� r� r� r� r# r# r$ �test_success_after_timeout8 s z(ConnectorTest.test_success_after_timeoutc C s� | � | j�\}}| �tdf� |�� | �tdftdf� | �tdd� | �tdftdf� | �tdd� | �tdf� | �tdd� | �tdf� | �|�� � | �tdd� | � t |j � d S )Nru r} Fr~ rv ) r� rI r� rx r� r r� r� �donere rf r� r� r# r# r$ � test_all_failC s zConnectorTest.test_all_failc C s� | � tdftdfg�\}}| �tdf� |�� | j�tdf� | �| j�d�j� |� � | �� | � t |j�d� | � |� | � t|j� d S )Nru rv r )r� rx r� �on_connect_timeoutr� r� r� r r� r� rR �lenr� re r r� r� r# r# r$ �-test_one_family_timeout_after_connect_timeoutS s z;ConnectorTest.test_one_family_timeout_after_connect_timeoutc C s� | � tdftdfg�\}}| �tdf� | �tdd� |�� | �� | �| jd jd� | �t|j�d� | � |� | �|� � td| jd f� d S )Nru rv TFr ) r� rx r� r� r� rR r r� r� r� r� r� r# r# r$ �.test_one_family_success_before_connect_timeoutc s z<ConnectorTest.test_one_family_success_before_connect_timeoutc C s� | � tdftdfg�\}}| �tdf� | �tdd� | �tdf� |�� | j�tdf� | �| j�d�j � | �� | � t |j�d� | � |� | � t|j� d S �Nru rv Fr )r� rx r� r� r� r� r� r� r r� rR r� r� re r r� r� r# r# r$ �0test_one_family_second_try_after_connect_timeoutp s z>ConnectorTest.test_one_family_second_try_after_connect_timeoutc C s� | � tdftdfg�\}}| �tdf� | �tdd� | �tdf� | �tdd� |�� | �� | �t|j�d� | �|� | � t |j � d S r� ) r� rx r� r� r� rR r� r r� re rf r� r� r# r# r$ �9test_one_family_second_try_failure_before_connect_timeout} s zGConnectorTest.test_one_family_second_try_failure_before_connect_timeoutc C s� | � | j�\}}| �tdf� |�� | �tdftdf� |�� | j�tdf� | � | j �d�j � | j�tdf� | � | j �d�j � | �� | � t |j �d� | �|� | �t|j� d S )Nru r} r )r� rI r� rx r� r r� r� r� r� r r� rR r� r� re r r� r� r# r# r$ �.test_two_family_timeout_before_connect_timeout� s z<ConnectorTest.test_two_family_timeout_before_connect_timeoutc C s� | � | j�\}}| �tdf� |�� | �tdftdf� | �tdd� | j�tdf� | � | j �d�j � | �� | � t |j �d� | �|� | � |�� td| j d f� d S )Nru r} Tr )r� rI r� rx r� r r� r� r� r� r r� rR r� r� r� r� r# r# r$ �%test_two_family_success_after_timeout� s z3ConnectorTest.test_two_family_success_after_timeoutc C s� | � | j�\}}| �tdf� |�� | j�tdf� | �| j�d�j � | �� |� � | �� | � t |j�d� | � |� | �t|j� d S )Nru r )r� rI r� rx r� r� r� r� r r� r� rR r� r� re r r� r� r# r# r$ �-test_two_family_timeout_after_connect_timeout� s z;ConnectorTest.test_two_family_timeout_after_connect_timeout) r. r/ r0 �objectr� r3 r> r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r# r# r! r$ r� � s0 r� )(� contextlibr r9 r7 ZunittestZtornado.concurrentr Ztornado.netutilr r Ztornado.queuesr Ztornado.tcpclientr r Ztornado.tcpserverr Ztornado.testingr r Ztornado.test.utilr r r Z tornado.genr �typing� TYPE_CHECKINGZtornado.iostreamr r r r rx r r r2 ZTestCasert r� r# r# r# r$ �<module> s( {
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка