Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/rtnl/__pycache__/iprsocket.cpython-39.pyc
Ðазад
a ]�h� � @ s� d dl Z d dlZd dlZd dlmZmZmZ d dlmZm Z d dl m Z m Z m Z d dlmZ d dlmZ ej�d�r�d dlmZmZ G d d � d e�ZG d d � d ee �ZG d d� dee �ZG dd� dee �ZdS )� N)�DEFAULT_RCVBUF�AddrPool� Namespace)� NETLINK_ROUTE�rtnl)� BatchSocket�ChaoticNetlinkSocket� NetlinkSocket)� NetlinkProxy)� MarshalRtnl�linux)� proxy_newlink� proxy_setlinkc s2 e Zd Z� fdd�Zd� fdd� Zdd� Z� ZS ) � IPRSocketBasec s� d|v r|� d� tt| �jtg|dd � �R i |�� t� | _| jdkrRtj | _d | _ t j � d�r�t| tdd�dd��}td |d �| _tjttjti| j_d S ) N�family� r r i i�� F)Z addr_poolZmonitor�return)�policy�nl)�pop�superr �__init__r r �marshal�groupsr ZRTMGRP_DEFAULTS� _s_channel�sys�platform� startswithr r r �_sproxyZ RTM_NEWLINKr Z RTM_SETLINKr Zpmap)�self�argv�kwargZsend_ns�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/rtnl/iprsocket.pyr s & ��zIPRSocketBase.__init__Nc s* t t| �j|d ur|n| jfi |�� d S )N)r r �bindr )r r r! r" r$ r% r& * s ��zIPRSocketBase.bindc C s� |� � |�� | jd ur(| j�|j�S | j�|�}|d ur�|d dkrX| �|d |�S |d dv r�| jd ur~| j� |d �S | j � |d �}|D ]8}|d d }|| j v r�| j | �|� q�|g| j |< q�t |d �S ntd� | �|j|�S )NZverdict�forward�data)r �error�headerZsequence_numberzIncorrect verdict)�reset�encode�compiled�appendr( r �handleZ_sendtor �sendr �parse�backlog�len� ValueError)r �msg�addr�retZmsgs�seqr$ r$ r% � sendto_gate/ s( zIPRSocketBase.sendto_gate)N)�__name__� __module__� __qualname__r r& r9 � __classcell__r$ r$ r" r% r s r c @ s e Zd ZdS )� IPBatchSocketN�r: r; r< r$ r$ r$ r% r> J s r> c @ s e Zd ZdS )�ChaoticIPRSocketNr? r$ r$ r$ r% r@ N s r@ c s$ e Zd ZdZdZ� fdd�Z� ZS )� IPRSocketa� The simplest class, that connects together the netlink parser and a generic Python socket implementation. Provides method get() to receive the next message from netlink socket and parse it. It is just simple socket-like class, it implements no buffering or like that. It spawns no additional threads, leaving this up to developers. Please note, that netlink is an asynchronous protocol with non-guaranteed delivery. You should be fast enough to get all the messages in time. If the message flow rate is higher than the speed you parse them with, exceeding messages will be dropped. *Usage* Threadless RT netlink monitoring with blocking I/O calls: >>> from pyroute2 import IPRSocket >>> from pprint import pprint >>> s = IPRSocket() >>> s.bind() >>> pprint(s.get()) [{'attrs': [('RTA_TABLE', 254), ('RTA_DST', '2a00:1450:4009:808::1002'), ('RTA_GATEWAY', 'fe80:52:0:2282::1fe'), ('RTA_OIF', 2), ('RTA_PRIORITY', 0), ('RTA_CACHEINFO', {'rta_clntref': 0, 'rta_error': 0, 'rta_expires': 0, 'rta_id': 0, 'rta_lastuse': 5926, 'rta_ts': 0, 'rta_tsage': 0, 'rta_used': 1})], 'dst_len': 128, 'event': 'RTM_DELROUTE', 'family': 10, 'flags': 512, 'header': {'error': None, 'flags': 0, 'length': 128, 'pid': 0, 'sequence_number': 0, 'type': 25}, 'proto': 9, 'scope': 0, 'src_len': 0, 'table': 254, 'tos': 0, 'type': 1}] >>> Nc s� |� dd�rt| �� | _tdd d f� fdd� }tjf� fdd� }t�|| �| _t�|| �| _ d|d < | jj |i |��S t t | �j |i |��S d S ) NZ clone_socketFr c s4 |dkr| j �||||�S tt| ��||||�S d S )Nr )� _brd_socket�getr rA )r �bufsizeZmsg_seq� terminate�callbackr" r$ r% rC � s � �zIPRSocket.bind.<locals>.getc sF | j �, | j�� tt| �j|d�W d � S 1 s80 Y d S )N)�code)Zsys_lockrB �closer rA )r rG r" r$ r% rH � s z IPRSocket.bind.<locals>.closeT� recursive) r �clonerB r �errno� ECONNRESET�types� MethodTyperC rH r& r rA )r r r! rC rH r" r$ r% r& � s �zIPRSocket.bind)r: r; r< �__doc__rB r& r= r$ r$ r" r% rA R s 6rA ) rK r rM Zpyroute2.commonr r r Zpyroute2.netlinkr r Zpyroute2.netlink.nlsocketr r r Zpyroute2.netlink.proxyr Z pyroute2.netlink.rtnl.marshalr r r Z$pyroute2.netlink.rtnl.ifinfmsg.proxyr r �objectr r> r@ rA r$ r$ r$ r% �<module> s 4
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка