Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/quic/__pycache__/_sync.cpython-39.pyc
Ðазад
a h�h�( � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl Z d dl Z d dl mZmZmZmZmZ ejZG dd� de�ZG dd� de�ZG dd� de�ZdS ) � N)�QUIC_MAX_DATAGRAM�BaseQuicConnection�BaseQuicManager�BaseQuicStream� UnexpectedEOFc s` e Zd Z� fdd�Zdd� Zdd� Zddd �Zdd d �Zd d� Zdd� Z dd� Z dd� Z � Z S )�SyncQuicStreamc s& t � �||� t�� | _t�� | _d S �N)�super�__init__� threading� Condition�_wake_up�Lock�_lock)�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/_sync.pyr s zSyncQuicStream.__init__c C s� | � |�}| j�2 | j�|�r.W d � d S || _W d � n1 sH0 Y | j�$ | j�|�sntjj �W d � n1 s�0 Y d| _q d S )Nr ) �_timeout_from_expirationr �_bufferZhaveZ _expectingr �wait�dns� exception�Timeout)r �amount� expiration�timeoutr r r �wait_for# s $ &zSyncQuicStream.wait_forc C s� | � |�}| j�* | j�� r,W d � d S W d � n1 s@0 Y | j�$ | j�|�sftjj�W d � q 1 sz0 Y q d S r ) r r r Zseen_endr r r r r )r r r r r r � wait_for_end/ s . zSyncQuicStream.wait_for_endNc C s� | � |�}| j�� rP| �|� | j� | j�� W d � S 1 sD0 Y n�| �d|� | j�& t� d| j� d��\}W d � n1 s�0 Y | �||� | j� | j� |�W d � S 1 s�0 Y d S )N� z!H) Z_expiration_from_timeout� _connection�is_h3r! r r �get_allr �struct�unpack�get)r r r �sizer r r �receive9 s * 4 zSyncQuicStream.receiveFc C s | � |�}| j�| j||� d S r )Z _encapsulater# �writeZ _stream_id)r �datagram�is_end�datar r r �sendG s zSyncQuicStream.sendc C s@ | � ||�r<| j� | j�� W d � n1 s20 Y d S r )Z_common_add_inputr �notify)r r. r- r r r � _add_inputK s zSyncQuicStream._add_inputc C s2 | j � | �� W d � n1 s$0 Y d S r )r �_close�r r r r �closeP s zSyncQuicStream.closec C s | S r r r3 r r r � __enter__T s zSyncQuicStream.__enter__c C s< | � � | j� | j�� W d � n1 s.0 Y dS �NF)r4 r r0 )r �exc_type�exc_val�exc_tbr r r �__exit__W s (zSyncQuicStream.__exit__)N)F) �__name__� __module__� __qualname__r r r! r* r/ r1 r4 r5 r: � __classcell__r r r r r s r c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zdd d �Zd � fdd� Z d � fdd� Z dd� Z d dd�Z � fdd�Z dd� Z� ZS ) �SyncQuicConnectionc s� t � �||||||� t| jtjd�| _| jd urpz | j�t j � | j| j�� W n t yn | j� � � Y n0 | j�| j� t�� \| _| _| j�d� | j�d� t�� | _d | _t�� | _d S )Nr F)r r �socket_factoryZ_af�socket� SOCK_DGRAM�_socket�_source�bindr ZinetZlow_level_address_tuple� Exceptionr4 �connect�_peer� socketpair� _send_wakeup�_receive_wakeup� setblockingr �Event�_handshake_complete�_worker_threadr r )r r �address�port�source� source_port�managerr r r r _ s" � zSyncQuicConnection.__init__c C s| d}|dk rx|d7 }z| j �t�}W n ty8 Y d S 0 | j�& | j�|| jt�� � W d � q1 sl0 Y qd S )Nr � � ) rC �recvr �BlockingIOErrorr r# Zreceive_datagramrH �time)r �countr, r r r �_readr s zSyncQuicConnection._readc C s, z| j �d� W q ty$ Y d S 0 q d S )N� )rK rW rX r3 r r r � _drain_wakeup} s z SyncQuicConnection._drain_wakeupc C s� �zPt �� }|�| jt j| j� |�| jt j| j� | j�s| � d�\}}|� |�}|D ]\}}|� � qX| j � | � |� W d � n1 s�0 Y | �� | j � | j�t�� �}W d � n1 s�0 Y |D ].\}}z| j�|� W q� t�y Y q�0 q�q4W | j � d| _W d � n1 �s40 Y | j�� | j�� nD| j � d| _W d � n1 �sx0 Y | j�� | j�� 0 d S )NFT)� selectors�DefaultSelector�registerrC � EVENT_READr[ rK r] �_doneZ_get_timer_values�selectr. r Z _handle_timer�_handle_eventsr# Zdatagrams_to_sendrY r/ rX r4 rN �set) r �selr �interval�items�key�_Z datagramsr, r r r �_worker� s6 (. & �& zSyncQuicConnection._workerc C sV | j � | j�� }W d � n1 s&0 Y |d u r<d S t|tjjj��r�| �� �rL| j � |�}|D ]�}t|tj jj �r�| j � | j �|j�}W d � n1 s�0 Y |r�|jd u r�|j|_n|jd u r�|j|_|jr�|�dd� qht|tj jj�rh| j � | j �|j�}W d � n1 �s*0 Y |rh|�|j|j� qhnL| j � | j �|j�}W d � n1 �sx0 Y |�rP|�|j|j� q t|tjjj��r�| j�� q t|tjjj��r�| j � d| _ W d � n1 �s�0 Y q t|tjjj �r | j � | j �|j�}W d � n1 �s60 Y |r |�dd� q d S )N� T) r r# Z next_event� isinstance�aioquicZquic�eventsZStreamDataReceivedr$ Z_h3_connZ handle_event�h3ZHeadersReceived�_streamsr( r �_headers�headersZ _trailersZ stream_endedr1 Z DataReceivedr. Z end_streamZHandshakeCompletedrN re ZConnectionTerminatedrb Z StreamReset)r �eventZ h3_eventsZh3_event�streamr r r rd � sJ ( , .. (.z!SyncQuicConnection._handle_eventsFc C sF | j � | j�|||� W d � n1 s,0 Y | j�d� d S �N� )r r# Zsend_stream_datarJ r/ )r ru r. r- r r r r+ � s .zSyncQuicConnection.writec sJ | j � t� �|||� W d � n1 s,0 Y |rF| j�d� d S rv )r r � send_headersrJ r/ )r r rs r- r r r rx � s .z SyncQuicConnection.send_headersc sJ | j � t� �|||� W d � n1 s,0 Y |rF| j�d� d S rv )r r � send_datarJ r/ )r r r. r- r r r ry � s .z SyncQuicConnection.send_datac C s( | j r d S tj| jd�| _| j�� d S )N)�target)�_closedr �Threadrk rO �startr3 r r r �run� s zSyncQuicConnection.runNc C sh | j �|�stjj�| j�: | jr&t�| j� d�}t | |�}|| j |< W d � n1 sZ0 Y |S r6 ) rN r r r r r rb r r# Z get_next_available_stream_idr rq )r r r ru r r r � make_stream� s (z SyncQuicConnection.make_streamc s6 | j � t� �|� W d � n1 s(0 Y d S r )r r � close_stream)r r r r r r� � s z SyncQuicConnection.close_streamc C s� | j �\ | jr W d � d S | j�| jd | jd � d| _| j�� | j�d� W d � n1 sh0 Y | j � � d S )Nr rV Trw ) r r{ �_manager�closedrH r# r4 rJ r/ rO �joinr3 r r r r4 � s *zSyncQuicConnection.close)F)F)F)N)r; r< r= r r[ r] rk rd r+ rx ry r~ r r� r4 r> r r r r r? ^ s ) r? c sf e Zd Zdejddf� fdd� Zddd �Z� fd d �Z� fd d �Z� fdd�Z dd� Z dd� Z � Z S )�SyncQuicManagerNFc s" t � �||t||� t�� | _d S r )r r r? r r r )r Zconf� verify_modeZ server_namerp r r r r � s zSyncQuicManager.__init__�U r Tc C sR | j �8 | �||||||�\}}|r,|�� |W d � S 1 sD0 Y d S r )r �_connectr~ ) r rP rQ rR rS Zwant_session_ticketZ want_tokenr r} r r r rG s �zSyncQuicManager.connectc s8 | j � t� �||� W d � n1 s*0 Y d S r )r r r� )r rP rQ r r r r� s zSyncQuicManager.closedc s: | j � t� �|||� W d � n1 s,0 Y d S r )r r �save_session_ticket)r rP rQ �ticketr r r r� s z#SyncQuicManager.save_session_ticketc s: | j � t� �|||� W d � n1 s,0 Y d S r )r r � save_token)r rP rQ �tokenr r r r� s zSyncQuicManager.save_tokenc C s | S r r r3 r r r r5 s zSyncQuicManager.__enter__c C s$ t | j�� �}|D ] }|�� qdS r6 )�listZ _connections�valuesr4 )r r7 r8 r9 � connectionsr r r r r: ! s zSyncQuicManager.__exit__)r� Nr TT) r; r< r= �ssl� CERT_REQUIREDr rG r� r� r� r5 r: r> r r r r r� � s � � r� )r^ rA r� r& r rY Zaioquic.quic.configurationrn Zaioquic.quic.connectionZaioquic.quic.eventsZ dns.exceptionr Zdns.inetZdns.quic._commonr r r r r r@ r r? r� r r r r �<module> s A
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка