Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/quic/__pycache__/_common.cpython-39.pyc
Ðазад
a h�hi* � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl Z d dl Z d dl Z d dlZ d dlZdZdZed ZG dd� de�ZG dd � d �ZG d d � d �ZG d d � d �ZG dd� de�ZG dd� d�ZG dd� de�ZdS )� N)�Any�Optionali � � c @ s e Zd ZdS )� UnexpectedEOFN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dns/quic/_common.pyr s r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�Bufferc C s d| _ d| _d S )N� F)�_buffer� _seen_end��selfr r r �__init__ s zBuffer.__init__c C s& | j r d S | j|7 _|r"d| _ d S )NT)r r �r �data�is_endr r r �put# s z Buffer.putc C s t | j�|krdS | jr t�dS )NTF)�lenr r r )r �amountr r r �have* s z Buffer.havec C s | j S �N)r r r r r �seen_end1 s zBuffer.seen_endc C s0 | � |�sJ �| jd |� }| j|d � | _|S r )r r )r r r r r r �get4 s z Buffer.getc C s | � � s J �| j}d| _|S )Nr )r r )r r r r r �get_all: s zBuffer.get_allN) r r r r r r r r r r r r r r s r c @ s^ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zddd�Z dd� Z dd� Z dd� Z dS )�BaseQuicStreamc C s* || _ || _t� | _d| _d | _d | _d S �Nr )� _connection� _stream_idr r � _expecting�_headers� _trailers)r � connection� stream_idr r r r B s zBaseQuicStream.__init__c C s | j S r )r! r r r r �idJ s zBaseQuicStream.idc C s | j S r )r# r r r r �headersM s zBaseQuicStream.headersc C s | j S r )r$ r r r r �trailersP s zBaseQuicStream.trailersc C s |d urt � � | }nd }|S r )�time)r �timeout� expirationr r r �_expiration_from_timeoutS s z'BaseQuicStream._expiration_from_timeoutc C s$ |d ur t |t�� d�}nd }|S )Ng )�maxr* )r r, r+ r r r �_timeout_from_expirationZ s z'BaseQuicStream._timeout_from_expirationTc C s� | j �� std��tj�|�}|j�� }|r2d}n d}|dt� |�� d� 7 }d|fd|j �� fd|j �� fd |fd g}|r�|� d d tt|���� fg� | j �| j|| � |r�| j �| j|d � d S )Nz%cannot send H3 to a non-H3 connections POSTs GETs ?dns=� =s :methods :schemes :authoritys :path)s accept� application/dns-message)s content-typer1 s content-lengthT)r �is_h3� SyntaxError�urllib�parse�urlparse�path�encode�base64�urlsafe_b64encode�rstrip�scheme�netloc�extend�strr � send_headersr! � send_data)r �url�datagram�postZ url_partsr7 �methodr( r r r �send_h3g s. ���zBaseQuicStream.send_h3c C s& | j �� r|S t|�}t�d|�| S )Nz!H)r r2 r �struct�pack)r rC �lr r r � _encapsulate� s zBaseQuicStream._encapsulatec C sJ | j �||� z"| jdkr(| j �| j�p.| j jW S tyD Y dS 0 d S )Nr T)r r r" r r r r r r r �_common_add_input� s �� z BaseQuicStream._common_add_inputc C s | j �| j� | j�dd� d S )Nr T)r � close_streamr! r r r r r r �_close� s zBaseQuicStream._closeN)T) r r r r r' r( r) r- r/ rF rJ rK rM r r r r r A s r c @ sL e Zd Zddd�Zdd� Zdd� Zdd d �Zdd d �Zddd�Zdd� Z dS )�BaseQuicConnectionNr c C s� d| _ || _|| _|| _d| _|| _i | _|�� rFtj j � |d�| _ nd | _ t j�|�| _t j�||f�| _|d u r�|dkr�| jtjkr�d}n| jtjkr�d}nt�|r�||f| _nd | _d S )NFr z0.0.0.0z::)Z_doner Z_addressZ_port�_closed�_manager�_streamsr2 �aioquic�h3r% Z H3Connection�_h3_conn�dns�inetZaf_for_addressZ_af�low_level_address_tupleZ_peer�socket�AF_INET�AF_INET6�NotImplementedError�_source)r r% �address�port�source� source_port�managerr r r r � s* zBaseQuicConnection.__init__c C s | j d uS r )rT r r r r r2 � s zBaseQuicConnection.is_h3c C s | j |= d S r )rQ )r r& r r r rL � s z BaseQuicConnection.close_streamFc C s | j �|||� d S r )rT r@ )r r& r( r r r r r@ � s z BaseQuicConnection.send_headersc C s | j �|||� d S r )rT rA )r r& r r r r r rA � s z BaseQuicConnection.send_dataTc C sL t � � }| j�� }|d u r"|d }t|| d�}| jrD|rDt|d�}||fS )Ni r g�������?)r* r Z get_timerr. rO �min)r Zclosed_is_special�nowr, �intervalr r r �_get_timer_values� s z$BaseQuicConnection._get_timer_valuesc C s t � � }||kr | j�|� d S r )r* r Z handle_timer)r r, rc r r r � _handle_timer� s z BaseQuicConnection._handle_timer)Nr N)F)F)T) r r r r r2 rL r@ rA re rf r r r r rN � s � " rN c @ s" e Zd Zdee ed�dd�ZdS )�AsyncQuicConnectionN)r+ �returnc � s d S r r )r r+ r r r � make_stream� s z AsyncQuicConnection.make_stream)N)r r r r �floatr ri r r r r rg � s rg c @ s@ e Zd Zddd�Zddd �Zd d � Zd d � Zdd� Zdd� ZdS )�BaseQuicManagerNFc C s� i | _ || _i | _i | _|| _|d u rvd }t|t�r<|}d}|rHdg}nddg}tjj j |||d�}|d urv|� |� || _ d S )NTrS Zdoqzdoq-i03)�alpn_protocols� verify_mode� server_name) � _connections�_connection_factory�_session_tickets�_tokens�_h3� isinstancer? rR �quic� configurationZQuicConfiguration�load_verify_locations�_conf)r �confrm �connection_factoryrn rS Z verify_pathrl r r r r � s* � zBaseQuicManager.__init__�U r Tc C s( | j �||f�}|d ur |dfS | j}|rtz$| j�||f�} t�|�}| |_W n ty` Y n0 t� | j ||�} nd } |r�z$| j �||f�} t�|�}| |_ W n ty� Y n0 t� | j ||�} nd } tjjj|| | d�} tj�||f�}| �|t�� � | �| ||||| �}|| j ||f< |dfS )NF)rv �session_ticket_handler� token_handlerT)ro r rx rq �pop�copy�session_ticket�KeyError� functools�partial�save_session_ticketrr �token� save_tokenrR ru r% ZQuicConnectionrU rV rW �connectr* rp )r r] r^ r_ r` Zwant_session_ticketZ want_tokenr% ry r� r| r� r} ZqconnZ lladdressr r r �_connect� sH � � �zBaseQuicManager._connectc C s( z| j ||f= W n ty" Y n0 d S r )ro r� )r r] r^ r r r �closed1 s zBaseQuicManager.closedc C s | j S r )rs r r r r r2 7 s zBaseQuicManager.is_h3c C sL t | j�}|tkr:t| j�� �dt� }|D ] }| j|= q,|| j||f< d S r )r rq �MAX_SESSION_TICKETS�list�keys�SESSIONS_TO_DELETE)r r] r^ �ticketrI �keys_to_delete�keyr r r r� : s z#BaseQuicManager.save_session_ticketc C sL t | j�}|tkr:t| j�� �dt� }|D ] }| j|= q,|| j||f< d S r )r rr r� r� r� r� )r r] r^ r� rI r� r� r r r r� E s zBaseQuicManager.save_token)NF)r{ Nr TT) r r r r r� r� r2 r� r� r r r r rk � s � � 8 rk c @ s e Zd Zddd�ZdS )�AsyncQuicManagerr{ Nr c C s t �d S r )r[ )r r] r^ r_ r` r r r r� R s zAsyncQuicManager.connect)r{ Nr )r r r r� r r r r r� Q s r� ) r9 r r� rX rG r* r4 �typingr r Zaioquic.h3.connectionrR Zaioquic.h3.eventsZaioquic.quic.configurationZaioquic.quic.connectionZdns.inetrU ZQUIC_MAX_DATAGRAMr� r� � Exceptionr r r rN rg rk r� r r r r �<module> s, #VBs
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка