File: //usr/lib/python3/dist-packages/iotop/__pycache__/netlink.cpython-310.pyc
o
$�DYy � @ s� d Z ddlZddlZddlZz"e�ejejd�Ze�d� [dd� Zdd� Z dd � Z
d9d d �Z W nN ej y~ zddl
Z
d
d� Zdd� Z dd � Z
d9dd �Z W n, ey{ ddlZe�d�ZG dd� dej�Zdd� Zdd� Z dd � Z
d9dd �Z Y nw Y nw dZdZdZdZdZdZdZdZd Z G d d � d �Z G d d � d e �Z G d!d"� d"e �Z G d#d$� d$e �Z G d%d&� d&e �Z!G d'd(� d(e �Z"dZ#dZ$dZ%dZ&dZ'd)Z(d*Z)d+Z*dZ+d,Z,d-Z-d.Z.d/Z/d0Z0d1Z1d2Z2d Z3G d3d4� d4�Z4G d5d6� d6�Z5d7d8� Z6dS ):z�
Netlink message generation/parsing
Copyright 2007 Johannes Berg <johannes@sipsolutions.net>
GPLv2+; See copying for details.
� N)r r c C � | � |� d S �N)�bind��
descriptor�addr� r �//usr/lib/python3/dist-packages/iotop/netlink.py�_nl_bind � r
c C s | � � S r )� getsockname�r r r r �_nl_getsockname s r c C r r )�send�r �msgr r r �_nl_send r r � @ c C s
| � |�S r )�recvfrom�r �bufsr r r �_nl_recv �
r c C s t �| �� |d � d S �N� )�_netlinkr �filenor r r r r
# � c C s t �| �� �S r )r r r r
r r r r & r c C s t �| �� |� d S r )r r r r r r r r ) � c C s t �| �� |�S r )r r r r r r r r , � c @ s0 e Zd ZdejfdejfdejfdejfgZdS )� SOCKADDR_NL� nl_family�nl_pad�nl_pid� nl_groupsN)�__name__�
__module__� __qualname__�ctypes�c_ushort�c_int�_fields_r r r r r 4 s �r c C s2 t tjdt�� d�}t�| �� t� |�t�
|��S �Nr ) r �socket�
AF_NETLINK�os�getpid�libcr r r( �pointer�sizeofr r r r r
: s
�c C sH t dddd�}t�t�|��}t�| �� t�|�t�|�� |j|j fS r, )
r r( r* r3 r1 r r r2 r# r$ )r r �lenr r r r @ s
� c C s t �| �� |t|�d�S r, )r1 r r r4 r r r r r H r c
C sn t dddd�}t�t�|��}t�|�}t�| �� ||dt�|�t�|��}t� t�|�|�}||j
|j ffS r, ) r r( r* r3 �create_string_bufferr1 r r r2 � string_atr# r$ )r r r r4 �buf�r�retr r r r K s
�r � � � � � c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�Attrc G s0 || _ t|�rtj|g|�R � | _d S || _d S r )�typer4 �struct�pack�data)�self� attr_typerC �valuesr r r �__init__g s
z
Attr.__init__c C sJ t �dt| j�d | j�}t| j�}|d d d@ | }|| j d| S )N�HHr; r ���� )rA rB r4 rC r@ )rD �hdr�length�padr r r �_dumpn s
z
Attr._dumpc C s d| j t| j�f S )Nz<Attr type %d, data "%s">)r@ �reprrC �rD r r r �__repr__t r z
Attr.__repr__c C � t �d| j�d S )N�Hr �rA �unpackrC rP r r r �u16w � zAttr.u16c C rR )N�hr rT rP r r r �s16z rW zAttr.s16c C rR )N�Ir rT rP r r r �u32} rW zAttr.u32c C rR )N�ir rT rP r r r �s32� rW zAttr.s32c C s | j S r )rC rP r r r �str� s zAttr.strc C s | j �d�d S )N� r )rC �splitrP r r r �nulstr� r z Attr.nulstrc C s
t | j�S r )�parse_attributesrC rP r r r �nested� r z Attr.nestedN)
r% r& r' rG rN rQ rV rY r[ r] r^ ra rc r r r r r? f s r? c @ � e Zd Zdd� ZdS )�StrAttrc C s" t �| |dt|� |�d�� d S )Nz%ds�utf-8�r? rG r4 �encode�rD rE rC r r r rG � s "zStrAttr.__init__N�r% r& r' rG r r r r re � � re c @ rd )�
NulStrAttrc C s$ t �| |dt|� |�d�d� d S )Nz%dsBrf r rg ri r r r rG � s �zNulStrAttr.__init__Nrj r r r r rl � rk rl c @ rd )�U32Attrc C � t �| |d|� d S )NrZ �r? rG �rD rE �valr r r rG � r zU32Attr.__init__Nrj r r r r rm � rk rm c @ rd )�U8Attrc C rn )N�Bro rp r r r rG � r zU8Attr.__init__Nrj r r r r rr � rk rr c @ s e Zd Zdd� Zdd� ZdS )�Nestedc C s || _ || _d S r )�attrsr@ )rD rE ru r r r rG � s
zNested.__init__c C sL g }| j D ] }|�|�� � qd�|�}t|�}t�d|d | j�}|| S )N� rH r; )ru �appendrN �joinr4 rA rB r@ )rD �contents�attrrL rK r r r rN � s
z Nested._dumpN)r% r& r' rG rN r r r r rt � s rt � � � � �
� � �
� � c @ s& e Zd Zd
dd�Zdd� Zdd � ZdS ) �Messager ���Nc C s` || _ || _|| _d| _|pg }t|t�r+g }|D ] }|�|�� � qd�|�| _ d S || _ d S )Nr� � )
r@ �flags�seq�pid�
isinstance�listrw rN rx �payload)rD �msg_typer� r� r� ry rz r r r rG � s
zMessage.__init__c C sZ | j dkr
|� � | _ |j| _t| j�}t�d|d | j| j| j | j�}|�|| j � d S )Nr� �IHHIIr> ) r� r� r4 r� rA rB r@ r� r )rD �connrL rK r r r r � s
�z Message.sendc C s d| j | j| j| jt| j�f S )Nz:<netlink.Message type=%d, pid=%d, seq=%d, flags=0x%x "%s">)r@ r� r� r� rO r� rP r r r rQ � s �zMessage.__repr__)r r� N)r% r& r' rG r rQ r r r r r� � s
r� c @ s. e Zd Zd dd�Zdd� Zdd� Zd d
� ZdS ) �
Connectionr Nc C sn t � t jt j|�| _| j�t jt jd� | j�t jt jd� t| jd|f� t | j�\| _
| _ d| _ || _
d S )Ni r )r- r. �SOCK_RAWr �
setsockopt�
SOL_SOCKET� SO_SNDBUF� SO_RCVBUFr
r r� �groups�_seq�
unexpected)rD �nltyper� �unexpected_msg_handlerr r r rG � s �
zConnection.__init__c C s t | j|� d S r )r r )rD r r r r r � r zConnection.sendc C s� t | j�\}\}}t�d|d d� �\}}}}}t||||dd � �} || _| jtkrMt�d| jd d� �d }
|
dkrMt dt
� |
�|
f �} |
| _ | �| S )Nr� r> r\ r; r zNetlink error: %s (%d))
r r rA rU r� r� r@ � NLMSG_ERRORr� �OSErrorr/ �strerror�errno) rD ry �nlpid�nlgrps�msglenr� r� r� r� r r� �errr r r �recv� s
�
�zConnection.recvc C s | j d7 _ | j S r )r� rP r r r r� s zConnection.seq)r N)r% r& r' rG r r� r� r r r r r� � s
r� c C sb i }t | �r/t�d| d d� �\}}t|| d|� �||< |d d d@ }| |d � } t | �s|S )NrH r; r rI )r4 rA rU r? )rC ru �attr_lenrE r r r rb s �rb )r )7�__doc__r/ r- rA r. r� �
_dummysockr r
r r r �errorr � ImportErrorr( �CDLLr1 � Structurer �
NLM_F_REQUEST� NLM_F_MULTI� NLM_F_ACK�
NLM_F_ECHO�
NLMSG_NOOPr� �
NLMSG_DONE�
NLMSG_OVERRUN�NLMSG_MIN_TYPEr? re rl rm rr rt �
NETLINK_ROUTE�NETLINK_UNUSED�NETLINK_USERSOCK�NETLINK_FIREWALL�NETLINK_INET_DIAG�
NETLINK_NFLOG� NETLINK_XFRM�NETLINK_SELINUX�
NETLINK_ISCSI�
NETLINK_AUDIT�NETLINK_FIB_LOOKUP�NETLINK_CONNECTOR�NETLINK_NETFILTER�NETLINK_IP6_FW�NETLINK_DNRTMSG�NETLINK_KOBJECT_UEVENT�NETLINK_GENERICr� r� rb r r r r �<module> s�
���;' %