Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/remote/__pycache__/transport.cpython-39.pyc
Ðазад
a ]�h}. � @ s0 d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z d dl m Z mZ d dlmZ d dlmZ d dlmZ ejd dd� dkr�d d lmZ n d d lmZ z d dlZW n ey� d dlZY n0 e� e �Z G d d � d e �Z G d d � d e �Z!ddd�Z"G dd� de�Z#dS )� N)�BytesIO)� SO_RCVBUF� SOL_SOCKET)�config)�netns)�NetlinkSocketBase���ZBSD)�IPRoutec @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )� Transportz} A simple transport protocols to send objects between two end-points. Requires an open file-like object at init. c C s. || _ t�� | _t�� | _t�� | _d| _d S )NT) �file_obj� threading�Lock�lock�queue�Queue� cmd_queue� brd_queue�run)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/remote/transport.py�__init__$ s zTransport.__init__c C s | j �� S �N)r �fileno�r r r r r + s zTransport.filenoc C sR t � }t�||� t�dt|�� �d d�}||�� 7 }| j�|� | j� � d S �NZII� r ) r �pickle�dump�struct�pack�len�getvaluer �write�flush)r �objr �packetr r r �send. s zTransport.sendc C sL t �d| j�d��\}}t� }|�| j�|d �� |�d� t�|�}|S r ) r �unpackr �readr r# �seekr �load)r �length�offsetr �retr r r Z__recv6 s zTransport.__recvc C s� | j r�| j�d�r�z�z:|�d�}|d u r:W W | j�� q n|W W | j�� S W n tjyb Y n0 | �� }||d �s�|�|� n|�d � |W | j�� S W | j�� q�| j�� 0 q d }z|jdd�}W n tjy� Y n0 |d ur |S q d S )NF�stage� )�timeout) r r �acquire�get�releaser �Empty�_Transport__recv�put)r Z own_queueZ other_queue�checkr. r r r �_m_recv> s: � � �zTransport._m_recvc C s | � | j| jdd� �S )Nc S s | dkS �N� broadcastr ��xr r r �<lambda>] � z Transport.recv.<locals>.<lambda>)r9 r r r r r r �recv[ s �zTransport.recvc C s | � | j| jdd� �S )Nc S s | dkS r: r r< r r r r> b r? z$Transport.recv_cmd.<locals>.<lambda>)r9 r r r r r r �recv_cmd` s �zTransport.recv_cmdc C s d| _ d S �NF)r r r r r �closee s zTransport.closeN) �__name__� __module__� __qualname__�__doc__r r r' r6 r9 r@ rA rC r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )� ProxyChannelc C s || _ || _d S r )�targetr/ )r Zchannelr/ r r r r j s zProxyChannel.__init__c C s | j �| j|d d��S )N�r/ �data�error)rI r' r/ )r rK r r r r' n s �zProxyChannel.sendN)rD rE rF r r' r r r r rH i s rH � localhostc C sl dd� }dt _t�tj|� z6|d ur0t�|� t||d�}|jj }t |d�|_ W n6 t y� } z |� d|d�� W Y d }~dS d }~0 0 |�� | �� g} |�� |i} g } |� dtjd d �� t j�rhzt�| | | �\} } } W n Y q�Y n0 | D �]n}|| v �r�| | }|�tt�d }|�n d }d }z|�|�}W n4 t �yl } z|}t�� |_W Y d }~n d }~0 0 |� d||d �� W d � n1 �s�0 Y � q�|| �� k� r�| �� }|d d k�r |�� t�ddd ddddd�}|� d|d d �� d S |d dk�r�d }z>|d d � }|� t � |d d �� |� ||d d � W n4 t �y� } z|}t�� |_W Y d }~n d }~0 0 |� d|d |d d�� n�|d dk� r�d }z^t ||d �|d i |d ��}|d dk�r|j!d u�r| �"|j!�� � |j!| |j!�� < W n8 t �yH } z d }|}t�� |_W Y d }~n d }~0 0 |� d|||d d�� � q�q�d S )Nc S s dt _d S rB )�Serverr )�signum�framer r r � stop_serveru s zServer.<locals>.stop_serverT)rI �groupsr; �init)r/ rL � )r/ �unamerL � rJ r/ �shutdown�IHHQIQQ� r �h � reconstruct�argvr0 �cookie)r/ rL �returnr] �command�name�kwarg�bind)#rN r �signalr �signal_stop_remote�netnsmodZsetnsr Z_sproxyr rH Z _s_channel� Exceptionr' r rU �select� getsockoptr r r@ � traceback� format_exc�tbrA rC r r r+ r �loads� sendto_gate�getattrZ _brd_socket�append)�trnsp_in� trnsp_outr rI rR rQ Ziprr �e�inputsZ broadcasts�outputs�events�_�fd�sock�bufsizerL rK �cmd�msgr. r r r rN t s� �( � �� �� ��� ��rN c s� e Zd ZdZdZdZdZd � fdd� Zdd� Zd dd�Z d d � Z e j f� fd d � Z d d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Z� ZS )!� RemoteSocketNr c s� t t| �j|d� || _|| _t�� | _t�� | _ d| _ | j� � }|d dkrVt d��|d d url|d �n|d | _ t�| j� d S )N)rR Fr/ rS zincorrect protocol initrL rU )�superr| r rp rq r r �cmdlock�RLock� shutdown_lock�closedrA � TypeErrorrU �atexit�registerrC )r rp rq rR rS �� __class__r r r � s zRemoteSocket.__init__c C s| | j �b | j�dd d t|�t�|�� �|gd d�� | j�� }|d d urR|d �|d W d � S 1 sn0 Y d S )Nr[ �r/ r] r` r\ ra rL r^ ) r~ rq r' �typer �dumpsr rp rA )r r{ �addrr. r r r rm � s �� zRemoteSocket.sendto_gatec C s^ d }| j �� }|d u r t� �|d dkrBt�t�� |d � qqBq|d d urV|d �|d S )Nr/ rc rK rL )rp r@ �EOFError�os�kill�getpid)r ry �flagsr{ r r r r@ � s zRemoteSocket.recvc C sH t td�rt�| j� n,ztj�| jdi f� W n tyB Y n0 d S )N� unregisterr )�hasattrr� r� rC Z _exithandlers�remove� ValueErrorr r r r �_cleanup_atexit s z RemoteSocket._cleanup_atexitc sv | j ��X | j�sRtt| ��� d| _| �� | j�ddi� |dkr�| jd ur�t � ddddd|dd�}| j�d|d d �� | j j � W d � n1 s�0 Y | j| j | j | jf}|D ].}zt|d �r�|�� W q� ty� Y q�0 q�|D ](}z|j�� W q� t�y Y q�0 q�z"t�| jtj� t�| jd� W n t�yP Y n0 W d � n1 �sh0 Y d S ) NTr/ rW r rX rY rV r; rJ rC )r� r� r} r| rC r� rq r' �remote_trnsp_outr r rp r �remote_trnsp_inr� rf r r� r� �childr rd �waitpid�OSError)r �coderK Ztransport_objsZtrnspr� r r rC sD � � zRemoteSocket.closec O sh | j �N | j�dd |||d�� | j�� }|d d ur>|d �|d W d � S 1 sZ0 Y d S )Nr_ r� rL r^ )r~ rq r' rp rA )r rz r\ ra r. r r r �proxy@ s �� zRemoteSocket.proxyc C s | j �� S r )rp r r r r r r P s zRemoteSocket.filenoc O s8 d|v rt �d� |d= d|d< | jdg|�R i |��S )N�asynczJuse "async_cache" instead of "async", "async" is a keyword from Python 3.7FZ async_cacherb )�log�warningr� �r r\ ra r r r rb S s �zRemoteSocket.bindc O s | j dg|�R i |��S )Nr' �r� r� r r r r' a s zRemoteSocket.sendc O s | j dg|�R i |��S )N�sendtor� r� r r r r� d s zRemoteSocket.sendtoc O s | j dg|�R i |��S )Nrh r� r� r r r rh g s zRemoteSocket.getsockoptc O s | j dg|�R i |��S )N� setsockoptr� r� r r r r� j s zRemoteSocket.setsockoptc O s | j |i |��S r )r� r� r r r �_sendtom s zRemoteSocket._sendtoc O s | j |i |��S r )r@ r� r r r �_recvp s zRemoteSocket._recv)r )r )rD rE rF rp rq r� r� r rm r@ r� �errno� ECONNRESETrC r� r rb r' r� rh r� r� r� � __classcell__r r r� r r| � s$ +r| )NrM r )$r� r� �loggingr� r rg rc r r ri �ior �socketr r Zpyroute2r r re Zpyroute2.netlink.nlsocketr rU Zpyroute2.iproute.bsdr Zpyroute2.iproute.linuxr � ImportErrorr � getLoggerrD r� �objectr rH rN r| r r r r �<module> s4 K d
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка