Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/__pycache__/__init__.cpython-39.pyc
Ðазад
a ]�hG� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZ ddlmZmZ dd lmZmZ dd lmZ dd lmZ dZd ZdZ d Z dd� Z G dd� de �Z dS )a, General structure ================= The NDB objects are dictionary-like structures that represent network objects -- interfaces, routes, addresses etc. They support the common dict API, like item getting, setting, iteration through key and values. In addition to that, NDB object add specific calls, see the API section below. Most of the NDB object types store all attributes in a flat one level dictionary. Some, like multihop routes, implement nested structures. In addition to that, some objects like `Interface` provide views on the DB that list only related objects -- addresses, routes and neighbours. More on these topic see in the corresponding sections. NDB objects and RTNL API ======================== The dictionary fields represent RTNL messages fields and NLA names, and the objects are used as argument dictionaries to normal `IPRoute` methods like `link()` or `route()`. Thus everything described for the `IPRoute` methods is valid here as well. See also: :ref:`iproute` .. testsetup:: from pyroute2 import IPMock as IPRoute from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True .. testcode:: # create a vlan interface with IPRoute eth0 = 2 with IPRoute() as ipr: ipr.link("add", ifname="vlan1108", kind="vlan", link=eth0, vlan_id=1108) # same with NDB: with NDB(log="stderr") as ndb: vlan = ndb.interfaces.create( ifname="vlan1108", kind="vlan", link="eth0", vlan_id=1108, ) vlan.commit() Slightly simplifying, if a network object doesn't exist, NDB will run an RTNL method with "add" argument, if exists -- "set", and to remove an object NDB will call the method with "del" argument. API === � N)�partial)�cli)� NetlinkError)�RequestProcessor� )� AuthManager� check_auth)�InvalidateHandlerException�State)� cmsg_event)�Record� � c C s� t |�� �t | j�kr&| j�d� d S | jjj| j| d j | j dfi |��| d d� | jjj| j| d j | j dfi |��| d d� | � � d S )Nz)ignore incomplete idx_req in the fallback�target�set��source�get) r �keys�kspec�log�debug�ndb� _event_queue�put�sources�api�load_sql)�self�idx_req�req� r! ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/__init__.py� fallback_addY s �� ��r# c s� e Zd ZdZdZdZg Zg Zg Zi Z i Z e Z g Z dZdZdZdZdZdZdZdZdZdZg ZdZdZdZdZ e dd� �Z e j dd� �Z e dd� �Z e d d � �Z!e!j d d � �Z!e"d d � �Z#e"dd� �Z$e"dd� �Z%e"dd� �Z&e"dd� �Z'e"dd� �Z(e)dd� �Z*dwdd �Z+e"dxd d ��Z,e)e-fd d ��Z.d!d"� Z/d#d$� Z0d%d&� Z1e d'd(� �Z2e"d)d*� �Z3e"d+d,� �Z4e"d-d.� �Z5d/d0� Z6d1d2� Z7d3d4� Z8e9d5�d6d7� �Z:e9d8�d9d:� �Z;d;d<� Z<d=d>� Z=e>j?d?d@� �Z@e>jAe9d5�dydAdB���ZBdCdD� ZCdzdFdG�ZDdHdI� ZEe9d8�d{dJdK��ZFdLdM� ZGdNdO� ZHe9d8�d|dPdQ��ZIdRdS� ZJe dTdU� �ZKe9d8�dVdW� �ZLdXdY� ZMdZd[� ZNd\d]� ZOd^d_� ZPd`da� ZQdbdc� ZRe9d8�ddde� �ZSe9d8�d}dgdh��ZTd~didj�ZUdkdl� ZVdmdn� ZW� fdodp�ZXdqdr� ZYddsdt�ZZdudv� Z[� Z\S )�� RTNL_Objectz� The common base class for NDB objects -- interfaces, routes, rules addresses etc. Implements common logic for all the classes, like item setting, commit/rollback, RTNL event filters, loading values from the DB backend etc. NFc C s | j S )z� Main reference table for the object. The SQL schema of this table is used to build the object key and to verify fields. Read-write property. ��_table�r r! r! r" �table� s zRTNL_Object.tablec C s || _ d S �Nr% )r �valuer! r! r" r( � s c C s | j rd| j| j f S | jS dS )z� Effective table where the object actually fetches the data from. It is not always equal `self.table`, e.g. snapshot objects fetch the data from snapshot tables. Read-only property. �%s_%sN)�ctxidr( r' r! r! r" �etable� s zRTNL_Object.etablec C s� | j pi }t�� }| jD ]Z}| j�|�}|| v r| | }|du rP||v rP|| }t|ttt f�rjt � |�}|||< qt |�t | j�k r�| j D ]&}| j�|�}| �|�r�| | ||< q�|S )z� Key of the object, used to build SQL requests to fetch the data from the DB. Read-write property. N)�_key� collections� OrderedDictr �iclass�nla2name� isinstance�list�tuple�dict�json�dumps�len�key_extra_fieldsr )r �nkey�ret�nameZknamer* r! r! r" �key� s" zRTNL_Object.keyc C sB t |t�sd S |�� D ]&\}}|d urt�| | j�|�|� qd S r) )r3 r6 �items� __setitem__r1 r2 )r �kr> r* r! r! r" r> � s c C s |j j�d|j �S )NzSELECT count(*) FROM %s)r � task_manager� db_fetchoner( ��cls�viewr! r! r" �_count� s �zRTNL_Object._countc C s dg fS )N� r! rD r! r! r" � _dump_where� s zRTNL_Object._dump_wherec c sF d|| j f }|V | �|�\}}|jj�|| |�D ] }|V q6d S )Nz7 SELECT %s FROM %s AS main )r( rI r rB �db_fetch)rE rF �names�fnamesr �where�values�recordr! r! r" �_sdump� s ��zRTNL_Object._sdumpc C s. | � ||jjj| j d |jjj| j d �S )N�norm_idxZknames�rP r �schema�compiledr( rD r! r! r" �summary� s �zRTNL_Object.summaryc C s. | � ||jjj| j d |jjj| j d �S )N� norm_namesrL rR rD r! r! r" �dump� s �zRTNL_Object.dumpc C s |S r) r! )rE � processed�specr! r! r" �spec_normalize� s zRTNL_Object.spec_normalizec C s | S r) r! )r> �contextr! r! r" �key_load_context s z RTNL_Object.key_load_contextTc s� |� _ |j� _|jj� _|� _|� _|jj� _|jj� _t� � _|� _ � j pP� j � _ g � _ t � � � _� jj�d�� _� j�d� |d u r�td � jj�d��g}|� _t� � _� j�d� g � _t�� � _� j�� d� _t�� � _ t � � � t � � �d�� _!� jj"� j d � _#� jj"� j d � _$� jj"� j d � _%� jj"� j d � _&� jj"� j d � _'� fd d �� j&D �� _(d � _)� j*d u �r�i � _*g � _+t,j-t.t,j/d it,j0d it,j0d t,j1d t,j2d t,j3d id�� _4t5|t6��r�|�7dd �� _8|�7dd�} n d � _8d} � �9|�} � �:|�} | �rd|| @ �r(t;d��|D ]} || � � j �<| �< �q,d� v�r�� �=d� j j>� n<| �srt;d��| � _?|�r�|d u �r�� �@� n� j@� j d� d� _Ad S )NZ rtnl_object�init�auth�invalidF)r[ �idxrQ � all_namesrV �lookup_fallbacksc s g | ]}� j �|��qS r! )rK �count��.0�xr' r! r" � <listcomp>4 � z(RTNL_Object.__init__.<locals>.<listcomp>)�addr �del� ndb_chain�createz object existsr zobject does not exists)r( T)BrF r r �masterr, rS rB r �changedr1 �utabler( �errors�time�atimer Zchannelr r � auth_managersr �state� snapshot_deps� threading�Event� load_event� load_debug�Lock�lockr � field_filter�weakref�proxy� object_datarT r �knormrY rK rb � names_count� last_save� event_map� _apply_script�errno�EEXISTr# �EAGAINZENODEV�ENOENTZESRCHZ EADDRNOTAVAIL� fallback_forr3 r6 �pop�chain�exists� complete_key�KeyErrorr2 � load_valueZdefault_targetr> r �_init_complete) r rF r> r1 r, �loadrm �checkrs rl r� Zckeyr= r! r' r" �__init__ s� � � �� zRTNL_Object.__init__c C s\ t |t�r|�� }t| �� ||d�}t |t�r8|�|� d|vrP|d urP||d< | �||�S )N)r[ �primer )r3 r �_as_dictr r| r6 �updaterZ )rE rY r[ � localhost�rpr! r! r" �new_spec^ s zRTNL_Object.new_specc C s� |D ]�}|� |�}zFt|t�r4d|v r4|d ||< n"|durVt|t�sV| | d ||< W q ttfy� |tkrv� n4|tkr�d||< n"|tkr�||= n|t kr�ntd��Y q0 qdS )zN Resolve specific fields e.g. convert port ifname into index. �indexNzunknown rslv policy) r r3 r6 �intr� � TypeError� RSLV_RAISE� RSLV_NONE� RSLV_DELETE� RSLV_IGNORE)rF rY �fields�policy�field� referencer! r! r" �resolvei s" zRTNL_Object.resolvec C s d S r) r! )r �markr! r! r" � mark_tflags� s zRTNL_Object.mark_tflagsc s t � fdd�t�� ��S )Nc s | � j vS r) �� hidden_fields�rf r' r! r" �<lambda>� rh z"RTNL_Object.keys.<locals>.<lambda>)�filterr6 r r' r! r' r" r � s zRTNL_Object.keysc s t � fdd�t�� ��S )Nc s | d � j vS )Nr r� r� r' r! r" r� � rh z#RTNL_Object.items.<locals>.<lambda>)r� r6 r? r' r! r' r" r? � s �zRTNL_Object.itemsc C s d| � d| jj�iS )Nr )r r r� r' r! r! r" r[ � s zRTNL_Object.contextc C s | j �|�S r) )� msg_classr2 �r r= r! r! r" r2 � s zRTNL_Object.nla2namec C s d S r) r! )r �left�rightr! r! r" �compare_record� s zRTNL_Object.compare_recordc C s | j �|�S r) )r� �name2nlar� r! r! r" r� � s zRTNL_Object.name2nlac C s | S r) r! r' r! r! r" � __enter__� s zRTNL_Object.__enter__c C s | � � d S r) )�commit)r �exc_type� exc_value� tracebackr! r! r" �__exit__� s zRTNL_Object.__exit__c C s t | �S r) )�idr' r! r! r" �__hash__� s zRTNL_Object.__hash__zobj:readc C s t �| |�S r) )r6 � __getitem__�r r> r! r! r" r� � s zRTNL_Object.__getitem__z obj:modifyc C s� | j �||��� D ]�\}}| �|�|kr*q| jdkr�|| jv r�| jr�| j�d|� d|� d| j � �� t | �| j | j | j d�| _ | j�d� n td| ��|dv r�| j�d � || �|d �kr|d kr�| j�|� t�| ||� qd S ) N�systemzprepare replace z = z in �rs �replacez"attempt to change a key field (%s))Z net_ns_fdZ net_ns_pid�setnsr )r r� r? r rt r� �_replace_on_key_changer r r> �typerF rs �_replacer � ValueErrorrn ri r6 r@ )r r> r* r; Znvaluer! r! r" r@ � s* � �� zRTNL_Object.__setitem__c s" t �d|�}|� fdd�|D �� S )N�Fieldsc s g | ] }� | �qS r! r! )re r> r' r! r" rg � rh z&RTNL_Object.fields.<locals>.<listcomp>)r/ � namedtuple)r �argvr� r! r' r" r� � s zRTNL_Object.fieldsc C s t | j�S r) )�reprr> r' r! r! r" �key_repr� s zRTNL_Object.key_reprc K s d|d< | |d< | j | S )a� Create an RTNL object of the same type, and add it to the commit chain. The spec format depends on the object. The method allows to chain creation of multiple objects sharing the same context. .. code-block:: python ( ndb.interfaces['eth0'] # 1. .set(state="up") # 2. .ipaddr # 3. .create(address='10.0.0.1', prefixlen=24) # 4. <- create() .create(address='10.0.0.2', prefixlen=24) # 5. <- create() .commit() # 6. ) Here: 1. returns an interface object `eth0` 2. sets `state="up"` and returns the object itself 3. returns an address view, that uses `eth0` as the context 4. creates an IP address, the interface lookup is done via context 5. creates another IP address -- same type, same context 6. commits the changes in the order: (interface `state="up"`; address `10.0.0.1/24`; address `10.0.0.2/24`) Trl rk )rF )r rY r! r! r" rl � s zRTNL_Object.createc C s` |p| j jj�dd�}|dkr&t| �S t�� }t| �D ]}| | ||< q6dtj |ddd� S dS )z� Return the object in a specified format. The format may be specified with the keyword argument `format` or in the `ndb.config['show_format']`. TODO: document different formats Z show_format�nativez%s � )�,z: )�indent� separatorsN) rF r �configr r6 r/ r0 �sortedr7 r8 )r �fmt�outr> r! r! r" �show� s zRTNL_Object.showc O s8 |r|d | |d < n |r4|� � D ]\}}|| |< q"| S )an Call formats: * `set(key, value)` * `set(key=value)` * `set(key1=value1, key2=value2)` .. code-block:: python with ndb.interfaces["eth0"] as eth0: eth0.set( mtu=1200, state='up', address='00:11:22:33:44:55', ) r r )r? )r r� �kwargr> r* r! r! r" r � s zRTNL_Object.setr c C s" t t|d d�| jjj�� d �S )Ng�������?r � )�max�minrF r r �qsize)r �itnr! r! r" �wtime s zRTNL_Object.wtimec C sB dd� }t �| �}| j�� D ] \}}| jj�|t|||�� q d S )Nc W s< zt | � |�|� W S ty6 | � d u r0t� �� Y n0 d S r) )�getattr� Exceptionr )�wr�fnamer� r! r! r" � wr_handler" s z(RTNL_Object.register.<locals>.wr_handler)r} �refr� r? r rB Zregister_handlerr )r r� r� �eventr� r! r! r" �register s ��zRTNL_Object.registerc C sn |p| j pt| �}| jdu r$| j}n| jj}t| �| j||| jd�}| jj� |t � |�| j � t | j�|_|S )a Create and return a snapshot of the object. The method creates corresponding SQL tables for the object itself and for detected dependencies. The snapshot tables will be removed as soon as the snapshot gets collected by the GC. N)r, rs )r, r� r� r> r� rF rs r rB Z db_save_depsr} r� r1 r rn )r r, r> �snpr! r! r" �snapshot7 s �� zRTNL_Object.snapshotc C sV | j �d|| jf � g }t|t�r.|�� }nt|�}| j| j|| j t d� | j D ]}||vrR|� d| � qR|�rBg }g }|� � D ]T\}}| j�|�}|| jv r�|}|dur�|| jv r�|� d|| jjf � |� |� q�| jj�dd�|�| jd�|�f |�}|du �r | j �d � dS t||�D ]\}}|||d d� < �q&| j �d | � |S ) aj Try to complete the object key based on the provided fields. E.g.:: >>> ndb.interfaces['eth0'].complete_key({"ifname": "eth0"}) {'ifname': 'eth0', 'index': 2, 'target': u'localhost', 'tflags': 0} It is an internal method and is not supposed to be used externally. z complete key %s from table %s�rF rY r� r� zf_%sN� f_%s = %szSELECT %s FROM %s WHERE %sz , � AND zgot noner zgot %s)r r r- r3 r r� r6 r� rF �resolve_fieldsr� r �appendr? r1 r� rY rS �plchr rB rC �join�zip) r r> �fetchr= r rN r* Znla_namerY r! r! r" r� O sJ � �� zRTNL_Object.complete_keyc C s | j �|�S )z6 Check if the object exists in the DB )rF r� r� r! r! r" r� � s zRTNL_Object.existsc C s� | j durf| j�d| j| j jf � t| �| j| j| jd�}|j�d� | j�d� | � | j � || _ | j�dt | jj � � |p�| j }|dkr�| � � �� S |j�| j�� � | j|_|jdd � |jD ]\}}|j|d � q�| S dS ) z� Try to rollback the object state using the snapshot provided as an argument or using `self.last_save`. Nzrollback replace: %s :: %sr� �remover� z rollback: %s���T)�rollback)r� )r� r r r> r� rF rs rt r r� �str�eventsr� r� �applyr �_apply_script_snapshots�rollback_chainru r� )r r� Z new_replace�linkr� r! r! r" r� � s* � � zRTNL_Object.rollbackc C s d S r) r! r' r! r! r" �clear� s zRTNL_Object.clearc C s | j dko| j o| j S )Nr� )rt rn r� r' r! r! r" �clean� s ��zRTNL_Object.cleanc C s� | j r | S | jr| j�� | j�dt| jj� � | jdkr�t| �}d| _ z| j dd�W S t y� } zNt � � |_t| �� �D ] }| |= q~|D ]}t�| ||| � q�|�W Y d}~n d}~0 0 | �� | _ z�z| j dd� W n� t �y` } zjz | �� W nN t �yH } z4|g|_t|d��r.|j�|j� d|_W Y d}~n d}~0 0 � W Y d}~n d}~0 0 W | j du�r�| j j�| j�� � n"| j du�r�| j j�| j�� � 0 | jdu�r�d| _| S )z� Commit the pending changes. If an exception is raised during `commit()`, automatically `rollback()` to the latest saved snapshot. z commit: %sr_ r� r� )�modeNr� )r� r� r� r r r� rt r� r6 r� r� r� r� � format_exc�tracer5 r r@ r� r� �hasattr�extendr r r� )r �saveZe_ir> Ze_cZe_rr! r! r" r� � sH � zRTNL_Object.commitc C s: | j � | j�d� | W d � S 1 s,0 Y dS )z Set the desired state to `remove`, so the next `apply()` call will delete the object from the system. r� N)r{ rt r r' r! r! r" r� � s zRTNL_Object.removec C sn d}| � � | j�dt| jj� � | j�� |vrB| j�d� dS | jr^| j�d| j � dS | j�d� dS )N))r_ r� )r� r_ )r� r_ )r� r� )r� r� z check: %szcheck state: FalseFzcheck changed: %sz check: TrueT)r r r r� rt r� Z transitionrn )r Z state_mapr! r! r" r� � s zRTNL_Object.checkc C s$ t |�}| jD ]}| | ||< q|S r) )r6 rn )r r� r r> r! r! r" �make_req s zRTNL_Object.make_reqc C s |S r) r! )r r� r! r! r" � make_idx_req s zRTNL_Object.make_idx_reqc C sh g }g }| j D ]4}|�d|| jjf � |�| �| j�|�d �� q| jj� d| j d� |�f |�d S )Nr� zV SELECT count(*) FROM %s WHERE %s r� r ) r r� rS r� r r1 r2 r rB rC r( r� )r � conditionsrN r= r! r! r" � get_count s ���zRTNL_Object.get_countc K s d S r) r! )r �methodrY r! r! r" � hook_apply+ s zRTNL_Object.hook_applyc C s | j dkrd| _n | �� | _| S )Nr_ r� )rt r� r� r' r! r! r" � save_context. s zRTNL_Object.save_contextr� c sb � j � j� � jtd� � j�dt� jj� � � j�d� � j � � g � _ z� j � � W n tyj Y n0 � jdd� � jdkr�� �� dkr�� j�d�}n � j�� }� fd d �� jj� j d D �}� �|�}� �|�}� j�d t|� � � j�d t|� � d}|dv �rlt� �� �D ]&\} } | |v�r | du�r | || < �q � jdu�rf� �|� jj � j j �}d}n<|dk�r|d}n,|dk�r�d}n |dk�r�d}|}ntd��� j�d|� �� � j�d|� �� |du�r�||�}d} t d�D �] } zP� j�d||f � � j � d j!� j!|fi |�� d} � j"|fi |�� W �n( t#�yh } �z � j�d | � | �sx� j�d � � | j$� j%| v �rP� j�d | j$� f � � j%| | j$ du�rT� j�d � j%| | j$ |f � zbt&� j%| | j$ t��r � j � d j!� j!� j%| | j$ fi |�� n� j%| | j$ � ||� W n t#�yL Y n0 n| �W Y d} ~ n d} ~ 0 0 � �'| �}� jj j(�)� }� jj*�� d �}|du�r�|j)}nd}� j�d |t+� �|||f � � �,� �r� j�d!� �qD� j�d"� � j �-|� � j � � �q� j�d#t+� �|f � � �.d$d%� � j,��sDg � _/td&��� j�d't+� � � |d(k�rv� j0�1� � j0�2� |�rֈ jj3�4� D �].}t5t6� �|��s�t5|t6� ���r��q�|j�� j j �7d)�� j8�f �}|D ]�}t9t:� jj� d* |��}t9� �fd+d,�|�� D ��}d|d-< z� j�;|��}W n t<�yD Y �q�Y n0 |j� j8d.� |j�d� |�=� z |�2� W n< t�y� } z"� j>�?t@�@� || f� W Y d} ~ n d} ~ 0 0 �qq�tA� jB�D ]}|�C� �q�n�� j/}g � _/|D ]v\}}� |d/< ||d0< � �.d1d%� |t� |�}t&|tD��s&|g}|D ].}t&|t��r@|�n|du�r*� j �?|� �q*�q� S )2as Apply the pending changes. If an exception is raised during `apply()`, no `rollback()` is called. No automatic snapshots are madre. In order to properly revert the changes, you have to run:: obj.save_context() try: obj.apply() except Exception: obj.rollback() r� zevents log: %sz run applyF)� set_stater� r r_ c s$ i | ] }� � |�d ur|� | �qS r) )r rd r' r! r" � <dictcomp>_ s �z%RTNL_Object.apply.<locals>.<dictcomp>rQ z apply req: %szapply idx_req: %sN)r_ r� ri r r� r� rj z state transition not supportedzapply transition from: zapply method: r� zAPI call %s (%s)r Tz error: %sz%error on the first API call, escalatezignore error %s for %szrun fallback %s (%s)z:stats: apply %s {objid %s, wtime %s, mqsize %s, nqsize %s}�checkedz check failedzstats: %s apply %s failc S s | S r) r! r� r! r! r" r� � rh z#RTNL_Object.apply.<locals>.<lambda>zcould not apply the changeszstats: %s passr� z SELECT * FROM %s_%s EXCEPT SELECT * FROM %s ra c s( g | ] }|d � j j� d v r|�qS )r r` )rS rT rd �r r( r! r" rg � s �z%RTNL_Object.apply.<locals>.<listcomp>rl )r, r r� c S s t | t� S r) )r3 r� r� r! r! r" r� � rh )Er� rF r� r� r r r� rt r� rx r� r� rB Z db_commitr� r r r r rS rT r( r� r r5 r? rm r� r[ r r� �ranger r r r �coder� r3 r� r r� �statsr� r� �wait� use_db_resyncr� r� r� r� �classesrN � issubclassr� rJ r, r6 r� �templater� r� rp r� rq �reversedr� r� r4 )r r� Z req_filterr� rt r� r r r rA �vZfirst_call_successr� �er� ZmqsizeZnqZnqsizerE �diffrO r> �objZ apply_script�opr� r< r! r r" r� 6 s: � � � ������ �� ��� �� 4 � zRTNL_Object.applyc C s& d }|p g }|pi }| j �d|� �� | j �d|� d|� d|� �� td�D ]�}||i |��}| j �d|� �� ||�r�| j �d� | S | j �d|� �� | jj�| d � | j�� | jjj | j | d � d �| d d � | jjj t | d | j�f| d d � | j� | �d �� | j�� qL|S ) Nz criteria zmethod z, r zret zcriteria matchedzresync the DB attempt r rW r r )r r r r rB Zdb_flushrx r� r r r r r r r� )r �criteriar r� r� r< �attemptr! r! r" r s6 ���� zRTNL_Object.use_db_resyncc C s" |� � D ]\}}| �||� qd S r) )r? r� )r �datar> r* r! r! r" r� ) s zRTNL_Object.updatec C s< t | j| j|�D ]&\}}}|dks*|dur| �||� qdS )z_ A bit special case: we can have several fields with non unique names. r N)r� rK r� r� )r rY r> rc r* r! r! r" �update_from_sql- s zRTNL_Object.update_from_sqlc s t t| ��||� d S r) )�superr$ r@ �r r> r* �� __class__r! r" � load_direct6 s zRTNL_Object.load_directc C s� || j v r| j | |�}| jr2| j�d||f � || jvrLt�| ||� nf| �|�|krh| j�|� nJ|| j v r�| j | | |�r�| j�|� n"| jr�| j�d||| �|�f � dS )zw Load a value and clean up the `self.changed` set if the loaded value matches the expectation. z load %s: %sz discard %s: %s (expected %s)N) �fields_load_transformry r r rn r6 r@ r r� � fields_cmpr r! r! r" r� 9 s �zRTNL_Object.load_valuec C sN | j s dS |du r0|du r"| j}nd| j|f }g }g }| j �� D ]B\}}|�d|| jjf � t|tt t f�rzt � |�}|�|� qB| j j�d|d�|�f |�}| j�dt|� � | j�dt| j� � |�rJ| j�^ |du �r| jdk�r*| j�d� t� | _n"| jd v�r*| �|� | j�d � W d � n1 �s@0 Y |S ) z2 Load the data from the database. Nr+ r� zSELECT * FROM %s WHERE %sr� zload_sql load: %szload_sql names: %sr_ )r� r� r� )r> r- r( r? r� rS r� r3 r4 r5 r6 r7 r8 r rB rC r� r r r� rK r{ rt r rn r ) r r( r, r r rN r= r* rY r! r! r" r M s8 � ,zRTNL_Object.load_sqlc C s� t | j| j�D ]T\}}| �|�}|dkr8||krb dS q|dkrDqq||�|�|�|�fvr dS q| j�dt|�d�� � |d �dd�d r�| j� d � t � | _ n| � � | j � � dS ) zt Check if the RTNL event matches the object and load the data from the database if it does. r NZtflagsz load_rtnl: %s�headerr� r r r_ ) r� r� r r Zget_attrr r r� rt r rn r rx )r r r� Znormr= r* r! r! r" � load_rtnlmsgt s zRTNL_Object.load_rtnlmsg)NTNTN)NN)N)r )N)N)FNr� )NN)NNT)]�__name__� __module__� __qualname__�__doc__rF ro r� r: r� r" r! �objectr| r� r� rS r� rt r rp r� Zreverse_updater& r� r� r. r� r� r� �propertyr( �setterr- r> � classmethodrG rI rP rU rW rZ � staticmethodr\ r� r� r� r� r� r r? r[ r2 r� r� r� r� r� r r� r@ r� r� r Zchange_pointerrl Z show_resultr� r r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� r r� r r r� r r$ � __classcell__r! r! r r" r$ p s� � W ! 7 = T 'r$ )!r( r/ r� r7 rv rq r� r} � functoolsr Zpyroute2r Zpyroute2.netlink.exceptionsr Zpyroute2.requests.mainr Z auth_managerr r r� r r �messagesr �reportr r� r� r� r� r# r6 r$ r! r! r! r" �<module> s* @
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка