Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/config/__pycache__/test_platform.cpython-39.pyc
Ðазад
a ]�h1! � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl mZ G dd� de�ZG d d � d e�Zd d � Zed kr�e� dS )z5 Platform tests to discover the system capabilities. � N)�config)�uifname)� RawIPRoute)� RTMGRP_LINKc @ s e Zd ZdS )�SkipTestN)�__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/config/test_platform.pyr s r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&S )'� TestCapsRtnla A minimal test set to collect the RTNL implementation capabilities. It uses raw RTNL sockets and doesn't run any proxy code, so no transparent helpers are executed -- e.g., it will not create bridge via `brctl`, if RTNL doesn't support it. A short developer's guide:: def test_whatever_else(self): code This test will create a capability record `whatever_else`. If the `code` fails, the `whatever_else` will be set to `False`. If it throws the `SkipTest` exception, the `whatever_else` will be set to `None`. Otherwise it will be set to whatever the test returns. To collect the capabilities:: tce = TestCapsExt() tce.collect() print(tce.capabilities) Collected capabilities are in the `TestCapsExt.capabilities` dictionary, you can use them directly or by setting the `config.capabilities` singletone:: from pyroute2 import config # ... tce.collect() config.capabilities = tce.capabilities c C sB i | _ g | _i | _i | _i | _t�� \| _| _d | _ t � � | _ d S �N) � capabilities�ifnames� rtm_newlink� rtm_dellink� rtm_events�os�pipe�cmd�cmdw�ip� threading�Event�event��selfr r r �__init__: s zTestCapsRtnl.__init__c C s | j | S r �r )r �keyr r r � __getitem__D s zTestCapsRtnl.__getitem__c C s || j |< dS )z# Set a capability. Nr )r r �valuer r r �set_capabilityG s zTestCapsRtnl.set_capabilityc C s8 t � }| j�|� t�� | j|< g | j|< g | j|< |S )z_ Register and return a new unique interface name to be used in a test. )r r �appendr r r r r �r �ifnamer r r r% M s zTestCapsRtnl.ifnamec C s� t � }|�t� t�� }|�|tjtjB � |�| jtjtjB � | j � � |�� }|D ]�\}}||� � kr�|� � }|D ]d}|� d�}|� d�} || jvr�qx| dkr�| j| � � | j| �|� qx| dkrx| j| �|� qxqX|�� d S qXqLd S )NZ IFLA_IFNAMEr Z RTM_NEWLINKZ RTM_DELLINK)r �bindr �select�poll�register�POLLIN�POLLPRIr r �set�fileno�getZget_attrr r r# r �close) r r r( �events�fdZevtZmsgs�msg�namer r r r �monitorY s, zTestCapsRtnl.monitorc C s t � | _d S r )r r r r r r �setupx s zTestCapsRtnl.setupc C sf | j D ]J}| j| �� | j| �� | j�|�r| jjd| j| d d d� qg | _ | j�� d S )N�delr �index)r7 ) r r �wait�clearr r. r �linkr/ r$ r r r �teardown s zTestCapsRtnl.teardownc C s t t| ��}tj| jd�}|�� | j�� |D ]�}|�d�r0| � � z0t | |�� }|du r`d}| � |dd� |� W nd t y� | � |dd� d� Y n@ t y� | jD ]}| j| �� q�| � |dd� d� Y n0 | �� q0t�| jd� |�� | jS )z� Run the tests and collect the capabilities. They will be saved in the `TestCapsRtnl.capabilities` attribute. )�targetZtest_NT� F� q)�sorted�dirr �Threadr4 �startr r8 � startswithr5 �getattrr" r � Exceptionr r r, r; r �writer �joinr )r �symbolsZmthreadr3 �retr% r r r �collect� s, zTestCapsRtnl.collectc C s t jS )z( Return collected uname )r �unamer r r r � test_uname� s zTestCapsRtnl.test_unamec C s t jt jtjfS )z5 Return machine, arch and byte order )r �machine�arch�sys� byteorderr r r r � test_machine� s zTestCapsRtnl.test_machinec C s t jS )z( Returned parsed kernel )r Zkernelr r r r �test_parsed_kernel_version� s z'TestCapsRtnl.test_parsed_kernel_versionc C s t �� t �� fS )z. Return current user/group id )r �getuid�getgidr r r r � test_uid_gid� s zTestCapsRtnl.test_uid_gidc C s t jS )z' Return Python version )rO �versionr r r r �test_python_version� s z TestCapsRtnl.test_python_versionc C s8 zt �dtd�d� W n Y dS 0 tt d�r4dS dS )zD Does unpack_from() support bytearray as the buffer �I)� r r r r FZ _u_f_origN)�struct� unpack_from� bytearray�hasattrr r r r �test_unpack_from� s z TestCapsRtnl.test_unpack_fromc C s" | � � | _| jjd| jdd� dS )zH An obvious test: an ability to create dummy interfaces �add�dummy�r% �kindN)r% �ghostr r: r r r r �test_create_dummy� s z TestCapsRtnl.test_create_dummyc C s | j jd| �� dd� dS )z< Can the kernel create bridges via netlink? r_ Zbridgera N�r r: r% r r r r �test_create_bridge� s z TestCapsRtnl.test_create_bridgec C s | j jd| �� dd� dS )z: Can the kernel create bonds via netlink? r_ Zbondra Nre r r r r �test_create_bond� s z TestCapsRtnl.test_create_bondc C s� t dd��<}t|�� �� d d �dkr8W d � dS W d � n1 sL0 Y | j| j �d� tt| j � | jg ��d d�S )av A normal flow (req == request, brd == broadcast message):: (req) -> RTM_NEWLINK (brd) <- RTM_NEWLINK (req) -> RTM_DELLINK (brd) <- RTM_DELLINK But on old kernels you can encounter the following:: (req) -> RTM_NEWLINK (brd) <- RTM_NEWLINK (req) -> RTM_DELLINK (brd) <- RTM_DELLINK (brd) <- RTM_NEWLINK (!) false positive And that obviously can break the code that relies on broadcast updates, since it will see as a new interface is created immediately after it was destroyed. One can ignore RTM_NEWLINK for the same name that follows a normal RTM_DELLINK. To do that, one should be sure the message will come. Another question is how many messages to ignore. This is not a test s.str., but it should follow after the `test_create_dummy`. It counts, how many RTM_NEWLINK messages arrived during the `test_create_dummy`. The ghost newlink messages count will be the same for other interface types as well. z /proc/version�r� r Ng �?rY ) �open�int�read�splitr rc r8 �max�lenr r. )r �fr r r �test_ghost_newlink_count� s " .z%TestCapsRtnl.test_ghost_newlink_countN)r r r �__doc__r r r" r% r4 r5 r; rJ rL rQ rR rU rW r^ rd rf rg rq r r r r r s& # r c C s t tjt� �� dd�� d S )N� )�indent)�print�json�dumpsr rJ r r r r �run s rx �__main__)rr rv r r' rZ rO r Zpyroute2r Zpyroute2.commonr Zpyroute2.iproute.linuxr Zpyroute2.netlink.rtnlr rE r �objectr rx r r r r r �<module> s"
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка