File manager - Edit - /usr/lib/python3/dist-packages/cloudinit/sources/helpers/__pycache__/netlink.cpython-310.pyc
Back
o �Ad/ � @ sV d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z e� e �Z dZ dZdZdZdZd Zd Zd Zd Zd ZdZdZdZdZe�e�Z e�e�Z e e Z dZ dZ dZ!dZ"d Z#dZ$dZ%dZ&dZ'dZ(dZ)edg d��Z*edddg�Z+edg d��Z,G dd � d e-�Z.d d � Z/d d � Z0d/d!d"�Z1d#d$� Z2d%d&� Z3d'd(� Z4d)d*� Z5d+d,� Z6d-d.� Z7dS )0� N)� namedtuple)�log)�util� � � � � � � i�� � �< �IHHII�BHiII� � � �RTAAttr)�length�rta_type�data�InterfaceOperstate�ifname� operstate� NetlinkHeader)r �type�flags�seq�pidc @ s e Zd ZdZdS )�NetlinkCreateSocketErrorz5Raised if netlink socket fails during create or bind.N)�__name__� __module__� __qualname__�__doc__� r$ r$ �C/usr/lib/python3/dist-packages/cloudinit/sources/helpers/netlink.pyr 9 s r c C sp zt � t jt jt j�} | �t�� tf� | �d� W n t j y0 } z d| }t |�|�d}~ww t � d� | S )au Creates netlink socket and bind on netlink group to catch interface down/up events. The socket will bound only on RTMGRP_LINK (which only includes RTM_NEWLINK/RTM_DELLINK/RTM_GETLINK events). The socket is set to non-blocking mode since we're only receiving messages. :returns: netlink socket in non-blocking mode :raises: NetlinkCreateSocketError r z*Exception during netlink socket create: %sNzCreated netlink socket) �socket� AF_NETLINK�SOCK_RAW� NETLINK_ROUTE�bind�os�getpid� RTMGRP_LINK� setblocking�errorr �LOG�debug)�netlink_socket�e�msgr$ r$ r% �create_bound_netlink_socket= s � �� r5 c C s^ | dusJ d��t | �tksJ d��t�t| dt� �\}}}}}t�d|� t|||||�S )a Gets netlink message type and length :param: data read from netlink socket :returns: netlink message type :raises: AssertionError if data is None or data is not >= NLMSGHDR_SIZE struct nlmsghdr { __u32 nlmsg_len; /* Length of message including header */ __u16 nlmsg_type; /* Type of message content */ __u16 nlmsg_flags; /* Additional flags */ __u32 nlmsg_seq; /* Sequence number */ __u32 nlmsg_pid; /* Sender port ID */ }; N� data is nonez+data is smaller than netlink message headerzGot netlink msg of type %d) �len� NLMSGHDR_SIZE�struct�unpack� NLMSGHDR_FMT�MSG_TYPE_OFFSETr0 r1 r )r �msg_len�msg_typer r r r$ r$ r% �get_netlink_msg_headerS s � � r? c C s^ | dusJ d��t � | gg g |�\}}}| |vrdS t�d� | �t�}|du r-t�d� |S )a� Select and read from the netlink socket if ready. :param: netlink_socket: specify which socket object to read from :param: timeout: specify a timeout value (integer) to wait while reading, if none, it will block indefinitely until socket ready for read :returns: string of data read (max length = <MAX_SIZE>) from socket, if no data read, returns None :raises: AssertionError if netlink_socket is None N�netlink socket is nonez netlink socket ready for readz,Reading from Netlink socket returned no data)�selectr0 r1 �recv�MAX_SIZEr/ )r2 �timeout�read_set�_r r$ r$ r% �read_netlink_socketl s rG c C s� | dusJ d��t |�tksJ d��|tksJ d��d }}d}ztjd| |d�d }tjd| |d d�d }W n tjyC Y dS w | |t || � }t|||�S ) a( Unpack a single rta attribute. :param: data: string of data read from netlink socket :param: offset: starting offset of RTA Attribute :return: RTAAttr object with length, type and data. On error, return None. :raises: AssertionError if data is None or offset is not integer. Nr6 zoffset is not integerz'rta offset is less than expected lengthr �H)�offsetr )r �int�RTATTR_START_OFFSETr9 � unpack_fromr/ �RTA_DATA_START_OFFSETr )r rI r r � attr_datar$ r$ r% �unpack_rta_attr� s � � rO c C s� | dusJ d��t | �tksJ d��d }}t}|t | �kr]t| |�}|r*|jdkr+n2t|jt t }||j| 7 }|jtkrFt|j�}n|jt krWt � |jd�}|� d�}|t | �ks |rc|du redS t �d||� t||�S )a� Reads Interface name and operational state from RTA Data. :param: data: string of data read from netlink socket :returns: InterfaceOperstate object containing if_name and oper_state. None if data does not contain valid IFLA_OPERSTATE and IFLA_IFNAME messages. :raises: AssertionError if data is None or length of data is smaller than RTATTR_START_OFFSET. Nr6 z2length of data is smaller than RTATTR_START_OFFSETr zutf-8� z!rta attrs: ifname %s operstate %d)r7 rK rO r � PAD_ALIGNMENTr �IFLA_OPERSTATE�ordr � IFLA_IFNAMEr � decode_binary�stripr0 r1 r )r r r rI �attr�padlen�interface_namer$ r$ r% �read_rta_oper_state� s0 � � � rZ c s6 t �d� d�� �fdd�}t| dtgttg|� �S )z�Block until a single nic is attached. :param: netlink_socket: netlink_socket to receive events :param: existing_nics: List of existing nics so that we can skip them. :raises: AssertionError if netlink_socket is none. z!Preparing to wait for nic attach.Nc s | � v rdS | �dS )NTFr$ ��iname�carrier� prevCarrier�� existing_nicsr r$ r% �should_continue_cb� s z5wait_for_nic_attach_event.<locals>.should_continue_cb)r0 r1 �read_netlink_messages� RTM_NEWLINK�OPER_UP� OPER_DOWN)r2 r` ra r$ r_ r% �wait_for_nic_attach_event� s �rf c s2 t �d� d� � fdd�}t| dtgtg|� � S )z�Block until a single nic is detached and its operational state is down. :param: netlink_socket: netlink_socket to receive events. z!Preparing to wait for nic detach.Nc s | � dS )NFr$ r[ �r r$ r% ra � s z5wait_for_nic_detach_event.<locals>.should_continue_cb)r0 r1 rb � RTM_DELLINKre )r2 ra r$ rg r% �wait_for_nic_detach_event� s �ri c sf | dusJ d��� dusJ d��t � �dksJ d��� fdd�}t�d� t| � ttgttg|� dS ) a� Block until media disconnect and connect has happened on an interface. Listens on netlink socket to receive netlink events and when the carrier changes from 0 to 1, it considers event has happened and return from this function :param: netlink_socket: netlink_socket to receive events :param: ifname: Interface name to lookout for netlink events :raises: AssertionError if netlink_socket is None or ifname is None. Nr@ zinterface name is noner z interface name cannot be emptyc s( |t ko|tk}|rt�d� � dS dS )Nz Media switch happened on %s.FT)re rd r0 r1 )r\ r] r^ � isVnetSwitchrg r$ r% ra s z=wait_for_media_disconnect_connect.<locals>.should_continue_cbz1Wait for media disconnect and reconnect to happen)r7 r0 r1 rb rc rh rd re )r2 r ra r$ rg r% �!wait_for_media_disconnect_connect� s �rk c C sn | du rt d��t� }t}t} t| t�}|du rqt�dt|�� ||7 }t�dt|�� d} t|�} | | k r�|| d� } t| �tk rJt�d� nft | �} t| �| j k r[t�d� nU| j t d t d @ } | | } t�d | � | j |vrwq4t | �}|du r�t�d |� q4|dur�|j|kr�t�d |j|� q4|j|vr�q4|}|j}||j||�s�dS | | k s8|| d� }q) a� Reads from the netlink socket until the condition specified by the continuation callback is met. :param: netlink_socket: netlink_socket to receive events. :param: ifname_filter: if not None, will only listen for this interface. :param: rtm_types: Type of netlink events to listen for. :param: operstates: Operational states to listen. :param: should_continue_callback: Specifies when to stop listening. NzNetlink socket is noneTzread %d bytes from socketz Length of data after concat %dr z#Data is smaller than netlink headerz*Partial data. Smaller than netlink messager z"offset to next netlink message: %dz!Failed to read rta attributes: %sz6Ignored netlink event on interface %s. Waiting for %s.)� RuntimeError�bytesrd rG �SELECT_TIMEOUTr0 r1 r7 r8 r? r rQ r rZ r r )r2 � ifname_filter� rtm_types� operstates�should_continue_callbackr r] r^ � recv_datarI �datalen�nl_msg�nlheaderrX �interface_stater$ r$ r% rb sj � � �� '�rb )N)8r+ rA r& r9 � collectionsr � cloudinitr �loggingr � getLoggerr r0 r- � NLMSG_NOOP� NLMSG_ERROR� NLMSG_DONErc rh � RTM_GETLINK� RTM_SETLINKrC �RTA_DATA_OFFSETr< rn r; � IFINFOMSG_FMT�calcsizer8 �IFINFOMSG_SIZErK rM rQ rT rR � OPER_UNKNOWN�OPER_NOTPRESENTre �OPER_LOWERLAYERDOWN� OPER_TESTING� OPER_DORMANTrd r r r rl r r5 r? rG rO rZ rf ri rk rb r$ r$ r$ r% �<module> sf � %
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings