Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/nslink/__pycache__/nspopen.cpython-39.pyc
Ðазад
a ]�h�, � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z m Z ddl m Z dd� Zdd � Zd d � Zd d � Zdd� ZG dd� de�ZG dd� de�Zdd� ZG dd� de�Ze e�G dd� de��ZdS )z� NSPopen ======= The `NSPopen` class has nothing to do with netlink at all, but it is required to have a reasonable network namespace support. � N)�config)�file� metaclass)�setnsc C s6 | d dkr| d �n | d dkr*| d S t d��d S )N�code�� �data�� zunsupported return code)� TypeError)�result� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/nslink/nspopen.py�_handle s r c s � �fdd�}|S )Nc s �� � � g| �R i |��S �N)�fileno��argv�kwarg��prime�targetr r �func! s z_make_fcntl.<locals>.funcr )r r r r r r � _make_fcntl s r c s � fdd�}|S )Nc s � | i |��S r r r �r r r r ( s z_make_func.<locals>.funcr )r r r r r � _make_func' s r c s � fdd�}t |�S )Nc s t | j� �S r )�getattrr ��self��namer r r / s z _make_property.<locals>.func)�property)r r r r r �_make_property. s r! c C sV t |�D ]H}t||�}dd i| |< t|d�| | d< t|d�rD|jnd | | d< qd S )N�api�__call__�callable�__doc__�doc)�dirr �hasattrr% )r" �obj� attr_name�attrr r r �_map_api5 s �r, c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )� MetaPopenzf API definition for NSPopen. All this stuff is required to make `help()` function happy. c sx t t| �j|i |�� i | _t| jtj� dD ]D}i }d|d�| j|< t|t� dD ] }d dtt |�j d�||< qTq.d S )N��stdin�stdout�stderrF)r$ r" ��fcntlZioctlZflock�lockfT)r" r$ r& ) �superr- �__init__r" r, � subprocess�Popenr r r3 r% )�clsr r �fname�mZename�� __class__r r r6 F s �zMetaPopen.__init__c C s t | j�� �dg S �N�release��listr" �keys)r9 r r r �__dir__V s zMetaPopen.__dir__c sn zt �| |�W S tyh ttj|�� t� tjtj f�r\� fdd�}� j |_ | |_ | Y S � Y S Y n0 d S )Nc s � | i |��S r r r �r+ r r �proxy` s z)MetaPopen.__getattribute__.<locals>.proxy) �type�__getattribute__�AttributeErrorr r7 r8 � isinstance�types� MethodType� FunctionTyper% � __objclass__)r9 �keyrE r rD r rG Y s zMetaPopen.__getattribute__)�__name__� __module__� __qualname__r% r6 rC rG � __classcell__r r r< r r- ? s r- c @ s e Zd Zdd� ZdS )� NSPopenFilec C s� || _ t|�D ]j}|�d�r qt||�}t|tjtjf�rft|�}||_ t|dd�|_ t | ||� ~qt | j |t |�� qdD ]:}tt|�}t||�}||_ t|dd�|_ t | ||� ~q~d S )N�_r% � r2 )r r' � startswithr rI rJ �BuiltinMethodTyperK r rO r% �setattrr= r! r3 r )r r Zanamer r r: r r r r6 k s& zNSPopenFile.__init__N)rO rP rQ r6 r r r r rS j s rS c C s� zt | ||�dd �d� W n0 tyJ } z|�|� W Y d }~d S d }~0 0 tj|i |��}dD ]*}t||�} | d ur`t| �} t||| � q`|�d � z |� � } W nB t � � \} } }z|�d| d�� W n Y n0 Y �q�Y n0 | d dk� r��q�z�| � d�}|} |�r*|� d �D ]}t| |�} �qt| | d �}t |tjtjtjf��rh|| d i | d ��}n|}|�d |d�� W q� t � � \} } }|�d| d�� Y q�0 q�|�� d S ) N�libc)�flagsrY )r0 r1 r/ r )r r r r? � namespace�.r r r )r �pop� Exception�putr7 r8 r rS rX �get�sys�exc_info�splitrI rJ rK rL rW �wait)�nsnamerZ � channel_in� channel_outr r �e�childr: r) Zfproxy�call�etZev�tb�ns�stepr+ r r r r � NSPopenServer� sX ��ro c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS )�ObjNSNc C s d S r r r r r r � __enter__� s zObjNS.__enter__c C s d S r r )r �exc_type� exc_value� tracebackr r r �__exit__� s zObjNS.__exit__c sN zt ��� �W S t�yH �j�� �jr6td���j�� �r��j� d r�� �fdd�}� �jv rx�j� d |_|W d � Y S � dv r�t � }� |_ �j�� i ��di �|_�j |_ �j |_ �j|_�j|_|W d � Y S �j � � �j d�� t�j �� �W d � Y S W d � n1 �s:0 Y Y n0 d S ) Nzthe object is releasedr$ c s& �j �� | �j|d�� t�j�� �S )N)r r r[ r )rg r_ rm r rf r` r �rN r r r rE � s ��z%ObjNS.__getattribute__.<locals>.proxyr& r. r" )r r[ )�objectrG rH �lock�released� RuntimeErrorr" r` r% rp rm rg rf r_ r )r rN rE Zobjnsr rv r rG � s0 �zObjNS.__getattribute__)rO rP rQ rm rq ru rG r r r r rp � s rp c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �NSPopena A proxy class to run `Popen()` object in some network namespace. Sample to run `ip ad` command in `nsname` network namespace:: nsp = NSPopen('nsname', ['ip', 'ad'], stdout=subprocess.PIPE) print(nsp.communicate()) nsp.wait() nsp.release() The `NSPopen` class was intended to be a drop-in replacement for the `Popen` class, but there are still some important differences. The `NSPopen` object implicitly spawns a child python process to be run in the background in a network namespace. The target process specified as the argument of the `NSPopen` will be started in its turn from this child. Thus all the fd numbers of the running `NSPopen` object are meaningless in the context of the main process. Trying to operate on them, one will get 'Bad file descriptor' in the best case or a system call working on a wrong file descriptor in the worst case. A possible solution would be to transfer file descriptors between the `NSPopen` object and the main process, but it is not implemented yet. The process' diagram for `NSPopen('test', ['ip', 'ad'])`:: +---------------------+ +--------------+ +------------+ | main python process |<--->| child python |<--->| netns test | | NSPopen() | | Popen() | | $ ip ad | +---------------------+ +--------------+ +------------+ As a workaround for the issue with file descriptors, some additional methods are available on file objects `stdin`, `stdout` and `stderr`. E.g., one can run fcntl calls:: from fcntl import F_GETFL from pyroute2 import NSPopen from subprocess import PIPE proc = NSPopen('test', ['my_program'], stdout=PIPE) flags = proc.stdout.fcntl(F_GETFL) In that way one can use `fcntl()`, `ioctl()`, `flock()` and `lockf()` calls. Another additional method is `release()`, which can be used to explicitly stop the proxy process and release all the resources. c O s� || _ d|v r |�d�| _nd| _t�� | _t�� | _t�� | _ d| _ tj t | j | j| j| j||fd�| _ | j �� | j�� }t|t�r�| j �� |�n t�| j� dS )an The only differences from the `subprocess.Popen` init are: * `nsname` -- network namespace name * `flags` keyword argument All other arguments are passed directly to `subprocess.Popen`. Flags usage samples. Create a network namespace, if it doesn't exist yet:: import os nsp = NSPopen('nsname', ['command'], flags=os.O_CREAT) Create a network namespace only if it doesn't exist, otherwise fail and raise an exception:: import os nsp = NSPopen('nsname', ['command'], flags=os.O_CREAT | os.O_EXCL) rZ r F)r �argsN)re r] rZ r ZMpQueuerg rf � threading�Lockrx ry Z MpProcessro �server�startr` rI r^ �join�atexit�registerr? )r re r r �responser r r r6 * s0 �� zNSPopen.__init__c C s� | j �f | jr W d � dS d| _| j�ddi� | j�� | j�� | j�� | `| `| `W d � n1 sr0 Y dS )z� Explicitly stop the proxy process and release all the resources. The `NSPopen` object can not be used after the `release()` call. NTr r? )rx ry rg r_ �closerf r r� r r r r r? \ s zNSPopen.releasec C s t | j�� �dg S r> r@ r r r r rC o s zNSPopen.__dir__N)rO rP rQ r% r6 r? rC r r r r r{ � s 32r{ )r% r� r3 r7 ra r} rJ Zpyroute2r Zpyroute2.commonr r Zpyroute2.netnsr r r r r! r, rF r- rw rS ro rp r{ r r r r �<module> s( +>2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка