Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/__pycache__/__init__.cpython-39.pyc
Ðазад
a ]�h� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z mZmZmZ ddlmZmZmZ ddlmZmZmZ e�e�ZeZ eZ G dd� de �Z ej d d kr�e!Z"d Z#d Z$e#Z%d Z&d Z'd Z(dZ)dZ*dZ+e#Z,dZ-d Z.d Z/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8d Z9d Z:dZ;dZ<dZ=dZ>dZ?dZ@dZAdZBdZCd ZDd ZEdZFd ZGd ZHdZId ZJd ZKdZLdZMdZNdZOdZPdZQdZRdZSdZTdZUdZVdZWdZXdZYd ZZd Z[dZ\dZ]dZ^dZ_dZ`dZadZbdZcdZddZedZfd Zgd ZhdZidZjdZkdZldZmdZndZodZpdZqdZrdZsdZtdZud ZvdZwd Zxd Zyd Zzd Z{dZ|dZ}d Z~d Zd Z�d Z�d!Z�e�e�B Z�d Z�d Z�d!Z�d"Z�d Z�d Z�d Z�d Z�dZ�dZ�dZ�dZ�d Z#d#Z�d$d%d&d'd(�Z�dZ�d Z�d Z�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�d Z�d)Z�d Z�d Z�dZ�dZ�dZ�dZ�dZ�dZ�dZ�dZ�e��� a�i a�i a�i a�G d*d+� d+e��Z�G d,d-� d-�Z�G d.d/� d/�Z�G d0d1� d1e��Z�G d2d3� d3e��Z�G d4d5� d5e��Z�G d6d7� d7e��Z�G d8d9� d9e��Z�G d:d;� d;e��Z�G d<d=� d=e��Z�G d>d?� d?e�e�e�e��Z�G d@dA� dAe�e�e�e��Z�G dBdC� dCe�e�e�e��Z�G dDdE� dEe��Z�G dFdG� dGe�eZ�G dHdI� dIe�eZ�G dJdK� dKe�eZ�G dLdM� dMe�e�e�eZ�G dNdO� dOeƃZ�G dPdQ� dQeƃZ�G dRdS� dSeȃZ�dS )Ta�5 Netlink ------- basics ====== General netlink packet structure:: nlmsg packet: header data Generic netlink message header:: nlmsg header: uint32 length uint16 type uint16 flags uint32 sequence number uint32 pid The `length` field is the length of all the packet, including data and header. The `type` field is used to distinguish different message types, commands etc. Please note, that there is no explicit protocol field -- you choose a netlink protocol, when you create a socket. The `sequence number` is very important. Netlink is an asynchronous protocol -- it means, that the packet order doesn't matter and is not guaranteed. But responses to a request are always marked with the same sequence number, so you can treat it as a cookie. Please keep in mind, that a netlink request can initiate a cascade of events, and netlink messages from these events can carry sequence number == 0. E.g., it is so when you remove a primary IP addr from an interface, when `promote_secondaries` sysctl is set. Beside of incapsulated headers and other protocol-specific data, netlink messages can carry NLA (netlink attributes). NLA structure is as follows:: NLA header: uint16 length uint16 type NLA data: data-specific struct # optional: NLA NLA ... So, NLA structures can be nested, forming a tree. Complete structure of a netlink packet:: nlmsg header: uint32 length uint16 type uint16 flags uint32 sequence number uint32 pid [ optional protocol-specific data ] [ optional NLA tree ] More information about netlink protocol you can find in the man pages. pyroute2 and netlink ==================== packets ~~~~~~~ To simplify the development, pyroute2 provides an easy way to describe packet structure. As an example, you can take the ifaddrmsg description -- `pyroute2/netlink/rtnl/ifaddrmsg.py`. To describe a packet, you need to inherit from `nlmsg` class:: from pyroute2.netlink import nlmsg class foo_msg(nlmsg): fields = ( ... ) nla_map = ( ... ) NLA are described in the same way, but the parent class should be `nla`, instead of `nlmsg`. And yes, it is important to use the proper parent class -- it affects the header structure. fields attribute ~~~~~~~~~~~~~~~~ The `fields` attribute describes the structure of the protocol-specific data. It is a tuple of tuples, where each member contains a field name and its data format. Field data format should be specified as for Python `struct` module. E.g., ifaddrmsg structure:: struct ifaddrmsg { __u8 ifa_family; __u8 ifa_prefixlen; __u8 ifa_flags; __u8 ifa_scope; __u32 ifa_index; }; should be described as follows:: class ifaddrmsg(nlmsg): fields = (('family', 'B'), ('prefixlen', 'B'), ('flags', 'B'), ('scope', 'B'), ('index', 'I')) Format strings are passed directly to the `struct` module, so you can use all the notations like `>I`, `16s` etc. All fields are parsed from the stream separately, so if you want to explicitly fix alignemt, as if it were C struct, use the `pack` attribute:: class tstats(nla): pack = 'struct' fields = (('version', 'H'), ('ac_exitcode', 'I'), ('ac_flag', 'B'), ...) Explicit padding bytes also can be used, when struct packing doesn't work well:: class ipq_mode_msg(nlmsg): pack = 'struct' fields = (('value', 'B'), ('__pad', '7x'), ('range', 'I'), ('__pad', '12x')) nla_map attribute ~~~~~~~~~~~~~~~~~ The `nla_map` attribute is a tuple of NLA descriptions. Each description is also a tuple in two different forms: either two fields, name and format, or three fields: type, name and format. Please notice, that the format field is a string name of corresponding NLA class:: class ifaddrmsg(nlmsg): ... nla_map = (('IFA_UNSPEC', 'hex'), ('IFA_ADDRESS', 'ipaddr'), ('IFA_LOCAL', 'ipaddr'), ...) This code will create mapping, where IFA_ADDRESS NLA will be of type 1 and IFA_LOCAL -- of type 2, etc. Both NLA will be decoded as IP addresses (class `ipaddr`). IFA_UNSPEC will be of type 0, and if it will be in the NLA tree, it will be just dumped in hex. NLA class names are should be specified as strings, since they are resolved in runtime. There are several pre-defined NLA types, that you will get with `nla` class: - `none` -- ignore this NLA - `flag` -- boolean flag NLA (no payload; NLA exists = True) - `uint8`, `uint16`, `uint32`, `uint64` -- unsigned int - `be8`, `be16`, `be32`, `be64` -- big-endian unsigned int - `ipaddr` -- IP address, IPv4 or IPv6 - `ip4addr` -- only IPv4 address type - `ip6addr` -- only IPv6 address type - `target` -- a univeral target (IPv4, IPv6, MPLS) - `l2addr` -- MAC address - `lladdr` -- link layer address (MAC, IPv4, IPv6) - `hex` -- hex dump as a string -- useful for debugging - `cdata` -- a binary data - `string` -- UTF-8 string - `asciiz` -- zero-terminated ASCII string, no decoding - `array` -- array of simple types (uint8, uint16 etc.) Please refer to `pyroute2/netlink/__init__.py` for details. You can also make your own NLA descriptions:: class ifaddrmsg(nlmsg): ... nla_map = (... ('IFA_CACHEINFO', 'cacheinfo'), ...) class cacheinfo(nla): fields = (('ifa_preferred', 'I'), ('ifa_valid', 'I'), ('cstamp', 'I'), ('tstamp', 'I')) Custom NLA descriptions should be defined in the same class, where they are used. explicit NLA type ids ~~~~~~~~~~~~~~~~~~~~~ Also, it is possible to use not autogenerated type numbers, as for ifaddrmsg, but specify them explicitly:: class iw_event(nla): ... nla_map = ((0x8B00, 'SIOCSIWCOMMIT', 'hex'), (0x8B01, 'SIOCGIWNAME', 'hex'), (0x8B02, 'SIOCSIWNWID', 'hex'), (0x8B03, 'SIOCGIWNWID', 'hex'), ...) Here you can see custom NLA type numbers -- 0x8B00, 0x8B01 etc. It is not permitted to mix these two forms in one class: you should use ether autogenerated type numbers (two fields tuples), or explicit numbers (three fields typles). nla map adapters ~~~~~~~~~~~~~~~~ If the default declarative NLA map is not flexible enough, one can use a custom map adapter. In order to do so, one should define at least one function to return `pyroute2.netlink.NlaSpec()`, and one optional function to tell the parser if the attribute is supported. The simplest definition only to decode packets: .. code-block:: python from pyroute2.netlink import NlaMapAdapter, NlaSpec, nlmsg def my_flexible_nla_spec(key): return NlaSpec(nlmsg_atoms.hex, key, f'NLA_CLASS_{key}') class my_msg(nlmsg): nla_map = NlaMapAdapter(my_flexible_nla_spec) # example result [ { 'attrs': [ ('NLA_CLASS_1', '00:00:00:00'), ('NLA_CLASS_5', '00:00:00:00'), ], 'header': { ... }, }, ] In this example the same routine is used both for decoding and encoding workflows, but the workflows are not equal, thus the example will fail on encoding. Still the example may be useful if you don't plan to encode packets of this type. The decoding workflow will pass an integer as the `key` for NLA type, while the encoding workflow passes a string as the `key` for NLA name. To correctly handle both workflows, you can use either the `key` type discrimination, or the explicit declaration syntax: .. code-block:: python # discriminate workflows by the key type def my_flexible_nla_spec(key): if isinstance(key, int): # decoding workflow ... else: # encoding workflow ... class my_msg(nlmsg): nla_map = NlaMapAdapter(my_flexible_nla_spec) .. code-block:: python # declarate separate workflows def my_flexible_nla_spec_encode(key): # receives a string -- nla type name ... def my_flexible_nla_spec_decode(key): # receives an int -- nla type id ... class my_msg(nlmsg): nla_map = { 'decode': NlaMapAdapter(my_flexible_nla_spec_decode), 'encode': NlaMapAdapter(my_flexible_nla_spec_encode), } array types ~~~~~~~~~~~ There are different array-like NLA types in the kernel, and some of them are covered by pyroute2. An array of simple type elements:: # declaration nla_map = (('NLA_TYPE', 'array(uint8)'), ...) # data layout +======+======+---------------------------- | len | type | uint8 | uint8 | uint 8 | ... +======+======+---------------------------- # decoded {'attrs': [['NLA_TYPE', (2, 3, 4, 5, ...)], ...], ...} An array of NLAs:: # declaration nla_map = (('NLA_TYPE', '*type'), ...) # data layout +=======+=======+-----------------------+-----------------------+-- | len | type* | len | type | payload | len | type | payload | ... +=======+=======+-----------------------+-----------------------+-- # type* -- in that case the type is OR'ed with NLA_F_NESTED # decoded {'attrs': [['NLA_TYPE', [payload, payload, ...]], ...], ...} parsed netlink message ~~~~~~~~~~~~~~~~~~~~~~ Netlink messages are represented by pyroute2 as dictionaries as follows:: {'header': {'pid': ..., 'length: ..., 'flags': ..., 'error': None, # if you are lucky 'type': ..., 'sequence_number': ...}, # fields attributes 'field_name1': value, ... 'field_nameX': value, # nla tree 'attrs': [['NLA_NAME1', value], ... ['NLA_NAMEX', value], ['NLA_NAMEY', {'field_name1': value, ... 'field_nameX': value, 'attrs': [['NLA_NAME.... ]]}]]} As an example, a message from the wireless subsystem about new scan event:: {'index': 4, 'family': 0, '__align': 0, 'header': {'pid': 0, 'length': 64, 'flags': 0, 'error': None, 'type': 16, 'sequence_number': 0}, 'flags': 69699, 'ifi_type': 1, 'event': 'RTM_NEWLINK', 'change': 0, 'attrs': [['IFLA_IFNAME', 'wlp3s0'], ['IFLA_WIRELESS', {'attrs': [['SIOCGIWSCAN', '00:00:00:00:00:00:00:00:00:00:00:00']]}]]} One important detail is that NLA chain is represented as a list of elements `['NLA_TYPE', value]`, not as a dictionary. The reason is that though in the kernel *usually* NLA chain is a dictionary, the netlink protocol by itself doesn't require elements of each type to be unique. In a message there may be several NLA of the same type. encoding and decoding algo ~~~~~~~~~~~~~~~~~~~~~~~~~~ The message encoding works as follows: 1. Reserve space for the message header (if there is) 2. Iterate defined `fields`, encoding values with `struct.pack()` 3. Iterate NLA from the `attrs` field, looking up types in `nla_map` 4. Encode the header Since every NLA is also an `nlmsg` object, there is a recursion. The decoding process is a bit simpler: 1. Decode the header 2. Iterate `fields`, decoding values with `struct.unpack()` 3. Iterate NLA until the message ends If the `fields` attribute is an empty list, the step 2 will be skipped. The step 3 will be skipped in the case of the empty `nla_map`. If both attributes are empty lists, only the header will be encoded/decoded. create and send messages ~~~~~~~~~~~~~~~~~~~~~~~~ Using high-level interfaces like `IPRoute` or `IPDB`, you will never need to manually construct and send netlink messages. But in the case you really need it, it is simple as well. Having a description class, like `ifaddrmsg` from above, you need to: - instantiate it - fill the fields - encode the packet - send the encoded data The code:: from pyroute2.netlink import NLM_F_REQUEST from pyroute2.netlink import NLM_F_ACK from pyroute2.netlink import NLM_F_CREATE from pyroute2.netlink import NLM_F_EXCL from pyroute2.iproute import RTM_NEWADDR from pyroute2.netlink.rtnl.ifaddrmsg import ifaddrmsg ## # add an addr to an interface # # create the message msg = ifaddrmsg() # fill the protocol-specific fields msg['index'] = index # index of the interface msg['family'] = AF_INET # address family msg['prefixlen'] = 24 # the address mask msg['scope'] = scope # see /etc/iproute2/rt_scopes # attach NLA -- it MUST be a list / mutable msg['attrs'] = [['IFA_LOCAL', '192.168.0.1'], ['IFA_ADDRESS', '192.162.0.1']] # fill generic netlink fields msg['header']['sequence_number'] = nonce # an unique seq number msg['header']['pid'] = os.getpid() msg['header']['type'] = RTM_NEWADDR msg['header']['flags'] = NLM_F_REQUEST |\ NLM_F_ACK |\ NLM_F_CREATE |\ NLM_F_EXCL # encode the packet msg.encode() # send the buffer nlsock.sendto(msg.data, (0, 0)) Please notice, that NLA list *MUST* be mutable. � N)� OrderedDict)�AF_INET�AF_INET6� AF_UNSPEC� inet_ntop� inet_pton)�AF_MPLS� basestring�hexdump)�NetlinkDecodeError� NetlinkError�NetlinkNLADecodeErrorc @ s e Zd ZdS )�NotInitializedN)�__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/pyroute2/netlink/__init__.pyr � s r �3� i� � � � � � � � � � � � � � � � � i � i @ � � i i i i�� � NLMSG_NOOP� NLMSG_ERROR� NLMSG_DONE� NLMSG_OVERRUN)r r r r i c @ s e Zd Zddd�ZdS )�NlaSpecr FNc C s | � ||||||d�� d S )N��class�type�name� nla_flags� nla_array�init)�update)�self� nla_class�nla_type�nla_namer1 r2 r3 r r r �__init__� s ��zNlaSpec.__init__)r FN)r r r r9 r r r r r, � s �r, c @ s, e Zd Zdd� fdd�Zdd� Zdd� Zd S ) � NlaMapAdapterc C s dS �NTr ��xr r r �<lambda>� � zNlaMapAdapter.<lambda>c C s || _ || _d | _d S �N)�api_get� api_contains�types)r5 rA rB r r r r9 � s zNlaMapAdapter.__init__c C s | � |�S r@ )rB �r5 �keyr r r � __contains__� s zNlaMapAdapter.__contains__c C s0 | � |�}t|d t�r,t| j|d �|d< |S )Nr. )rA � isinstance�str�getattrrC )r5 rE �retr r r � __getitem__� s zNlaMapAdapter.__getitem__N)r r r r9 rF rK r r r r r: � s r: c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� SQLSchemac C sJ g }|j D ]@}|d d dkr |�|d fd�d|j�|d d�f�f� q |jD ]x}t|d t�rv|d }|d }n|d }|d }t||d �}t|dd �}|rRd�||j�|d�f�}|�|f|f� qR|j D ]&\}} t|t�r�|f}|�|| f� q�|j D ]2\} } | � � D ] \}} |�| f| | f� �q�q || _ g | _ g | _d S ) Nr �_� �BIGINT� r r �sql_type)�fields�append�join�sql_constraints�get�nla_maprG r rI �sql_extra_fields� sql_extend� sql_schema�spec�index� foreign_keys) r5 �clsrJ �field� nla_tupler8 r7 rQ �fnameZftypeZdcls�prefixr r r r9 � sB ��� � zSQLSchema.__init__c G s || _ | S r@ )r\ )r5 r\ r r r � unique_index s zSQLSchema.unique_indexc C sN d}| j D ] \}}|d |kr" q2|d7 }q t� �||� d|� �f| j |< | S )Nr r rN )r[ �KeyError)r5 r0 r[ �idxr_ Ztspecr r r � constraint s zSQLSchema.constraintc C s | j �|||d�� | S )N)rR � parent_fields�parent)r] rS )r5 rh rR rg r r r � foreign_key s ��zSQLSchema.foreign_keyc G s( |d }|d d� }| j �||f� | S )N���)r[ rS )r5 r[ Zf_type�f_namer r r �push$ s zSQLSchema.pushc C s t | j�S r@ )�iterr[ �r5 r r r �__iter__* s zSQLSchema.__iter__c C s t | j�S r@ )r r[ rn r r r �as_dict- s zSQLSchema.as_dictN) r r r r9 rc rf ri rl ro rp r r r r rL � s ( rL c @ s� e Zd ZdZdZdZdZdZdZi Z i Z dZ dZ i Z dZi ZdZdZdZdZdZdZdZdZdZdZdd � ZdVd d �Ze d d � �Z e dd� �Z dd� Z dWdd�Z!dd� Z"dd� Z#dd� Z$dd� Z%d d � Z&d d � Z'd d!� Z(d"d#� Z)d$d%� Z*d&d'� Z+e d(d)� �Z,e d*d+� �Z-e d,d-� �Z.d.d/� Z/d0d1� Z0d2d3� Z1dXd4d5�Z2dYd6d7�Z3d8d9� Z4dZd:d;�Z5d<d=� Z6de7fd>d?�Z8d@dA� Z9dBdC� Z:dDdE� Z;dFdG� Z<dHdI� Z=dJdK� Z>dLdM� Z?dNdO� Z@dPdQ� ZAdRdS� ZBdTdU� ZCdS )[� nlmsg_basea Netlink base class. You do not need to inherit it directly, unless you're inventing completely new protocol structure. Use nlmsg or nla classes. The class provides several methods, but often one need to customize only `decode()` and `encode()`. r Nr r F) �_buf�data�chain�offset�lengthrh �decoded� _nla_init� _nla_array� _nla_flags�valueZ _r_value_map� __weakref__c C s || j d | j d @ S �Nr )�align)r5 rv r r r � msg_alignd s znlmsg_base.msg_alignc C s� t �| � | jD ]}d| |d < qd | _|p0t� | _|| _|p@d| _| g| _|d url| j r^|nt � |�| _ nd | _ d| _ || _d| _| j| _g | d< t| _| jr�| jjs�| �� | jr�i | d< d S )Nr F�attrs�header)�dictr9 rR rr � bytearrayrs ru rv rt � own_parent�weakref�proxyrh rw rx ry r1 rz r r{ rW � __class__�_nlmsg_base__compiled_nla� compile_nlar� )r5 rs ru rv rh r3 �ir r r r9 g s* znlmsg_base.__init__c C s t | �S r@ )rL )r^ r r r rZ � s znlmsg_base.sql_schemac C sZ t �dd�t�� �� | jd u rTt�� | _| j�| j | j | j p@d � � | j� d� | jS )Nznlmsg.buf is deprecated: %srP r ) �logging�errorrT � traceback� format_stackrr �io�BytesIO�writers ru rv �seekrn r r r �buf� s � znlmsg_base.bufc C s t | �| j| jd�}|�� |S )z� Return a decoded copy of the netlink message. Works correctly only if the message was encoded, or is received from the socket. �rs ru )r/ rs ru �decode)r5 rJ r r r �copy� s znlmsg_base.copyc C s t � | _d| _d| _d S )Nr F)r� rs ru rw )r5 r� r r r �reset� s znlmsg_base.resetc C sZ | j d ur| j �|�S | �di ��dd �}|d urF|tjvrFg tj|< tj| �|� d S )Nr� �sequence_number)rh �register_clean_cbrV � clean_cbs�__dict__rS )r5 �cb�seqr r r r� � s z nlmsg_base.register_clean_cbc C s� | � di �� dd �}| � di �� dd�}|d ur�|t@ s�|tjv r�tj| D ]8}z |� W qL t�d| � t�t�� � Y qL0 qLtj|= d S )Nr� r� �flagsr zCleanup callback fail: %s)rV � NLM_F_REQUESTr� r� �logr� r� � format_exc)r5 r� Zmsfr� r r r �unregister_clean_cb� s ��� z nlmsg_base.unregister_clean_cbc C s0 t | d �D ] }|d |kr | d �|� q | S )Nr� r )�tuple�remove)r5 r0 r� r r r � _strip_one� s znlmsg_base._strip_onec C s. t |t�r| �|� n|D ]}| �|� q| S )z� Remove an NLA from the attrs chain. The `attrs` parameter can be either string, or iterable. In the latter case, will be stripped NLAs, specified in the provided list. )rG r r� )r5 r� r0 r r r �strip� s znlmsg_base.stripc C s� |d u r d S | � � }| �� }|jD ]\}}||= q"d|v r@|d= d|v rN|d= |D ]f}|dvrR|dkr�||vs~|| || kr�|| ||< qR|dkrR||v rR|| || krR|| ||< qRd|v �r�g |d< |d D ]�}t|d t��r.td� t|d |�|�|d ��} | d u�r�|d �|d | g� q�td t |d �� |dk�rr|�|d �|d k�r�|d �|� q�|dkr�|�|d �|d kr�|d �|� q�d|v �r�|d �s�|d= |�s�d S t|� |S ) Nr� r{ )r� r� Z__align�__sub__�__and__r� r � recursionr Zfail) �getvaluer� rR rG rq �printrI �get_attrrS r/ ) r5 �rvalueZop0Zop1�lvalue�resrE rM �attr�diffr r r Z__ops� sN znlmsg_base.__opsc C s t | �� �dkS �Nr )�len�keysrn r r r �__bool__ s znlmsg_base.__bool__c C s | � |dd�S )z( Subjunction operation. r� �__ne__��_nlmsg_base__ops�r5 r� r r r r� s znlmsg_base.__sub__c C s | � |dd�S )z( Conjunction operation. r� �__eq__r� r� r r r r� s znlmsg_base.__and__c C s | � |� S r@ )r� r� r r r r� s znlmsg_base.__ne__c C sL | � � }|| u rDt|t| ��r*| | du S t|t�r@t| �|kS dS ||kS )z� Having nla, we are able to use it in operations like:: if nla == 'some value': ... NF)r� rG r/ r� )r5 r� r� r r r r� s znlmsg_base.__eq__c C s& d}| j D ]}|t�|d �7 }q |S )Nr r )rR �struct�calcsize)r5 �sizer_ r r r �get_size$ s znlmsg_base.get_sizec C s& ||� | j�d t| j� d� �� S )z� Convert NLA name into human-friendly name Example: IFLA_ADDRESS -> address Requires self.prefix to be set r N)�findrb r� �lower�r5 r0 r r r �nla2name+ s znlmsg_base.nla2namec C s* |� � }|�| j�dkr&d| j|f }|S )z� Convert human-friendly name into NLA name Example: address -> IFLA_ADDRESS Requires self.prefix to be set rj z%s%s)�upperr� rb r� r r r �name2nla6 s znlmsg_base.name2nlac C sx | j }| jdur�| jr~t| j||d � �}t�|d�p`t�|tt dt � d| j|����p`t| | d< |d7 }| d d | _ nV| jD ]2\}}t � || j|�d | d |< |t � |�7 }q�d| v r�t| d d d�| _ | j�rT| �g � || j | j k �r^t| �| j|| d�}d |_|jdu�r&|j|_|�� | j�|� ||j d d d @ 7 }q�n | �|� tj�rn| �� d | _dS ) a� Decode the message. The message should have the `buf` attribute initialized. e.g.:: data = sock.recv(16384) msg = ifinfmsg(data) If you want to customize the decoding process, override the method, but don't forget to call parent's `decode()`:: class CustomMessage(nlmsg): def decode(self): nlmsg.decode(self) ... # do some custom data tuning Nr )rv r/ �HHr� rv r �rs ru rh Fr ���T)ru r� �is_nlar� rs � cache_hdrrV � __setitem__r� �zipr� � unpack_fromrv r� �maxry �setvaluer/ � cell_headerr� r{ rS � ft_decoder� r� r� rw )r5 ru rE r0 �fmt�cellr r r r� D sX �������� znlmsg_base.decodec C s~ | j }d}| jdurJt�d�dd� | jD ���}| j�dg| � ||7 }| jr�d}| �� D ]x}t | �| j|| d�}d|_|j dur�|j |_|� |� | j p�|| j B |d d < |d7 }|�� ||jd d d @ 7 }q\n| �� dur�| �|�\}}| j�r| �|�}d | v �rz| jdu�rz|| j | | _| d d < | j }| jD ]6\}}t�|| j|| d �|d�� |t�|�7 }�qBdS )av Encode the message into the binary buffer:: msg.encode() sock.send(msg.data) If you want to customize the encoding process, override the method:: class CustomMessage(nlmsg): def encode(self): ... # do some custom data tuning nlmsg.encode(self) r NrP c S s g | ] }|d �qS )r r ��.0r= r r r � <listcomp>� r? z%nlmsg_base.encode.<locals>.<listcomp>r r� Fr� r/ r r� rv )ru r� r� r� rT rs �extendry r� r/ r� r� � header_typerz �encoderv � ft_encoderW � encode_nlas� pack_intorV ) r5 ru r� Zhsizer� r{ r� r0 r� r r r r� � sB � ��znlmsg_base.encodec C s� t |t�rb| �|� d|v r�g | d< |d D ]2}t� }|�|d � | d �|d |�� g� q,nXz6|| j�� v r�tdd� | j� � D ��}|� ||�}W n t y� Y n0 || d< || _ | S )Nr� r r c S s g | ]}|d |d f�qS )r r r r� r r r r� � r? z'nlmsg_base.setvalue.<locals>.<listcomp>r{ ) rG r� r4 rq r� rS r� � value_map�values�itemsrV � TypeErrorr{ )r5 r{ r` ZnlvZ reverse_mapr r r r� � s& � znlmsg_base.setvaluec s& � fdd�| d D �}|r"|d S dS )z6 Return the first encoded NLA by name c s g | ]}|d � kr|d �qS �r r r �r� r� �r� r r r� � r? z*nlmsg_base.get_encoded.<locals>.<listcomp>r� r Nr )r5 r� �default�cellsr r� r � get_encoded� s znlmsg_base.get_encodedc C s* t |t�r|f}| j|� }|dur&|S |S )z8 Universal get() for a netlink message. N)rG rH � get_nested)r5 rE r� rJ r r r rV � s znlmsg_base.getc G s~ | }|D ]p}t |t�r\|}|jr,|�|�}n|�� }|�|�}|du rV||v rV|| }|}qt |t�rr|�|�}q dS q|S )z+ Return nested NLA or None N)rG rq rb r� r� r� r� rV )r5 r� �pointerr� �nlar{ r r r r� s znlmsg_base.get_nestedc C s: z| � |�}W n ty$ | Y S 0 |r2|d S |S dS )z= Return the first NLA with that name or None r N)� get_attrsrd )r5 r� r� r� r r r r� s znlmsg_base.get_attrc s � fdd�| d D �S )z7 Return attrs by name or an empty list c s g | ]}|d � kr|d �qS r� r r� r� r r r� / r? z(nlmsg_base.get_attrs.<locals>.<listcomp>r� r )r5 r� r r� r r� + s znlmsg_base.get_attrsc sv |t u r t� }|d= |d= d|_| �dg �}� durH� fdd�|D �}ndd� |D �}|rr|D ] }||_q^|d }|S )rN r{ r� Nc s g | ]}|j � kr|j�qS r )r0 r� r� r� r r r� : r? z"nlmsg_base.nla.<locals>.<listcomp>c S s g | ] }|j �qS r )r� r� r r r r� < r? r )r rq r{ rV rt )r5 r� r� �responsert �linkr r� r r� 1 s znlmsg_base.nlac C s4 t |t�r| j| S |dkr(|| vr(tS t�| |�S �Nr{ )rG �intrt r r� rK rD r r r rK C s znlmsg_base.__getitem__c C s |dkr|| vrd S t �| |�S r� )r� � __delitem__rD r r r r� J s znlmsg_base.__delitem__c C s | � |�S r@ )�load)r5 �stater r r � __setstate__O s znlmsg_base.__setstate__c C s t | �d| �� fS )Nr )r/ �dumprn r r r � __reduce__R s znlmsg_base.__reduce__c C sP t |t�rB|�� D ],\}}|dkr6| d �|d � q|| |< qn | �|� | S )a� Load packet from a dict:: ipr = IPRoute() lo = ipr.link('dump', ifname='lo')[0] msg_type, msg_value = type(lo), lo.dump() ... lo = msg_type() lo.load(msg_value) The same methods -- `dump()`/`load()` -- implement the pickling protocol for the nlmsg class, see `__reduce__()` and `__setstate__()`. r� )rG r� r� r4 r� )r5 r� �k�vr r r r� U s znlmsg_base.loadc C s� | � � }t|t�r�i }|�� D ]�\}}|dkr@t|d �|d< q |dkr�g |d< }|d D ]n}t|d t�r�|�|d |d �� g� q\t|d t�r�|�|d t|d �g� q\|�|d |d g� q\q |||< q n|}|S )z' Dump packet as a dict r� r� r r ) r� rG r� r� rq rS r� �setr� )r5 �arJ r� r� r� r� r r r r� n s" znlmsg_base.dumpc C sn | j r0t| j�r0t| jd d�r0dd� | jD �S | jtkr@| jS d| v rj| d tkrj| j�| d | d �S | S )z� Atomic NLAs return their value in the 'value' field, not as a dictionary. Complex NLAs return whole dictionary. r r� c S s g | ] }|� � �qS r )r� r� r r r r� � r? z'nlmsg_base.getvalue.<locals>.<listcomp>r{ )ry r� r{ �hasattrr r� rV rn r r r r� � s ��� znlmsg_base.getvaluec C s$ t | jt�r4| | j_| j| j_| j| j_d| j_d S t | jt�r�t | jd t�r\| | jd _t | jd t�rx| | jd _| jd | j_| jd | j_d| j_d S i }i }g }| jD ].}t |d t �s�t |�}|� d� |� |� q�t |d d t ��s t dd� |D ��}dd � t ||�D �}n|}|D ]�\}}} } | d d k�rR| d d � } d} nd } | �d �} | �d�} d| k �r�| k �r�n n | | d | � }| d | � } nd }| dk�r�t| �} n&| dk�r�t| �} | tO } n t| | �} | ||| | |d�}| ||< ||< �q&|| j_|| j_d| j_d S )NTr� r� rj r c s s | ]}|d V qdS )r Nr r� r r r � <genexpr>� r? z)nlmsg_base.compile_nla.<locals>.<genexpr>c S s8 g | ]0}|d d |d d |d d |d d f�qS )r r r r )r� r� r r r r� � s �z*nlmsg_base.compile_nla.<locals>.<listcomp>�*r F�(�)� recursive�nestedr- )rG rW r: rC r� �_nlmsg_base__t_nla_map�_nlmsg_base__r_nla_mapr� r� r� �listrS � enumerater� r� r/ � NLA_F_NESTEDrI )r5 � t_nla_map� r_nla_maprW �itemZ nla_typesZzippedrE r0 r6 r1 r2 Zlb�rbr3 �primer r r r� � sr � �znlmsg_base.compile_nlac C s || j j�� v S r@ )r� r r� )r5 r� r r r � valid_nla� s znlmsg_base.valid_nlac C s8 | j j}tt| d ��D �]}| d | }|d |v r||d }|d }t|tj�rf|| |d d�}|| j|| |d d�}| j|d O _t|t �r�t|�d kr�| j|d O _|d |_ |� |d � |d |jB |d d < z |� � W n � Y n 0 d |_ t|d |�| d |< ||jd d d@ 7 }q|S )zz Encode the NLA chain. Should not be called manually, since it is called from `encode()` routine. r� r r. r )r{ r3 )rs ru rh r3 r1 r r2 r/ r� Tr0 r r� )r� r �ranger� rG rC � FunctionTypers rz r� ry r� r� rw �nla_slotrv )r5 ru r r� r� r � msg_class� nla_instancer r r r� � s: � � znlmsg_base.encode_nlasc C s | j j}|| j | jd k�rd}t�d| j|�\}}|ttB @ }t t |d�| j| | j �}||v r�|| }|| d }t |t j �r�|| | j|d�}|| j|| ||d d�}|d |_|ttB @ |_|d } nd } t| j||d �}| d �t| |�� ||d d d@ 7 }qdS )zz Decode the NLA chain. Should not be called manually, since it is called from `decode()` routine. r Nr� r. r� r3 )rs ru rh rv r3 r2 r0 �UNKNOWN)rs ru rv r� r r� )r� r� ru rv r� r� rs r �NLA_F_NET_BYTEORDER�minr� rG rC r ry rz �nla_baserS r ) r5 ru r r rv Z base_msg_type�msg_typer r r0 r r r � decode_nlas s> � � � �znlmsg_base.decode_nlas)Nr NNN)N)N)N)N)Dr r r �__doc__rR r� �packr� r~ rW rU rX rY Zlookup_fallbacksr1 r� r� rb r� r� r� Z_nlmsg_base__compiled_ftr� r Z_nlmsg_base__schema� __slots__r r9 � classmethodrZ �propertyr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rV r� r� r� r r� rK r� r� r� r� r� r� r� r r� r r r r r rq 1 s� � . [: S)rq c @ s e Zd Zdd� ZdS )�nlmsg_decoder_genericc C s� | j D ]h\}}t�|d �p2t�|t�|��p2t| }t�|| j|�}||7 }t|�dkrf|d | |< q|| |< q| j r�|d d d@ }z| � |� W q� t y� } z"t � t�� � t|��W Y d }~q�d }~0 0 n| d= | d tu r�| d= d S )Nr r r r� r� r{ )rR � cache_fmtrV r� r� r� r� rs r� rW r � Exceptionr� �warningr� r� r r )r5 ru r0 r� r� r{ �er r r r� R s* �� z nlmsg_decoder_generic.ft_decodeN�r r r r� r r r r r Q s r c @ s e Zd Zdd� ZdS )�nlmsg_decoder_stringc C sB t �d| jd | j|�\}| jdkr6|�d�| d< n|| d< d S )N�%isr r � r{ )r� r� rv rs �zstringr� )r5 ru r{ r r r r� v s � z nlmsg_decoder_string.ft_decodeNr r r r r r u s r c @ s e Zd Zdd� ZdS )�nlmsg_decoder_structc C s� g }d}| j D ] }|�|d � ||d 7 }qt�|| j|�}t|�}|D ] }|d dkrJ|�d�| |< qJ| jr�|d d d@ }z| �|� W q� t y� } z"t � t � � � t|��W Y d }~q�d }~0 0 n| d= | d tu r�| d= d S ) NrP r r rM r r� r� r{ )rR rS r� r� rs r �poprW r r r� r r� r� r r ) r5 ru �namesr� r_ r{ r� r0 r r r r r� � s( z nlmsg_decoder_struct.ft_decodeNr r r r r r$ � s r$ c @ s e Zd Zdd� ZdS )�nlmsg_encoder_genericc C s� | j D �]l\}}| | }|dkr<t|p(d�| j }d| }nt�|�}|}| j�dg| � tjd dkr�t |t �r�t |d�}q�t |t �r�t |�}n"tjd dkr�t |t�r�|�d�}zb|d d kr�t�|| j|� n@t|�tttfv �rtj|| j|g|�R � nt�|| j||� W nR tj�yj t�d�t�� �� t�t�� � t�d ||t|�f � � Y n0 ||7 }q|d d d @ | }||7 }| j�dg| � ||fS )N�srP r! r r �utf-8�2rj r= zerror pack: %s %s %sr r r� )rR r� r# r� r� rs r� �sys�versionrG rH �bytes�floatr� �unicoder� r� r/ r r� r� r� r� rT r� r� r� )r5 ru r0 r� r{ rv Zefmtr� r r r r� � s@ z nlmsg_encoder_generic.ft_encodeN)r r r r� r r r r r' � s r' c @ sd e Zd ZdZdd� Zdd� Zdd� Zdd � Zed d � �Z ed d � �Z edd� �Z dd� Z dd� Z dS )r �r� c C s ||f| _ d S r@ r0 )r5 r0 r{ r r r r9 � s znla_slot.__init__c C sZ z | j d }|js|�� W dS tyT t�d| j d � t�t�� � Y dS 0 d S )Nr Tz decoding %sr F)r� rw r� r r� r r� r� �r5 r� r r r � try_to_decode� s znla_slot.try_to_decodec C s6 | j d }| �� r|�� S |j|j|j|j � S d S r} )r� r2 r� rs ru rv r1 r r r � get_value� s znla_slot.get_valuec C s | � � r| jd jS d S r} )r2 r� rz rn r r r � get_flags� s znla_slot.get_flagsc C s | j d S r� r0 rn r r r r0 � s z nla_slot.namec C s | � � S r@ )r3 rn r r r r{ � s znla_slot.valuec C s | � � | jd S r} )r2 r� rn r r r r� � s z nla_slot.nlac C sr |dkr| � � S |dkr"| jd S t|t�rft| j�|��}| jd |v rb| � � ||�| jd �< |S t|��d S )Nr r )r3 r� rG �slicer rK r\ � IndexError)r5 rE r( r r r rK � s znla_slot.__getitem__c C s: | � � r$t| jd | �� | � � f�S t| jd | �� f�S r� )r4 �reprr� r3 rn r r r �__repr__ s znla_slot.__repr__N)r r r r r9 r2 r3 r4 r r0 r{ r� rK r8 r r r r r � s r c @ s e Zd ZdZdZdZdS )� nla_headerr T))rv �H�r/ r: N)r r r r r� r� r r r r r9 s r9 c @ s e Zd ZdZdZdZdS )r z! Generic NLA base class. r r N�r r r r r r# r r r r r s r c @ s e Zd ZdZdZdgZdZdS )�nla_base_stringz) NLA base class, string decoder. r )r{ r( r N)r r r r r rR r# r r r r r= s r= c @ s e Zd ZdZdZdS )�nla_base_structz0 NLA base class, packed struct decoder. r N�r r r r r r r r r r> , s r> c @ s e Zd ZdZdZG dd� de�ZG dd� de�ZG dd� de�ZG d d � d e�Z G d d � d e�Z G d d� de�Z G dd� de�Z G dd� de�Z G dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�ZG d!d"� d"e�ZG d#d$� d$e�ZG d%d&� d&e�ZG d'd(� d(e�ZG d)d*� d*e�ZG d+d,� d,e�ZG d-d.� d.e�Z G d/d0� d0e�Z G d1d2� d2e �Z G d3d4� d4e�Z G d5d6� d6e�Z G d7d8� d8e�Z!G d9d:� d:e�Z"G d;d<� d<e�Z#G d=d>� d>e�Z$G d?d@� d@e$�Z%e#Z&e%Z'dAS )B� nlmsg_atomsz( A collection of base NLA types r c @ s e Zd ZdZdZdd� ZdS )znlmsg_atoms.nonezy 'none' type is used to skip decoding of NLA. You can also use 'hex' type to dump NLA's content. r c C s t �| � d | _d S r@ �r r� r{ rn r r r r� J s znlmsg_atoms.none.decodeN�r r r r r r� r r r r �noneB s rC c @ s e Zd ZdZdZg Zdd� ZdS )znlmsg_atoms.flagzJ 'flag' type is used to denote attrs that have no payload r c C s t �| � d| _d S r; rA rn r r r r� W s znlmsg_atoms.flag.decodeN)r r r r r rR r� r r r r �flagN s rD c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.uint8r �INTEGER)r{ �BN�r r r r rQ rR r r r r �uint8[ s rH c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.uint16r rE )r{ r: NrG r r r r �uint16a s rI c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.uint32r rO )r{ �INrG r r r r �uint32g s rK c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.uint64r rO )r{ �QNrG r r r r �uint64m s rM c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.int8r rE )r{ �bNrG r r r r �int8s s rO c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.int16r rE )r{ �hNrG r r r r �int16y s rQ c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.int32r rO )r{ r� NrG r r r r �int32 s rR c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.int64r rO )r{ �qNrG r r r r �int64� s rT c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.be8r rE )r{ z>BNrG r r r r �be8� s rU c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.be16r rE )r{ z>HNrG r r r r �be16� s rV c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.be32r rO )r{ �>INrG r r r r �be32� s rX c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.be64r rO )r{ z>QNrG r r r r �be64� s rY c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.sbe8r rE )r{ z>bNrG r r r r �sbe8� s rZ c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.sbe16r rE )r{ z>hNrG r r r r �sbe16� s r[ c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.sbe32r rO )r{ z>iNrG r r r r �sbe32� s r\ c @ s e Zd ZdZdZdgZdS )znlmsg_atoms.sbe64r rO )r{ z>qNrG r r r r �sbe64� s r] c @ s( e Zd ZdZdZdZdd� Zdd� ZdS )znlmsg_atoms.ipXaddrr �TEXTNc C s t | j| j�| d< t�| � d S r� )r �familyr{ r= r� rn r r r r� � s znlmsg_atoms.ipXaddr.encodec C s t �| � t| j| d �| _d S r� )r= r� r r_ r{ rn r r r r� � s znlmsg_atoms.ipXaddr.decode)r r r r rQ r_ r� r� r r r r �ipXaddr� s r` c @ s e Zd ZdZdZeZdS )znlmsg_atoms.ip4addrz3 Explicit IPv4 address type class. r N)r r r r r r r_ r r r r �ip4addr� s ra c @ s e Zd ZdZdZeZdS )znlmsg_atoms.ip6addrz3 Explicit IPv6 address type class. r N)r r r r r r r_ r r r r �ip6addr� s rb c @ s( e Zd ZdZdZdZdd� Zdd� ZdS ) znlmsg_atoms.ipaddra This class is used to decode IP addresses according to the family. Socket library currently supports only two families, AF_INET and AF_INET6. We do not specify here the string size, it will be calculated in runtime. r r^ c C s6 | j �d�dkrt}nt}t|| j �| d< t�| |�S )N�:rj r{ )r{ r� r r r r= r� �r5 ru r_ r r r r� � s z nlmsg_atoms.ipaddr.ft_encodec C s4 t �| |� | jdkr t}nt}t|| d �| _d S )Nr r{ )r= r� rv r r r r{ rd r r r r� � s z nlmsg_atoms.ipaddr.ft_decodeN)r r r r r rQ r� r� r r r r �ipaddr� s re c @ s8 e Zd ZdZdZdZdZdZdd� Zdd � Z d d � Z dS ) znlmsg_atoms.targeta A universal target class. The target type depends on the msg family: * AF_INET: IPv4 addr, string: "127.0.0.1" * AF_INET6: IPv6 addr, string: "::1" * AF_MPLS: MPLS labels, 0 .. k: [{"label": 0x20, "ttl": 16}, ...] r r^ NTc C s2 | j d ur| j S | }|jd ur&|j}q|�dt�S )Nr_ )r_ rh rV r )r5 r� r r r � get_family s z nlmsg_atoms.target.get_familyc C s | � � }|ttfv r&t|| j�| d< n�|tkr�d| d< t| jttt f�rP| j}n>d| v r�| � dd�| � dd�| � dd�| � dd�d�g}ng }|D ]^}|� dd�d > |� dd�d > B |� d�r�d ndd > B |� dd�B }| d t � d |�7 < q�nt d��t�| � d S )Nr{ r? �labelr �tc�bos�ttl�rg rh ri rj r! r r r rW �socket family not supported)rf r r r r{ r rG r� r r� rV r� r r� r= r� )r5 r_ �labels�recordrg r r r r� s6 �� �� �� znlmsg_atoms.target.encodec C s� t �| � | �� }|ttfv r0t|| d �| _n�|tkr�g | _tt | d �d �D ]b}t � d| d |d |d d � �d }|d@ d? |d@ d? |d @ d ? |d @ d �}| j� |� qRnt d ��d S )Nr{ r rW r l p� r! i r r' r � rk rl )r= r� rf r r r r{ r r r� r� �unpackrS r� )r5 r_ r� rg rn r r r r� 0 s& �� �znlmsg_atoms.target.decode) r r r r r rQ r_ r� rf r� r� r r r r �target� s rq c @ s e Zd ZdZeZdS )znlmsg_atoms.mpls_targetr N)r r r r r r_ r r r r � mpls_targetE s rr c @ s. e Zd ZdZdZdZdgZdd� Zdd� Zd S ) znlmsg_atoms.l2addrz% Decode MAC address. r r^ )r{ z=6sc C s6 t jdgdd� | j�d�D ��R � | d< t�| � d S )N�BBBBBBc S s g | ]}t |d ��qS �r �r� r� r r r r� V r? z-nlmsg_atoms.l2addr.encode.<locals>.<listcomp>rc r{ )r� r r{ �splitr r� rn r r r r� T s �� znlmsg_atoms.l2addr.encodec C s0 t �| � d�dd� t�d| d �D ��| _d S )Nrc c s s | ]}d | V qdS �z%02xNr r� r r r r� \ s z,nlmsg_atoms.l2addr.decode.<locals>.<genexpr>rs r{ )r r� rT r� rp r{ rn r r r r� Z s �znlmsg_atoms.l2addr.decodeN) r r r r r rQ rR r� r� r r r r �l2addrJ s rx c @ s( e Zd ZdZdZdZdd� Zdd� ZdS ) znlmsg_atoms.lladdra1 Decode link layer address: a MAC, IPv4 or IPv6 address. This type depends on the link layer address length: * 6: MAC addr, string: "52:ff:ff:ff:ff:03" * 4: IPv4 addr, string: "127.0.0.1" * 16: IPv6 addr, string: "::1" * any other length: hex dump r r^ c C s� d| j v r^t| j �dkrLd| j vrLtjdgdd� | j �d�D ��R � | d< q�tt| j �| d< n,d| j v rztt| j �| d< ntd � | j ���t � | � d S ) Nrc � z::rs c S s g | ]}t |d ��qS rt ru r� r r r r� r r? z-nlmsg_atoms.lladdr.encode.<locals>.<listcomp>r{ �.zUnsupported value {}) r{ r� r� r rv r r r r� �formatr= r� rn r r r r� n s �� znlmsg_atoms.lladdr.encodec C s� t �| � t| d �dkr>d�dd� t�d| d �D ��| _n�t| d �dkr`tt| d �| _n|t| d �dkr�tt | d �| _nZt| d �d kr�d | _nB| j j }| j j }| j j ||| � }t�d t|�� t| d �| _d S ) Nr{ r rc c s s | ]}d | V qdS rw r r� r r r r� s �z,nlmsg_atoms.lladdr.decode.<locals>.<genexpr>rs r r r rP zqunknown or invalid lladdr size, please report to: https://github.com/svinota/pyroute2/issues/717 packet data: %s)r= r� r� rT r� rp r{ r r r rh ru rv rs r� r r )r5 ru rv rs r r r r� | s& � �znlmsg_atoms.lladdr.decodeN�r r r r r rQ r� r� r r r r �lladdr` s r} c @ s e Zd ZdZdZdd� ZdS )znlmsg_atoms.hexzD Represent NLA's content with header as hex string. r c C s t �| � t| d �| _d S r� )r= r� r r{ rn r r r r� � s znlmsg_atoms.hex.decodeNrB r r r r �hex� s r~ c @ s4 e Zd ZdZdZdZedd� �Zdd� Zdd � Z d S ) znlmsg_atoms.arrayz+ Array of simple data type )�_fmtTc C sZ t | dd �d ur| jS z"t | j| j�}|jd d | _W n tyR | j| _Y n0 | jS )Nr r r )rI r rh rx rR r )r5 Zfclassr r r r� � s znlmsg_atoms.array.fmtc C sN d| j d d� t| j�| j dd � f }tj|g| j�R � | d< t�| � d S )N�%s%i%srj r{ )r� r� r{ r� r r= r� )r5 r� r r r r� � s (znlmsg_atoms.array.encodec C s~ t �| � t| d �}t�| j�}|| }|| p6| }| d d | � }d| jd d� || jdd � f }t�||�| _d S )Nr{ r� rj )r= r� r� r� r� r� rp r{ )r5 Z data_lengthZ element_sizeZ array_size�trailrs r� r r r r� � s "znlmsg_atoms.array.decodeN) r r r r r r� r r� r� r� r r r r �array� s r� c @ s e Zd ZdZdZdS )znlmsg_atoms.cdataz Binary data r Nr? r r r r �cdata� s r� c @ s( e Zd ZdZdZdZdd� Zdd� ZdS ) znlmsg_atoms.stringz UTF-8 string. r r^ c C s< t | d t�r.tjd dkr.t| d d�| d< t�| � d S )Nr{ r r r) )rG rH r+ r, r- r= r� rn r r r r� � s znlmsg_atoms.string.encodec C sL t �| � | d | _tjd dkrHz| j�d�| _W n tyF Y n0 d S )Nr{ r r r) )r= r� r{ r+ � version_info�UnicodeDecodeErrorrn r r r r� � s znlmsg_atoms.string.decodeNr| r r r r �string� s r� c @ s e Zd ZdZdZdZdS )znlmsg_atoms.asciizz) Zero-terminated string. r r Nr< r r r r �asciiz� s r� N)(r r r r r r rC rD rH rI rK rM rO rQ rR rT rU rV rX rY rZ r[ r\ r] r= r` ra rb re rq rr rx r} r~ r� r� r� r� �binaryZ nul_stringr r r r r@ ; sF L9 $ r@ c @ s e Zd ZdZdZdd� ZdS )r� z Main NLA class r c C s t �| � | d= d S �Nr� )r r� rn r r r r� s z nla.decodeNrB r r r r r� � s r� c @ s e Zd ZdZdZdd� ZdS )� nla_stringz NLA + string decoder r c C s t �| � | d= d S r� )r= r� rn r r r r� s znla_string.decodeNrB r r r r r� s r� c @ s e Zd ZdZdZdd� ZdS )� nla_structz% NLA + packed struct decoder r c C s t �| � | d= d S r� )r> r� rn r r r r� s znla_struct.decodeNrB r r r r r� s r� c @ s e Zd ZdZdZdZdS )�nlmsgz$ Main netlink message class r ))rv rJ r; )r� r: )r� rJ )�pidrJ N)r r r r r r� r r r r r� # s r� c @ s e Zd ZdZdZdZdZdS )�nlmsgerrz$ Extended ack error message r ))r� r� ))ZNLMSGERR_ATTR_UNUSEDrC )ZNLMSGERR_ATTR_MSGr� )ZNLMSGERR_ATTR_OFFSrK )ZNLMSGERR_ATTR_COOKIErH N)r r r r r rR rW r r r r r� 5 s r� c @ s e Zd ZdZdZdZdS )�genlmsgz! Generic netlink message r ))�cmdrF )r, rF )�reservedr: N)r r r r r rR r r r r r� F s r� c @ sX e Zd ZdZdZdZG dd� de�ZG dd� de�ZG dd � d e�Z G d d � d e�Z d S ) �ctrlmsgz! Netlink control message r ) )�CTRL_ATTR_UNSPECrC )�CTRL_ATTR_FAMILY_IDrI )�CTRL_ATTR_FAMILY_NAMEr� )�CTRL_ATTR_VERSIONrK )�CTRL_ATTR_HDRSIZErK )�CTRL_ATTR_MAXATTRrK )� CTRL_ATTR_OPSz*ops)�CTRL_ATTR_MCAST_GROUPSz *mcast_groups)�CTRL_ATTR_POLICY� policy_nest)�CTRL_ATTR_OP_POLICY� command_nest)� CTRL_ATTR_OPrK c @ s e Zd ZdZdZdS )z ctrlmsg.opsr ))�CTRL_ATTR_OP_UNSPECrC )�CTRL_ATTR_OP_IDrK )�CTRL_ATTR_OP_FLAGSrK N�r r r r rW r r r r �opsf s r� c @ s e Zd ZdZdZdS )zctrlmsg.mcast_groupsr ))�CTRL_ATTR_MCAST_GRP_UNSPECrC )�CTRL_ATTR_MCAST_GRP_NAMEr� )�CTRL_ATTR_MCAST_GRP_IDrK Nr� r r r r � mcast_groupso s r� c @ s: e Zd ZdZedd� �edd� �d�ZG dd� de�ZdS ) zctrlmsg.policy_nestr c C s t d| d| � d��S )N�attribute_nestzPOLICY(r� �r, r< r r r r> } r? z ctrlmsg.policy_nest.<lambda>c C s t dt| dd� �| �S )Nr� r rj �r, r� r< r r r r> � r? �r� r� c @ s: e Zd ZdZedd� �edd� �d�ZG dd� de�ZdS ) z"ctrlmsg.policy_nest.attribute_nestr c C s t d| d| � d��S )N�nl_policy_type_attrzATTR(r� r� r< r r r r> � r? z+ctrlmsg.policy_nest.attribute_nest.<lambda>c C s t dt| dd� �| �S )Nr� r rj r� r< r r r r> � r? r� c @ s e Zd ZdZdZdS )z6ctrlmsg.policy_nest.attribute_nest.nl_policy_type_attrr ) )�NL_POLICY_TYPE_ATTR_UNSPECrC )�NL_POLICY_TYPE_ATTR_TYPErK )� NL_POLICY_TYPE_ATTR_MIN_VALUE_SrT )� NL_POLICY_TYPE_ATTR_MAX_VALUE_SrT )� NL_POLICY_TYPE_ATTR_MIN_VALUE_UrT )� NL_POLICY_TYPE_ATTR_MAX_VALUE_UrT )� NL_POLICY_TYPE_ATTR_MIN_LENGTHrK )� NL_POLICY_TYPE_ATTR_MAX_LENGTHrK )� NL_POLICY_TYPE_ATTR_POLICY_IDXrK )�"NL_POLICY_TYPE_ATTR_POLICY_MAXTYPErK )�#NL_POLICY_TYPE_ATTR_BITFIELD32_MASKrK )�NL_POLICY_TYPE_ATTR_PADrM )�NL_POLICY_TYPE_ATTR_MASKrM Nr� r r r r r� � s r� N)r r r r r: rW r� r� r r r r r� � s ��� r� N)r r r r r: rW r� r� r r r r r� x s ��� r� c @ s: e Zd ZdZedd� �edd� �d�ZG dd� de�ZdS ) zctrlmsg.command_nestr c C s t d| d| � d��S )N�command_nest_attrszOP(r� r� r< r r r r> � r? z ctrlmsg.command_nest.<lambda>c C s t dt| dd� �| �S )Nr� r rj r� r< r r r r> � r? r� c @ s e Zd ZdZdZdS )z'ctrlmsg.command_nest.command_nest_attrsr ))ZCTRL_ATTR_POLICY_UNSPECrC )ZCTRL_ATTR_POLICY_DOrK )ZCTRL_ATTR_POLICY_DUMPrK Nr� r r r r r� � s r� N)r r r r r: rW r� r� r r r r r� � s ��� r� N) r r r r r rW r� r� r� r� r� r r r r r� P s +r� )�r r� r� r� r+ � threadingr� rC r� � collectionsr �socketr r r r r Zpyroute2.commonr r r Zpyroute2.netlink.exceptionsr r r � getLoggerr r� Z_neZ_der r r, rH r/ ZNLMSG_MIN_TYPEZ GENL_NAMSIZZ GENL_MIN_IDZ GENL_MAX_IDZGENL_ADMIN_PERMZGENL_CMD_CAP_DOZGENL_CMD_CAP_DUMPZGENL_CMD_CAP_HASPOLZGENL_ID_GENERATEZ GENL_ID_CTRLZCTRL_CMD_UNSPECZCTRL_CMD_NEWFAMILYZCTRL_CMD_DELFAMILYZCTRL_CMD_GETFAMILYZCTRL_CMD_NEWOPSZCTRL_CMD_DELOPSZCTRL_CMD_GETOPSZCTRL_CMD_NEWMCAST_GRPZCTRL_CMD_DELMCAST_GRPZCTRL_CMD_GETMCAST_GRPZCTRL_CMD_GETPOLICYr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� ZNL_ATTR_TYPE_INVALIDZNL_ATTR_TYPE_FLAGZNL_ATTR_TYPE_U8ZNL_ATTR_TYPE_U16ZNL_ATTR_TYPE_U32ZNL_ATTR_TYPE_U64ZNL_ATTR_TYPE_S8ZNL_ATTR_TYPE_S16ZNL_ATTR_TYPE_S32ZNL_ATTR_TYPE_S64ZNL_ATTR_TYPE_BINARYZNL_ATTR_TYPE_STRINGZNL_ATTR_TYPE_NUL_STRINGZNL_ATTR_TYPE_NESTEDZNL_ATTR_TYPE_NESTED_ARRAYZNL_ATTR_TYPE_BITFIELD32r� r� r� r� r� r� r� r� r� r� r� r� r� � NETLINK_ROUTEZNETLINK_UNUSED�NETLINK_USERSOCK�NETLINK_FIREWALLZNETLINK_SOCK_DIAG� NETLINK_NFLOG� NETLINK_XFRMZNETLINK_SELINUXZ NETLINK_ISCSIZ NETLINK_AUDITZNETLINK_FIB_LOOKUPZNETLINK_CONNECTORZNETLINK_NETFILTER�NETLINK_IP6_FW�NETLINK_DNRTMSGZNETLINK_KOBJECT_UEVENTZNETLINK_GENERICZNETLINK_SCSITRANSPORTr r r� Z NLM_F_MULTIZ NLM_F_ACKZ NLM_F_ECHOZNLM_F_DUMP_INTRZNLM_F_DUMP_FILTEREDZ NLM_F_ROOTZ NLM_F_MATCHZ NLM_F_ATOMICZ NLM_F_DUMPZ NLM_F_REPLACEZ NLM_F_EXCLZ NLM_F_CREATEZ NLM_F_APPENDZ NLM_F_CAPPEDZNLM_F_ACK_TLVSr( r) r* r+ Z NLMSG_CONTROLZNLMSG_TRANSPORTZ NLMSG_MAX_LENZmtypesZ IPRCMD_NOOPZ IPRCMD_STOPZ IPRCMD_ACKZ IPRCMD_ERRZIPRCMD_REGISTERZ IPRCMD_RELOADZ IPRCMD_ROUTEZIPRCMD_CONNECTZIPRCMD_DISCONNECTZ IPRCMD_SERVEZIPRCMD_SHUTDOWNZIPRCMD_SUBSCRIBEZIPRCMD_UNSUBSCRIBEZIPRCMD_PROVIDEZ IPRCMD_REMOVEZIPRCMD_DISCOVERZIPRCMD_UNREGISTERZ SOL_NETLINKZNETLINK_ADD_MEMBERSHIPZNETLINK_DROP_MEMBERSHIPZNETLINK_PKTINFOZNETLINK_BROADCAST_ERRORZNETLINK_NO_ENOBUFSZNETLINK_RX_RINGZNETLINK_TX_RINGZNETLINK_LISTEN_ALL_NSIDZNETLINK_EXT_ACKZNETLINK_GET_STRICT_CHK�localr� r r� Z cache_jitr� r, r: rL rq �objectr r r$ r' r r9 r r= r> r@ r� r� r� r� r� r� r� r r r r �<module> s� \ �O &$ 3B � � � B �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка