Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/quic/__pycache__/_trio.cpython-39.pyc
Ðазад
a h�h $ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl m Z d dlmZmZmZmZmZ G dd� de�ZG dd� de�ZG dd � d e�ZdS ) � N)� NullContext)�QUIC_MAX_DATAGRAM�AsyncQuicConnection�AsyncQuicManager�BaseQuicStream� UnexpectedEOFc s` e Zd Z� fdd�Zdd� Zdd� Zddd �Zdd d �Zd d� Zdd� Z dd� Z dd� Z � Z S )�TrioQuicStreamc s t � �||� t�� | _d S �N)�super�__init__�trio� Condition�_wake_up)�self� connection� stream_id�� __class__� �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dns/quic/_trio.pyr s zTrioQuicStream.__init__c � sl | j �|�rd S || _| j4 I d H �& | j�� I d H W d �I d H q`1 I d H sV0 Y d| _q d S )Nr )�_bufferZhaveZ _expectingr �wait)r �amountr r r �wait_for s :zTrioQuicStream.wait_forc � s^ | j �� rd S | j4 I d H �& | j�� I d H W d �I d H q 1 I d H sN0 Y q d S r )r Zseen_endr r �r r r r � wait_for_end' s zTrioQuicStream.wait_for_endNc � s� |d u rt d �}n t�|�}|�� | j�� rR| �� I d H | j�� W d � S | �d�I d H t � d| j� d��\}| �|�I d H | j� |�W d � S W d � n1 s�0 Y t j j�d S )N� z!H)r r � move_on_after� _connection�is_h3r r �get_allr �struct�unpack�get�dns� exception�Timeout)r �timeout�context�sizer r r �receive. s 8zTrioQuicStream.receiveFc � s& | � |�}| j�| j||�I d H d S r )Z _encapsulater �writeZ _stream_id)r �datagram�is_end�datar r r �send> s zTrioQuicStream.sendc � sT | � ||�rP| j4 I d H � | j�� W d �I d H qP1 I d H sF0 Y d S r )Z_common_add_inputr �notify)r r. r- r r r � _add_inputB s zTrioQuicStream._add_inputc � s | � � d S r )�_closer r r r �closeG s zTrioQuicStream.closec � s | S r r r r r r � __aenter__L s zTrioQuicStream.__aenter__c � sV | � � I d H | j4 I d H � | j�� W d �I d H qR1 I d H sH0 Y dS �NF)r3 r r0 )r �exc_type�exc_val�exc_tbr r r � __aexit__O s 4zTrioQuicStream.__aexit__)N)F) �__name__� __module__� __qualname__r r r r* r/ r1 r3 r4 r9 � __classcell__r r r r r s r c sR e Zd Zd� fdd� Zdd� Zdd� Zdd d �Zd d � Zdd d�Zdd� Z � Z S )�TrioQuicConnectionNc sP t � �||||||� tj�| jtjd�| _t�� | _t�� | _ d | _ d| _ d S )Nr F) r r r �socket�_af� SOCK_DGRAM�_socket�Event�_handshake_complete� _run_done� _worker_scope� _send_pending)r r �address�port�source� source_port�managerr r r r W s zTrioQuicConnection.__init__c � sP �z,| j r*| j�tj�| j | j��I d H | j�| j�I d H | j �s| � d�\}}| j r^d}t j t �� | d��:| _| j�t�I d H }| j�|| jt�� � W d � n1 s�0 Y d | _| �|� | �� I d H d| _ | j�t�� �}|D ]\}}| j�|�I d H q�q>W d| _ | j�� | j�� n d| _ | j�� | j�� 0 d S )NFg )�deadlineT) �_sourcerB �bindr$ ZinetZlow_level_address_tupler@ �connect�_peer�_doneZ_get_timer_valuesrG r Z CancelScope� current_timerF �recvr r Zreceive_datagram�timeZ _handle_timer�_handle_eventsZdatagrams_to_sendr/ r3 rD �set)r Z expiration�intervalr, Z datagrams�_r r r �_worker_ s: � �4 � zTrioQuicConnection._workerc � s� d}| j �� }|d u rd S t|tjjj��r| �� r�| j� |�}|D ]�}t|tj jj �r�| j � |j�}|r�|jd u r~|j|_n|jd u r�|j|_|jr�|�dd�I d H qDt|tj jj�rD| j � |j�}|rD|�|j|j�I d H qDn*| j � |j�}|�r�|�|j|j�I d H nzt|tjjj��r0| j�� n\t|tjjj��rTd| _| j � � n8t|tjjj ��r�| j � |j�}|�r�|�dd�I d H |d7 }|dkrd}t � d�I d H qd S )Nr � T� � )!r Z next_event� isinstance�aioquicZquic�eventsZStreamDataReceivedr Z_h3_connZ handle_event�h3ZHeadersReceived�_streamsr# r �_headers�headersZ _trailersZ stream_endedr1 Z DataReceivedr. Z end_streamZHandshakeCompletedrD rW ZConnectionTerminatedrR rB r3 Z StreamResetr �sleep)r �count�eventZ h3_eventsZh3_event�streamr r r rV � sN � z!TrioQuicConnection._handle_eventsFc � s. | j �|||� d| _| jd ur*| j�� d S )NT)r Zsend_stream_datarG rF �cancel)r rh r. r- r r r r+ � s zTrioQuicConnection.writec � s` | j r d S t�� 4 I d H �"}|�| j� W d �I d H qR1 I d H sH0 Y | j�� d S r )�_closedr Z open_nursery� start_soonrZ rE rW )r �nurseryr r r �run� s 6zTrioQuicConnection.runc � s� |d u rt d �}n t�|�}|�N | j�� I d H | jr<t�| j�d�}t | |�}|| j |< |W d � S 1 st0 Y t j j �d S r5 )r r r rD r rR r r Z get_next_available_stream_idr rb r$ r% r& )r r' r( r rh r r r � make_stream� s "z TrioQuicConnection.make_streamc � s^ | j sZ| j�| jd | jd � d| _ | j�� d| _| jd urJ| j�� | j � � I d H d S )Nr r\ T) rj �_manager�closedrQ r r3 rG rF ri rE r r r r r r3 � s zTrioQuicConnection.close)N)F)N) r: r; r< r rZ rV r+ rm rn r3 r= r r r r r> V s %, r> c sB e Zd Zdejddf� fdd� Zddd �Zd d � Zd d � Z� Z S )�TrioQuicManagerNFc s t � �||t||� || _d S r )r r r> �_nursery)r rl Zconf� verify_modeZ server_namera r r r r � s zTrioQuicManager.__init__�U r Tc C s, | � |||||�\}}|r(| j�|j� |S r )�_connectrr rk rm )r rH rI rJ rK Zwant_session_ticketr �startr r r rP � s �zTrioQuicManager.connectc � s | S r r r r r r r4 � s zTrioQuicManager.__aenter__c � s* t | j�� �}|D ]}|�� I d H qdS r5 )�listZ _connections�valuesr3 )r r6 r7 r8 � connectionsr r r r r9 � s zTrioQuicManager.__aexit__)rt Nr T) r: r; r< �ssl� CERT_REQUIREDr rP r4 r9 r= r r r r rq � s � � rq )r? rz r! rU Zaioquic.quic.configurationr_ Zaioquic.quic.connectionZaioquic.quic.eventsr Z dns.exceptionr$ Zdns.inetZdns._asyncbackendr Zdns.quic._commonr r r r r r r> rq r r r r �<module> s =
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка