File: //usr/share/netplan/netplan_cli/cli/commands/__pycache__/apply.cpython-310.pyc
o
t��foT � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z m
Z
ddlmZ ddlmZmZmZ d Zd
ZG d d � d e
j�ZdS )
znetplan apply command line� N� )�utils� )�
ConfigManager�ConfigurationError)�apply_sriov_config)�OvsDbServerNotRunning�OvsDbServerNotInstalled�apply_ovs_cleanupznetplan-ovs-cleanup.service� c sx e Zd Z� fdd�Zdd� Zddd �Zed
d � �Zeg fd d
��Zede fdd��Z
eddd��Z eddd��Z � Z
S )� NetplanApplyc s( t � jdddd� d| _d| _d | _d S )N�applyz.Apply current netplan config to running systemT)�
command_id� description�leafF)�super�__init__�
sriov_only�only_ovs_cleanup�state��self�� __class__� �4/usr/share/netplan/netplan_cli/cli/commands/apply.pyr , s �
zNetplanApply.__init__c C sP | j jdddd� | j jdddd� | j jddd � | j| _| �� | �� d S )
Nz --sriov-only�
store_truez0Only apply SR-IOV related configuration and exit)�action�helpz--only-ovs-cleanupz1Only clean up old OpenVSwitch interfaces and exitz--statez0Directory containing previous YAML configuration)r )�parser� add_argument�
command_apply�func�
parse_args� run_commandr r r r �run4 s
�
�� zNetplanApply.runTFNc ( C sV t � }|r|| _| jrt�||� d S | jr t�|dd|� d S dtjv r[t �
d�}|d u r2t d��t �
|ddddd dd
g�}|d krY|rKt�|� n|d krStd
��t d| ��d S d}tt�d��} t�d�}
||
v rr|
�|� t|
�} t�d�} t�| t�� �}
t| �}g }d }dtjv r�|�ddg� t j}|�t�� � |r�t j
||d�d kr�|r�t�tj � nt d��t�� }tt�d��}|s�| r�d}t�d�}||v r�|�|� t|�}|s�| r�d}t�d�}|
� t�||�� t|�}|s�|r�d}|�rt� � |�r)t �!d� t�|| ||� dg}t�"d��r |�#d d� tj$d ||d � nt �!d � d }|�rrt �!d � t�%� �rqd!|
v �rGt�&d!�}|D ] }||
v�rR�qIz t�'d"d#|g� W �qI t j(�yi Y �qIw tj)d |d � nt �!d$� t�� }|�*� t�+||�}| j�r�t | j�}|�*� |j,�-� } |j,�-� } t�.| | |� t�� }|D ]<}t �!d%|� z"t j/d&d'd(d)| gt j0t j0d*� t j/d&d+d)| gt j0t j0d*� W �q� t j(�y� t �!d,|� Y �q�w t�� } |�1� D ]X\} } | �2d-�}!|!�rEt3|!�t4k�r t �5d.�6|!| �� �q�| |v �r!|!| v �r!t �!d/�6| |!�� �q�t j/d0d1d2d3| d4gt j0t j0d*� t j/d0d1d2d3| d-| �2d-�gt j0t j0d*� �q�t �/g d5�� t �/d&d6g� t�||� tj7�8d7��rit�$d8d9g� |�r�d:d;� t�d<�D �}"d=d;� t�d>�D �}#z
t�9� t�:t�;� � W n t j(�y� t �5d?� tj$d@dAgdd � Y nw tj$d8t<gdd � tj$d8|"|# dd � |�r%t�||�}$|$D ]} t�=| � �q�t j>dBddC� tj)d8|d � d!|$v �r�d}|�rg dD�}%t?dE�D ]'}&t j@|%dddF�}'|'jAdGk�rtB�CdH� �q�dItD|'jE�v �r ntB�CdJ� �q�d!|$v �r'|�r)t�F|� d S d S d S d S )KNF�SNAP�busctlzmissing busctl utility�callz--quietz--systemzio.netplan.Netplanz/io/netplan/Netplan�Applyr � z'failed to communicate with dbus servicez1failed to communicate with dbus service: error %sz//run/systemd/system/netplan-ovs-cleanup.servicez /run/systemd/network/*netplan-*z!/run/systemd/system/netplan-ovs-*z0/run/NetworkManager/system-connections/netplan-*�NETPLAN_PROFILE�valgrindz--leak-check=full)�stderrz(the configuration could not be generatedTzDnetplan generated networkd configuration changed, reloading networkdznetplan-wpa-*.serviceznetplan-wpa@*.service�stop)�syncz2no netplan generated networkd configuration exists� z9netplan generated NM configuration changed, restarting NM�lo�device�
disconnectz,no netplan generated NM configuration existsz%netplan triggering .link rules for %s�udevadmz test-builtin�net_setup_linkz/sys/class/net/)�stdoutr- �testz#Ignoring device without syspath: %s�namez5Interface name {} is too long. {} will not be renamedz+Interface rename {} -> {} already happened.�ip�link�set�dev�down)r4 �triggerz--attr-match=subsystem=net�settlez*/run/systemd/system/netplan-regdom.service�startznetplan-regdom.servicec S s g | ]}t j�|��qS r )�os�path�basename��.0�fr r r �
<listcomp> s z.NetplanApply.command_apply.<locals>.<listcomp>z1/run/systemd/system/*.wants/netplan-wpa-*.servicec S s& g | ]}|� d t �stj�|��qS )�/)�endswith�OVS_CLEANUP_SERVICErA rB rC rD r r r rG s �z1/run/systemd/system/*.wants/netplan-ovs-*.servicez:Falling back to a hard restart of systemd-networkd.service�restartzsystemd-networkd.servicez/run/NetworkManager/devices)�
ignore_errors)�nmcli�general�status�
)�capture_output�text� � z
connectedg �?)Gr r r r �process_sriov_configr �process_ovs_cleanuprA �environ�shutil�which� RuntimeError�
subprocessr( �sys�exit�PermissionError�bool�glob�remover �
nm_interfaces� netifaces�
interfaces�extend�STDOUT�append�get_generator_path� EX_CONFIGr �update�systemctl_daemon_reload�logging�debug�systemctl_is_active�insert� systemctl�
nm_running� nm_get_connection_for_interfacerM �CalledProcessError�systemctl_network_manager�parse�process_link_changes�virtual_interfaces�keys�clear_virtual_links�
check_call�DEVNULL�items�get�len� IF_NAMESIZE�warning�formatrB �exists�networkctl_reload�networkctl_reconfigure�networkd_interfacesrJ �
ip_addr_flush�rmtree�ranger% �
returncode�time�sleep�strr6 �nm_bring_interface_up)(r � run_generater/ �
exit_on_error� state_dir�config_managerr' �res�ovs_cleanup_service�old_files_networkd� old_ovs_glob�
old_files_ovs� old_nm_glob� nm_ifaces� old_files_nm�generator_call� generate_out�devices�restart_networkd�restart_ovs_glob� restart_ovs�restart_nm_glob�
restart_nm� wpa_services�loopback_connectionr2 �changes�cm�
prev_links�
curr_links�devices_after_udev�iface�settings�new_name� netplan_wpa� netplan_ovsrb �cmd�_�outr r r r! A sj
� ��
��
��� ��
�
���
�
�&zNetplanApply.command_applyc C sV | D ]&}|� � D ] \}}t|�turq|�dg �}|D ] }||kr& dS qqqdS )zp
Is this physical interface a member of a 'composite' virtual
interface? (bond, bridge)
rd TF)r| �type�dictr} )�
composites�phy� compositer� r� �membersr� r r r �is_composite_memberJ s
���z NetplanApply.is_composite_memberc C s� |s t �d� g S tt| �t|� �}tt|��|��}|D ]"}zdddd|g}t�|� W q tjy@ t �d�|�� Y q w |S )a%
Calculate the delta of virtual links. And remove the links that were
dropped from the YAML config, if they were not dropped by the backend
already.
We can make use of the netplan netdef ids, as those equal the interface
name for virtual links.
z;Cannot clear virtual links: no network interfaces provided.r9 r: �deleter< z Could not delete interface {}) rl r� �listr; � intersectionr[ rz rs r� )r� r� r� �dropped_interfaces�interfaces_to_clearr: r� r r r ry [ s
�z NetplanApply.clear_virtual_linksr� c C s� i }|j |jg}|j�� D ]Q}|j}|sq
|jsq
t�||j�r*t �
d� |j�� q
t �
| |�}|s<t �d� |j�� q
||krIt �
d� |�� q
|jrXt �d� |j||�� q
d|i||< q
t �
d� |�� |S )z�
Go through the pending changes and pick what needs special handling.
Only applies to non-critical interfaces which can be safely updated.
z Skipping composite member {}z,Cannot find unique matching interface for {}z&Skipping correctly named interface: {}zLCannot rename {} ({} -> {}) at runtime (needs reboot), due to being criticalr8 zLink changes: {})�bridges�bonds�physical_interfaces�values�set_name�
_has_matchr r� �idrl rm r� r �find_matching_ifacer� �critical)rd r� r� �composite_interfaces�netdef�newname�current_iface_namer r r rv u s4 �z!NetplanApply.process_link_changesc
C sb zt | � W d S tjy0 } z t�t|�� |r%t�d� W Y d }~d S W Y d }~d S d }~ww )NrT )r r �
config_errorsrl �errorr� r\ r] )r� r� �er r r rU � s ���z!NetplanApply.process_sriov_configc
C s� z t | ||� W d S ttfy3 } z t�t|�� |r(t�d� W Y d }~d S W Y d }~d S d }~w tyM } zt� d�
|�� W Y d }~d S d }~w t ye } z
t� d|� W Y d }~d S d }~ww )NrT z Cannot call Open vSwitch: {}.z Cannot call Open vSwitch: %s.)
r
�OSErrorrZ rl r� r� r\ r] r r� r� r rm )r� �ovs_old� ovs_currentr� r� r r r rV � s �� ���z NetplanApply.process_ovs_cleanup)TFTN)T)�__name__�
__module__� __qualname__r r% r! � staticmethodr� ry r rv rU rV �
__classcell__r r r r r * s
+ r )�__doc__rl rA r\ r` r[ rX rc r� r0 r �
configmanagerr r �sriovr �ovsr r r
rJ r �NetplanCommandr r r r r �<module> s