Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/iostream_test.cpython-39.pyc
Ðазад
a _�hb� � @ s d dl mZ d dlmZ d dlmZ d dlmZmZmZm Z m Z d dl m Z d dl mZmZ d dlmZ d dlmZ d d lmZ d d lmZmZmZmZmZm Z d d l m Z m Z m Z d d l!m"Z"m#Z# d d l$Z$d d l%Z%d d l&Z&d d l'Z'd d l(Z(d d l)Z)d d l*Z*d d l+Z+d d l,Z,d d l-Z-d dl.m/Z/ d d l.Z.dd� Z0G dd� de"�Z1G dd� de2�Z3G dd� de2�Z4G dd� de4�Z5G dd� de3e�Z6G dd � d e3e�Z7G d d � d e5e�Z8G d d � d e5e�Z9G d!d"� d"e5e�Z:G d#d$� d$e�Z;G d%d&� d&e�Z<e G d'd(� d(e4e��Z=G d)d*� d*e.j>�Z?d S )+� )�Future)�gen)�netutil)�IOStream� SSLIOStream� PipeIOStream�StreamClosedError� _StreamBuffer)� HTTPHeaders)� Condition�Event)�gen_log)�ssl_wrap_socket)� TCPServer)�AsyncHTTPTestCase�AsyncHTTPSTestCase� AsyncTestCase�bind_unused_port� ExpectLog�gen_test)� skipIfNonUnix� refusing_port� skipPypy3V58)�RequestHandler� ApplicationN)�mockc C s0 t tj�tj�t�d�tj�tj�t�d�d�S )N�test.crt�test.key)�certfile�keyfile)�dict�os�path�join�dirname�__file__� r& r& ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/iostream_test.py�_server_ssl_options( s �r( c @ s e Zd Zdd� ZdS )� HelloHandlerc C s | � d� d S )NZHello)�write��selfr& r& r' �get0 s zHelloHandler.getN)�__name__� __module__� __qualname__r- r& r& r& r' r) / s r) c @ sl e Zd Zdd� Zdd� Zdd� Zedd� �Zed d � �Zed d � �Z ed d� �Z edd� �Z edd� �Z dS )�TestIOStreamWebMixinc C s t � �d S �N��NotImplementedErrorr+ r& r& r' �_make_client_iostream5 s z*TestIOStreamWebMixin._make_client_iostreamc C s t dtfg�S )N�/)r r) r+ r& r& r' �get_app8 s z TestIOStreamWebMixin.get_appc C s | j dddid�}|�� d S )Nr6 � Connection�close)�headers)�fetchZrethrow)r, �responser& r& r' �test_connection_closed; s z+TestIOStreamWebMixin.test_connection_closedc c sT | � � }|�d| �� f�V |�d� |�� V }| �|�d�� | �|�d�� d S )N� 127.0.0.1� GET / HTTP/1.0 s HTTP/1.1 200� Hello)r5 �connect� get_http_portr* �read_until_close� assertTrue� startswith�endswith)r, �stream�datar& r& r' �test_read_until_closeE s z*TestIOStreamWebMixin.test_read_until_closec c s� | � � | _| j�d| �� f�V | j�d� | j�d�V }| �|d� | j�d�V }| �|d� | j�d�V }| �|d� | j�� d S ) Nr> r? � s HTTP/1.1 r � � s 200)r5 rG rA rB r* � read_bytes� assertEqualr9 )r, rH r& r& r' �test_read_zero_bytesO s z)TestIOStreamWebMixin.test_read_zero_bytesc c s� | � � }|�d| �� f�}|�d�}| �|�� � t�||�}g }|�� sb|�� V |� |j � qB| � |||g� |� � V }| � |�d�� |�� d S )Nr> �% GET / HTTP/1.0 Connection: close r@ )r5 rA rB r* � assertFalse�doner Z WaitIterator�next�appendZcurrent_futurerN rC rD rF r9 )r, rG � connect_futZ write_fut�itZresolved_orderrH r& r& r' �test_write_while_connectingc s z0TestIOStreamWebMixin.test_write_while_connectingc c s� | � � }|�d| �� f�V }| �||� |�d�V |�d�V }| �|d� |�d�V }t�|� d��}t |d �}|� |�V }| �|d� |� � d S ) z3Basic test of IOStream's ability to return Futures.r> r? � s HTTP/1.1 200 OK � �latin1zContent-Lengthr@ N) r5 rA rB ZassertIsr* � read_untilrN r �parse�decode�intrM r9 )r, rG Zconnect_result� first_lineZ header_datar: �content_length�bodyr& r& r' �test_future_interfacey s z*TestIOStreamWebMixin.test_future_interfacec c sj | � � }|�d| �� f�V |�d�V | �t�� |�d�V W d � n1 sT0 Y |�� d S )Nr> r? � )r5 rA rB r* � assertRaisesr rM r9 �r, rG r& r& r' � test_future_close_while_reading� s *z4TestIOStreamWebMixin.test_future_close_while_readingc c s� | � � }|�d| �� f�V |�d�V |�d�V |�� V }| �|d� | �t�� |� d� W d � n1 st0 Y d S )Nr> rP rY r@ � ) r5 rA rB r* r[ rC rN rd r rM )r, rG ra r& r& r' � test_future_read_until_close� s z1TestIOStreamWebMixin.test_future_read_until_closeN) r. r/ r0 r5 r7 r= r rI rO rW rb rf rh r& r& r& r' r1 4 s r1 c @ sL e Zd Zdd� Zdd� Zedd� �Zedd� �Zed d � �Zed d � �Z ed d� �Z edd� �Z ee j d�dd��Zee j d�dd��Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Zed*d+� �Zed,d-� �Zed.d/� �Z ed0d1� �Z ed2d3� �Z ed4d5� �Z d6S )7�TestReadWriteMixinc K s t �d S r2 r3 )r, �kwargsr& r& r' �make_iostream_pair� s z%TestReadWriteMixin.make_iostream_pairc K s G dd� d�}|| |�S )z�Like make_iostream_pair, but called by ``async with``. In py37 this becomes simpler with contextlib.asynccontextmanager. c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z=TestReadWriteMixin.iostream_pair.<locals>.IOStreamPairContextc S s || _ || _d S r2 )�testrj )r, rl rj r& r& r' �__init__� s zFTestReadWriteMixin.iostream_pair.<locals>.IOStreamPairContext.__init__c � s" | j jf i | j��I d H | _| jS r2 )rl rk rj �pairr+ r& r& r' � __aenter__� s zHTestReadWriteMixin.iostream_pair.<locals>.IOStreamPairContext.__aenter__c � s | j D ] }|�� qd S r2 )rn r9 )r, �typ�value�tb�sr& r& r' � __aexit__� s zGTestReadWriteMixin.iostream_pair.<locals>.IOStreamPairContext.__aexit__N)r. r/ r0 rm ro rt r& r& r& r' �IOStreamPairContext� s ru r& )r, rj ru r& r& r' � iostream_pair� s z TestReadWriteMixin.iostream_pairc c s. | � � V \}}|�d�V |�� |�� d S )NrK )rk r* r9 )r, �rs�wsr& r& r' �test_write_zero_bytes� s z(TestReadWriteMixin.test_write_zero_bytesc c s� | � � V \}}z^|�d� g }|�|�d�V � |�� |�|�d�V � | �|ddg� W |�� |�� n|�� |�� 0 d S )N� 12rg � 1� 2)rk r* rT rM r9 rN )r, rw rx �chunksr& r& r' �"test_future_delayed_close_callback� s �z5TestReadWriteMixin.test_future_delayed_close_callbackc c s� | j dd�V \}}zb|�d� |�d�V }| �d|� |�� t�d�V |�d�V }| �d|� W |�� |�� n|�� |�� 0 d S )N� )Zread_chunk_sizes AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAs AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAg{�G�z�?)rk r* rM rN r9 r �sleep�r, rw rx rH r& r& r' �test_close_buffered_data� s �z+TestReadWriteMixin.test_close_buffered_datac c sz | � � V \}}zT|�d� |�� |�d�V }| �|d� |�� V }| �|d� W |�� |�� n|�� |�� 0 d S )Ns 1234rg r{ s 234)rk r* r9 rM rN rC r� r& r& r' �!test_read_until_close_after_close� s �z4TestReadWriteMixin.test_read_until_close_after_closec c s� | � � V \}}z~t|t�r0t�� dkr0t�d��d}t|�D ]}|�d� q<|�d� |� d�V }| � t |�|d d � W |� � |� � n|� � |� � 0 d S )N�PyPyz$pypy gc causes problems with openssl� s AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAArX � � ) rk � isinstancer �platform�python_implementation�unittestZSkipTest�ranger* r[ rN �lenr9 )r, rw rx ZNUM_KB�irH r& r& r' �test_large_read_until s" � � �z(TestReadWriteMixin.test_large_read_untilc � s� | � � 4 I d H �V\}}t�|�d��}|�d�I d H |�d� |�� |I d H W d �I d H q|1 I d H sr0 Y d S )N� done� xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx)rv �asyncio� ensure_futurer[ r* r9 �r, rw rx �rfr& r& r' �.test_read_until_with_close_after_second_packet s zATestReadWriteMixin.test_read_until_with_close_after_second_packetr+ c � s� | � � 4 I d H ��\}}t�|�d��}|�d�I d H |�d� |�� | �t�� |I d H W d � n1 sr0 Y W d �I d H q�1 I d H s�0 Y d S )Nr� r� s foo)rv r� r� r[ r* r9 rd r r� r& r& r' �'test_read_until_unsatisfied_after_close2 s z:TestReadWriteMixin.test_read_until_unsatisfied_after_closec c s� d}| � � V \}}t� }|�|j� zR|�|� |�d�V }| �||� |�� |�d� |�� V W |�� |�� n|�� |�� 0 d S )Ns OK rX ) rk r �set_close_callback�setr* r[ rN r9 �wait)r, �OKrw rx �event�resr& r& r' �%test_close_callback_with_pending_read@ s �z8TestReadWriteMixin.test_close_callback_with_pending_readc # s� | � � V \}}dg� t� �� �fdd�}|�|� zd|�d� |�d�V }| �|d� | �� d � |�� ��� V | � � d � W |�� |�� n|�� |�� 0 d S )NFc s d� d< �� � d S )NTr )�notifyr& ��closedZcondr& r' �close_callback` s zETestReadWriteMixin.test_future_close_callback.<locals>.close_callback� arg r ) rk r r� r* rM rN rQ r9 r� rD )r, rw rx r� r� r& r� r' �test_future_close_callbackX s" �z-TestReadWriteMixin.test_future_close_callbackc c sd | � � V \}}z>|�d�}|�td�� |V }| �|d� W |�� |�� n|�� |�� 0 d S )N� � hellos hell)rk rM r* � memoryviewrN r9 �r, rw rx �futrH r& r& r' �test_write_memoryviewq s �z(TestReadWriteMixin.test_write_memoryviewc c s� | � � V \}}z�|jddd�}|�d� |V }| �|d� |jddd�}|�d� |V }| �|d� |jddd�V }| �|d � W |�� |�� n|�� |�� 0 d S ) N�2 T��partialr� rL s world� worr rK )rk rM r* rN r9 r� r& r& r' �test_read_bytes_partial} s �z*TestReadWriteMixin.test_read_bytes_partialc c s� | � � V \}}t� }|�|j� z�|jddd�}|�d� |V }| �|d� |jddd�}|�d� |V }| �|d� ttd��2 |jddd�}|�d� |� � V W d � n1 s�0 Y W |� � |� � n|� � |� � 0 d S � N� defr� �Z max_bytes� abcdef� �Unsatisfiable read� � 123456) rk r r� r� r[ r* rN r r r� r9 �r, rw rx r� r� rH r& r& r' �test_read_until_max_bytes� s( * �z,TestReadWriteMixin.test_read_until_max_bytesc c s� | � � V \}}t� }|�|j� z�|�d� ttd��J | �t�� |j ddd�V W d � n1 sh0 Y W d � n1 s�0 Y |� � V W |� � |� � n|� � |� � 0 d S �Nr� r� r� r� r� ) rk r r� r� r* r r rd r r[ r� r9 �r, rw rx r� r& r& r' � test_read_until_max_bytes_inline� s L �z3TestReadWriteMixin.test_read_until_max_bytes_inlinec c s� | � � V \}}t� }|�|j� z`|�d� ttd��( |jddd� |�� V W d � n1 sd0 Y W |� � |� � n|� � |� � 0 d S �Nr� r� r� r� r� ) rk r r� r� r* r r r[ r� r9 r� r& r& r' �'test_read_until_max_bytes_ignores_extra� s * �z:TestReadWriteMixin.test_read_until_max_bytes_ignores_extrac c s� | � � V \}}t� }|�|j� z�|jddd�}|�d� |V }| �|d� |jddd�}|�d� |V }| �|d� ttd��2 |jddd� |�d� |� � V W d � n1 s�0 Y W |� � |� � n|� � |� � 0 d S r� ) rk r r� r� �read_until_regexr* rN r r r� r9 r� r& r& r' � test_read_until_regex_max_bytes� s( * �z2TestReadWriteMixin.test_read_until_regex_max_bytesc c s� | � � V \}}t� }|�|j� z`|�d� ttd��( |jddd� |�� V W d � n1 sd0 Y W |� � |� � n|� � |� � 0 d S r� � rk r r� r� r* r r r� r� r9 r� r& r& r' �&test_read_until_regex_max_bytes_inline� s * �z9TestReadWriteMixin.test_read_until_regex_max_bytes_inlinec c s� | � � V \}}t� }|�|j� z`|�d� ttd��( |jddd� |�� V W d � n1 sd0 Y W |� � |� � n|� � |� � 0 d S r� r� r� r& r& r' �-test_read_until_regex_max_bytes_ignores_extra s * �z@TestReadWriteMixin.test_read_until_regex_max_bytes_ignores_extrac c sr | j dd�V \}}zH|�dd � td�D ] }|�d�V }| �|d� q*W |�� |�� n|�� |�� 0 d S )N� ( ��max_buffer_sizes aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa�d r� )rk r* r� rM rN r9 �r, rw rx r� rH r& r& r' �"test_small_reads_from_large_buffer s �z5TestReadWriteMixin.test_small_reads_from_large_bufferc c sv | j dd�V \}}zL|�dd � td�D ] }|jddd�V }| �|d� q*W |�� |�� n|�� |�� 0 d S )Nr� r� s aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa r� � r� r� )rk r* r� r[ rN r9 r� r& r& r' �(test_small_read_untils_from_large_buffer$ s �z;TestReadWriteMixin.test_small_read_untils_from_large_bufferc c s� d}| j d| d�V \}}zT|�d| � |�|�V t�d�V td�D ]}|�|�V qJW |�� |�� n|�� |�� 0 d S )Nrc r� r� s aaaaaaaaaag�������?rJ )rk r* rM r r� r� r9 )r, �MBrw rx r� r& r& r' �test_flow_control3 s �z$TestReadWriteMixin.test_flow_controlc # sh � � � V \}}� fdd�}�z4td�}|�|�}|�d� t�d�V � �|�� � |�d� |V }� �|�� � � � |d� � � t |�d� |�|�}t�d�V � �|�� � |�d� |V }� �|�� � � � |d� � � t |�d � td �}|�d � |�|�V }� � |d � � � t |�d � |� d �V }� � |d� W |� � |� � n|� � |� � 0 d S )Nc s � j �dd� � d S )Nc S s t �d�S )N皙�����?)r r� r& r& r& r' �<lambda>J rK zGTestReadWriteMixin.test_read_into.<locals>.sleep_some.<locals>.<lambda>)�io_loopZrun_syncr& r+ r& r' � sleep_someI s z5TestReadWriteMixin.test_read_into.<locals>.sleep_some� r� r� s world!!s helloworlds 1234567890s !!12345678r� s abcdefghis 90ab� s cdefghi) rk � bytearray� read_intor* r r� rD �readingrQ rN �bytesrM r9 )r, rw rx r� �bufr� rH r& r+ r' �test_read_intoE s@ �z!TestReadWriteMixin.test_read_intoc c s� | � � V \}}z�td�}|j|dd�}|�d� |V }| �|�� � | �|d� | �t|�d� |�d� |j|dd�V }| �|d� | �t|�d� |j|dd�V }| �|d � | �t|�d � W |�� |�� n|�� |�� 0 d S ) Nr� Tr� r� r� s hello s world!1234567890s world!1234r� s 5678901234) rk r� r� r* rQ r� rN r� r9 )r, rw rx r� r� rH r& r& r' �test_read_into_partialo s( �z)TestReadWriteMixin.test_read_into_partialc c sZ | � � V \}}z4t� }|�|�}| �|�� d� W |�� |�� n|�� |�� 0 d S �Nr )rk r� r� rN �resultr9 )r, rw rx r� r� r& r& r' �test_read_into_zero_bytes� s �z,TestReadWriteMixin.test_read_into_zero_bytesc # s� t �d��d�| �� V \��t�� �t�� � tj����fdd��}tj� ���fdd��}z6|� |� gV ��� � �� ks�J �W ��� ��� n��� ��� 0 d S )N�* i@B c 3 sX � } | dkrH�� dtd| ��}t�|�}��|� ��|�V | |8 } q| dksTJ �d S )Nr rg �� )�randint�minr! �urandom�updater* )� remaining�sizerH )�nbytes� produce_hash�rrx r& r' �produce� s z9TestReadWriteMixin.test_many_mixed_reads.<locals>.producec 3 s� �} | dkr��� � dkrJ��dtd| ��}��|�V }� �|� | |8 } q��dtd| ��}t|�}��|�V }||ks|J �� �|� | |8 } q| dks�J �d S )Nr g �?rg r� )�randomr� r� rM r� r� r� )r� r� rH r� �n)� consume_hashr� r� rw r& r' �consume� s z9TestReadWriteMixin.test_many_mixed_reads.<locals>.consume) r� �Randomrk �hashlib�sha1r � coroutine� hexdigestr9 )r, r� r� r& )r� r� r� r� rw rx r' �test_many_mixed_reads� s �z(TestReadWriteMixin.test_many_mixed_readsN) r. r/ r0 rk rv r ry r~ r� r� r� r� �typing�Anyr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r& r& r& r' ri � sd ) ri c @ s~ e Zd Zdd� Zdd� Zejdd� �Zedd� �Z ed d � �Z ed d � �Z e e ed d� ���Ze edd� ��Zedd� �ZdS )�TestIOStreamMixinc K s t � �d S r2 r3 �r, � connectionrj r& r& r' �_make_server_iostream� s z'TestIOStreamMixin._make_server_iostreamc K s t � �d S r2 r3 r� r& r& r' r5 � s z'TestIOStreamMixin._make_client_iostreamc + s� t � \}}t� �� ��fdd�}t�||� �jt�� fi � ��}|�d|f�}�|gV \}}�j�|� � � |� � t � ||f��d S )Nc s �� �j| fi � ��� d S r2 )� set_resultr� )r� �address�rj r, Zserver_stream_futr& r' �accept_callback� s �z=TestIOStreamMixin.make_iostream_pair.<locals>.accept_callbackr> ) r r r �add_accept_handlerr5 �socketrA r� Zremove_handler�filenor9 r �Return)r, rj �listener�portr� � client_streamrU � server_streamr& r� r' rk � s z$TestIOStreamMixin.make_iostream_pairc c s� t � \}}| �|� tt�� �}|�| j� ttddd��J | �t �� |� d|f�V W d � n1 sl0 Y W d � n1 s�0 Y | � t |j tj �|j � tjdkr�tjg}ttd�r�|�tj� | � |j jd |v � d S )Nz.*F)�requiredr> �cygwin�WSAECONNREFUSEDr )r Z addCleanupr r� r� �stopr r rd r rA rD r� �error�sysr� �errnoZ ECONNREFUSED�hasattrrT r �args)r, Z cleanup_funcr rG Z_ERRNO_CONNREFUSEDr& r& r' �test_connection_refused� s L z)TestIOStreamMixin.test_connection_refusedc c s� t � t jt jd�}t|�}|�| j� tjdt �t j d�d��Z | � t �� |� d�V W d � n1 sl0 Y | �t|jt j�� W d � n1 s�0 Y d S )Nr zsocket.socket.connect�boom�Z side_effect)� localhost�P )r� �AF_INET� SOCK_STREAMr r� r r �patch�gaierrorr ZEIOrd r rA rD r� r )r, rs rG r& r& r' � test_gaierror� s � *z TestIOStreamMixin.test_gaierrorc c s� | � � V \}}zztjdtd�d��D | �td�� |�� W d � n1 sN0 Y W d � n1 sl0 Y W |�� |�� n|�� |�� 0 d S )Nz.tornado.iostream.BaseIOStream._try_inline_readr r )rk r r �IOErrorZassertRaisesRegexprC r9 �r, �server�clientr& r& r' � test_read_until_close_with_error s �F �z2TestIOStreamMixin.test_read_until_close_with_errorc c s� | � � V \}}zZt�|j�� � | �tj�� |�d� W d � n1 sL0 Y W |�� |�� n|�� |�� 0 d S )Nrg )rk r! r9 r� r rd r rM r r& r& r' �test_inline_read_error s * �z(TestIOStreamMixin.test_inline_read_errorc # s� | � � V \� }t� }� �|j� zn� �d� |�d� � fdd�}|� _ttd�� |� � V W d � n1 sr0 Y W � � � |� � n� � � |� � 0 d S )Nrg r� c s t �� j�� � � j�� � d S r2 )r! r9 r� r � __class__� read_from_fdr& �r r& r' �fake_read_from_fd< s zJTestIOStreamMixin.test_async_read_error_logging.<locals>.fake_read_from_fdz error on read) rk r r� r� rM r* r r r r� r9 )r, r r� r" r& r! r' � test_async_read_error_logging. s * �z/TestIOStreamMixin.test_async_read_error_loggingc # s� d\��d}�� | �| j �d�V \�� tj���fdd���tj� ��fdd��}z4�fdd �t|�D �|� g V W ��� � �� n��� � �� 0 d S ) z? Test that write() Futures are never orphaned. )i� r� r� r� c 3 s& d� } t ��D ]}��| �V qd S )N� x)r� r* )rH r� )�mr� r r& r' r� T s z4TestIOStreamMixin.test_future_write.<locals>.producec 3 s* d} | �k r&� � ��V }| t|�7 } qd S r� )rM r� )Znreadr� )r r% � total_bytesr& r' r� Z s z4TestIOStreamMixin.test_future_write.<locals>.consumec s g | ] }� � �qS r& r& )�.0r� )r� r& r' � <listcomp>b rK z7TestIOStreamMixin.test_future_write.<locals>.<listcomp>N)rk r r� r� r9 )r, Z nproducersr� r& )r r% r� r� r r& r' �test_future_writeH s " �z#TestIOStreamMixin.test_future_writeN)r. r/ r0 r� r5 r r� rk r r r r r r r r# r) r& r& r& r' r� � s& r� c @ s e Zd Zdd� ZdS )�TestIOStreamWebHTTPc C s t t�� �S r2 )r r� r+ r& r& r' r5 i s z)TestIOStreamWebHTTP._make_client_iostreamN�r. r/ r0 r5 r& r& r& r' r* h s r* c @ s e Zd Zdd� ZdS )�TestIOStreamWebHTTPSc C s t t�� ttjd�d�S )N�� cert_reqs�� ssl_options)r r� r �ssl� CERT_NONEr+ r& r& r' r5 n s z*TestIOStreamWebHTTPS._make_client_iostreamNr+ r& r& r& r' r, m s r, c @ s e Zd Zdd� Zdd� ZdS )� TestIOStreamc K s t |fi |��S r2 �r r� r& r& r' r� s s z"TestIOStream._make_server_iostreamc K s t |fi |��S r2 r4 r� r& r& r' r5 v s z"TestIOStream._make_client_iostreamN�r. r/ r0 r� r5 r& r& r& r' r3 r s r3 c @ s e Zd Zdd� Zdd� ZdS )�TestIOStreamSSLc K s* t j|fddd�t� ��}t|fi |��S )NTF�� server_side�do_handshake_on_connect)r1 � wrap_socketr( r r� r& r& r' r� { s ���z%TestIOStreamSSL._make_server_iostreamc K s t |fdttjd�i|��S )Nr0 r- )r r r1 r2 r� r& r& r' r5 � s � ��z%TestIOStreamSSL._make_client_iostreamNr5 r& r& r& r' r6 z s r6 c @ s e Zd Zdd� Zdd� ZdS )�TestIOStreamSSLContextc K s\ t �t j�}|�tj�tj�t�d�tj�tj�t�d�� t ||ddd�}t |fi |��S )Nr r TFr7 ) r1 � SSLContext�PROTOCOL_SSLv23�load_cert_chainr! r" r# r$ r% r r �r, r� rj �contextr& r& r' r� � s ��z,TestIOStreamSSLContext._make_server_iostreamc K s t �t j�}t|fd|i|��S )Nr0 )r1 r< r= r r? r& r& r' r5 � s z,TestIOStreamSSLContext._make_client_iostreamNr5 r& r& r& r' r; � s r; c s� e Zd Z� fdd�Z� fdd�Zdd� Zejdd� �Zejd d � �Z dd d �Z ddd�Z e dd� �Z e dd� �Ze dd� �Z� ZS )�TestIOStreamStartTLSc s� z�t t| ��� t� \| _| _d | _t� | _t � | j| j � t t � � �| _| j�| j�d| jf�| j� | �� | j�| j| j� | �� W n. ty� } zt|� � W Y d }~n d }~0 0 d S )Nr> )�superrA �setUpr r r r r �server_acceptedr r� �acceptr r� r r� Z add_futurerA r r� � Exception�print)r, �e�r r& r' rC � s � zTestIOStreamStartTLS.setUpc sD | j d ur| j �� | jd ur(| j�� | j�� tt| ��� d S r2 )r r9 r r rB rA �tearDownr+ rI r& r' rJ � s z TestIOStreamStartTLS.tearDownc C s. | j d ur| �d� t|�| _ | j�d � d S )Nz should only get one connection)r Zfailr rD r� )r, r� r� r& r& r' rE � s zTestIOStreamStartTLS.acceptc c s* | j �|� | j�d�V }| �||� d S �NrX )r r* r r[ rN �r, �lineZ recv_liner& r& r' �client_send_line� s z%TestIOStreamStartTLS.client_send_linec c s* | j �|� | j�d�V }| �||� d S rK )r r* r r[ rN rL r& r& r' �server_send_line� s z%TestIOStreamStartTLS.server_send_lineNc C s | j }d | _ |�d||�S )NF)r � start_tls)r, r0 �server_hostnamer r& r& r' �client_start_tls� s z%TestIOStreamStartTLS.client_start_tlsc C s | j }d | _ |�d|�S )NT)r rP )r, r0 r r& r& r' �server_start_tls� s z%TestIOStreamStartTLS.server_start_tlsc c s� | � d�V | �d�V | � d�V | � d�V | �d�V | � d�V | �ttjd��}| �t� �}|V | _|V | _ | � t | jt �� | � t | j t �� | �d�V | � d�V d S ) Ns 220 mail.example.com ready s EHLO mail.example.com s 250-mail.example.com welcome s 250 STARTTLS s STARTTLS s 220 Go ahead r- s 250 mail.example.com welcome ) rO rN rR r r1 r2 rS r( r r rD r� r )r, � client_future� server_futurer& r& r' �test_start_tls_smtp� s z(TestIOStreamStartTLS.test_start_tls_smtpc c s� | � t� �}ttd��� | jdd�}| �tj�� |V W d � n1 sL0 Y | �tjtj f�� |V W d � n1 s�0 Y W d � n1 s�0 Y d S )N� SSL Errorr �rQ ) rS r( r r rR rd r1 �SSLErrorr� r �r, rU rT r& r& r' �test_handshake_fail� s $z(TestIOStreamStartTLS.test_handshake_failc c s� | � t� �}ttd��� | jt�� dd�}| �tj�� |V W d � n1 sR0 Y | �t �� |V W d � n1 s�0 Y W d � n1 s�0 Y d S )NrW r> rX ) rS r( r r rR r1 �create_default_contextrd rY rF rZ r& r& r' �test_check_hostname� s �$ z(TestIOStreamStartTLS.test_check_hostname)NN)N)r. r/ r0 rC rJ rE r r� rN rO rR rS r rV r[ r] � __classcell__r& r& rI r' rA � s rA c @ s> e Zd Zejdd� �Zedd� �Zedd� �Zedd� �Z d S ) �WaitForHandshakeTestc c s� d }}z�t � \}}|t� d�}|�|� t�tjj�}d|_tj|_ | j t tdd�O _ t t � � |d�}|�d|f�V | �|j �� � W |d ur�|�� |d ur�|�� n"|d ur�|�� |d ur�|�� 0 d S )Nr/ F� OP_NO_TLSv1_3r r> )r r( Z add_socketr1 r\ �Purpose� SERVER_AUTH�check_hostnamer2 � verify_mode�options�getattrr r� rA ZassertIsNotNone�cipherr r9 )r, Z server_clsr r �sockr Zssl_ctxr& r& r' �connect_to_server s( �z&WaitForHandshakeTest.connect_to_serverc # s6 | �t � � G � �fdd�dt�}| �|�V � V d S )Nc s* e Zd Z�fdd�Zej� fdd��ZdS )zGWaitForHandshakeTest.test_wait_for_handshake_future.<locals>.TestServerc s$ � � |j�� � � j�| j|� d S r2 )Z assertIsNoner� rg r� Zspawn_callback�handle_connection�r, rG r� )rl r& r' � handle_stream( s zUWaitForHandshakeTest.test_wait_for_handshake_future.<locals>.TestServer.handle_streamc 3 s |� � V � �d � d S r2 ��wait_for_handshaker� re ��handshake_futurer& r' rj , s zYWaitForHandshakeTest.test_wait_for_handshake_future.<locals>.TestServer.handle_connectionN)r. r/ r0 rl r r� rj r& �rp rl r& r' � TestServer' s rr �r r ri �r, rr r& rq r' � test_wait_for_handshake_future" s z3WaitForHandshakeTest.test_wait_for_handshake_futurec # s6 | �t � � G � �fdd�dt�}| �|�V � V d S )Nc s e Zd Zej� �fdd��ZdS )zVWaitForHandshakeTest.test_wait_for_handshake_already_waiting_error.<locals>.TestServerc 3 s* |� � }��t|j � |V � �d � d S r2 )rn rd � RuntimeErrorr� )r, rG r� r� rq r& r' rl : s zdWaitForHandshakeTest.test_wait_for_handshake_already_waiting_error.<locals>.TestServer.handle_streamN�r. r/ r0 r r� rl r& rq r& r' rr 9 s rr rs rt r& rq r' �-test_wait_for_handshake_already_waiting_error4 s zBWaitForHandshakeTest.test_wait_for_handshake_already_waiting_errorc # s0 t � � G � fdd�dt�}| �|�V � V d S )Nc s e Zd Zej� fdd��ZdS )zRWaitForHandshakeTest.test_wait_for_handshake_already_connected.<locals>.TestServerc 3 s" |� � V |� � V � �d � d S r2 rm rk ro r& r' rl J s z`WaitForHandshakeTest.test_wait_for_handshake_already_connected.<locals>.TestServer.handle_streamNrw r& ro r& r' rr I s rr rs rt r& ro r' �)test_wait_for_handshake_already_connectedE s z>WaitForHandshakeTest.test_wait_for_handshake_already_connectedN) r. r/ r0 r r� ri r ru rx ry r& r& r& r' r_ s r_ c @ s2 e Zd Zejdd� �Zedd� �Zedd� �ZdS )�TestPipeIOStreamc K s, t �� \}}t|fi |��t|fi |��fS r2 )r! �piper )r, rj r� �wr& r& r' rk V s z#TestPipeIOStream.make_iostream_pairc c s| | � � V \}}|�d� |�d� |�d�V }| �|d� |�d�V }| �|d� |�� |�� V }| �|d� |�� d S )Ns hels lo world� s hello rL r� s ld)rk r* r[ rN rM r9 rC r� r& r& r' �test_pipe_iostream\ s z#TestPipeIOStream.test_pipe_iostreamc c sP | � � V \}}d}|�d| � |�|�V }| �|d| � |�� |�� d S )Nrc r{ )rk r* rM rN r9 )r, rw rx Z NUM_BYTESrH r& r& r' � test_pipe_iostream_big_writep s z-TestPipeIOStream.test_pipe_iostream_big_writeN) r. r/ r0 r r� rk r r~ r r& r& r& r' rz T s rz c @ sJ e Zd ZdZdd� Zdd� Zddd�Zd d � Zd d � Zd d� Z dd� Z dS )�TestStreamBufferz9 Unit tests for the private _StreamBuffer class. c C s t �d�| _ d S )Nr� )r� r� r+ r& r& r' rC � s zTestStreamBuffer.setUpc C s4 t |ttf�rt|�S t |t�r(|�� S t|��d S r2 )r� r� r� r� �tobytes� TypeError)r, �br& r& r' �to_bytes� s zTestStreamBuffer.to_bytesr� c C s t � }|jsJ �||_|S r2 )r Z_large_buf_threshold)r, Zlarge_buf_thresholdr� r& r& r' �make_streambuffer� s z"TestStreamBuffer.make_streambufferc C sj d}|dt |� k rf| �|�|��}| �|� | �t |�|� | �|�|�||f� |d d d }qd S )Nrg r� rL )r� r� �peekrD ZassertLessEqualrE )r, r� �expectedr� �gotr& r& r' � check_peek� s zTestStreamBuffer.check_peekc C s� | � t|�d� d}|D ]:}||7 }|�||�� | � t|�t|�� | �||� q|r�| j�dt|�d �}||d � }|�|� | � t|�t|�� | �||� qT| � t|�d� d S )Nr rK rg )rN r� rT r� r� � randrange�advance)r, r� �objsZ input_typer� �or� r& r& r' � check_append_all_then_skip_all� s z/TestStreamBuffer.check_append_all_then_skip_allc C s� g d�}| � � }| �||t� | � � }| �||t� | � � }| �||t� | � d�}td�D ]}|�d� q\| �t|j �d� td�D ]}|�d� q�| �t|j �d� |� d� | �t|j �d� |� d� | �t|j �d� | �t|�d� d S ) N)rz s 345s 67s 89a� bcdes fghs ijklmnr� rJ r$ rg r� � r � r� r� r� r� r� r� rT rN r� �_buffersr� �r, r� r� r� r& r& r' � test_small� s& zTestStreamBuffer.test_smallc C s g d�}| � � }| �||t� | � � }| �||t� | � � }| �||t� | � d�}td�D ]}|�d� q\| �t|j �d� |�d� | �t|j �d� |�d� | �t|j �d� |� d� | �t|j �d � |� d � | �t|j �d � | �t|�d � d S ) N)s 1212121212s 345345s( 6767676767676767676767676767676767676767s$ 89a89a89a89a89a89a89a89a89a89a89a89ar� s fghfghfghfghfghfghfghs ijklmnijklmnr� rL s xxxxxxxxxxx� yr� � z�! rg r� r r� r� r& r& r' � test_large� s( zTestStreamBuffer.test_largeN)r� ) r. r/ r0 �__doc__rC r� r� r� r� r� r� r& r& r& r' r� � s r� )@Ztornado.concurrentr �tornador r Ztornado.iostreamr r r r r Ztornado.httputilr Z tornado.locksr r Z tornado.logr Ztornado.netutilr Ztornado.tcpserverr Ztornado.testingr r r r r r Ztornado.test.utilr r r Z tornado.webr r r� r r� r! r� r� r� r1 r r� r� r r( r) �objectr1 ri r� r* r, r3 r6 r; rA r_ rz ZTestCaser� r& r& r& r' �<module> sV o + iM+
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка