File: //lib/python3.9/site-packages/iotop/__pycache__/netlink.cpython-39.opt-1.pyc
a
B��Q� � @ s� d Z ddlZddlZddlZzDe�ejejd�Ze�d� [dd� Zdd� Z dd � Z
d9d d �Z W n� ej � y� z.ddl
Z
d
d� Zdd� Z dd � Z
d:dd �Z W nX ey� ddlZe�d�ZG dd� dej�Zdd� Zdd� Z dd � Z
d;dd �Z Y n0 Y n0 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 s | � |� d S �N)�bind��
descriptor�addr� r �1/usr/lib/python3.9/site-packages/iotop/netlink.py�_nl_bind s r c C s | � � S r )� getsockname�r r r r �_nl_getsockname s r c C s | � |� d S r )�send�r �msgr r r �_nl_send s r � @ c C s
| � |�S r )�recvfrom�r �bufsr r r �_nl_recv s r c C s t �| �� |d � d S �N� )�_netlinkr �filenor r r r r s c C s t �| �� �S r )r r
r r r r r r s c C s t �| �� |� d S r )r r
r r r r r r " s c C s t �| �� |�S r )r r r r r r r r $ s c @ s0 e Zd ZdejfdejfdejfdejfgZdS )� SOCKADDR_NLZ nl_familyZnl_pad�nl_pid� nl_groupsN)�__name__�
__module__� __qualname__�ctypesZc_ushort�c_intZ_fields_r r r r r , 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 2 s
�c C sH t dddd�}t�t�|��}t�| �� t�|�t�|�� |j|j fS r" )
r r r! r) r' r
r r( r r )r r �lenr r r r 8 s
�c C s t �| �� |t|�d�S r" )r' r
r r* r r r r r @ s c
C sn t dddd�}t�t�|��}t�|�}t�| �� ||dt�|�t�|��}t� t�|�|�}||j
|j ffS r" ) r r r! r) Zcreate_string_bufferr' r r r( Z string_atr r )r r r r* �buf�r�retr r r r C 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 s. || _ t|�r$tj|g|�R � | _n|| _d S r )�typer* �struct�pack�data)�self� attr_typer7 �valuesr r r �__init__^ s z
Attr.__init__c C sJ t �dt| j�d | j�}t| j�}|d d d@ | }|| j d| S )N�HHr/ r ���� )r5 r6 r* r7 r4 )r8 �hdr�lengthZpadr r r �_dumpe s
z
Attr._dumpc C s d| j t| j�f S )Nz<Attr type %d, data "%s">)r4 �reprr7 �r8 r r r �__repr__k s z
Attr.__repr__c C s t �d| j�d S )N�Hr �r5 �unpackr7 rC r r r �u16n s zAttr.u16c C s t �d| j�d S )N�hr rF rC r r r �s16p s zAttr.s16c C s t �d| j�d S )N�Ir rF rC r r r �u32r s zAttr.u32c C s t �d| j�d S )N�ir rF rC r r r �s32t s zAttr.s32c C s | j S r )r7 rC r r r �strv s zAttr.strc C s | j �d�d S )N� r )r7 �splitrC r r r �nulstrx s z Attr.nulstrc C s
t | j�S r )�parse_attributesr7 rC r r r �nestedz s z Attr.nestedN)
r r r r; rA rD rH rJ rL rN rO rR rT r r r r r3 ] s r3 c @ s e Zd Zdd� ZdS )�StrAttrc C s" t �| |dt|� |�d�� d S )Nz%ds�utf-8�r3 r; r* �encode�r8 r9 r7 r r r r; ~ s zStrAttr.__init__N�r r r r; r r r r rU } s rU c @ s e Zd Zdd� ZdS )�
NulStrAttrc C s$ t �| |dt|� |�d�d� d S )Nz%dsBrV r rW rY r r r r; � s zNulStrAttr.__init__NrZ r r r r r[ � s r[ c @ s e Zd Zdd� ZdS )�U32Attrc C s t �| |d|� d S )NrK �r3 r; �r8 r9 �valr r r r; � s zU32Attr.__init__NrZ r r r r r\ � s r\ c @ s e Zd Zdd� ZdS )�U8Attrc C s t �| |d|� d S )N�Br] r^ r r r r; � s zU8Attr.__init__NrZ r r r r r` � s r` c @ s e Zd Zdd� Zdd� ZdS )�Nestedc C s || _ || _d S r )�attrsr4 )r8 r9 rc r r r r; � s zNested.__init__c C sL g }| j D ]}|�|�� � q
d�|�}t|�}t�d|d | j�}|| S )N� r< r/ )rc �appendrA �joinr* r5 r6 r4 )r8 �contents�attrr@ r? r r r rA � s
z Nested._dumpN)r r r r; rA r r r r rb � s rb � � � � �
� � �
� � c @ s& e Zd Zd
dd�Zdd� Zdd � ZdS ) �Messager ���Nc C s^ || _ || _|| _d| _|p g }t|t�rTg }|D ]}|�|�� � q2d�|�| _ n|| _ d S )Nrt � )
r4 �flags�seq�pid�
isinstance�listre rA rf �payload)r8 �msg_typerv rw r{ rg rh r r r r; � s
zMessage.__init__c C sZ | j dkr|� � | _ |j| _t| j�}t�d|d | j| j| j | j�}|�|| j � d S )Nrt �IHHIIr2 ) rw rx r* r{ r5 r6 r4 rv r
)r8 Zconnr@ r? 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">)r4 rx rw rv rB r{ rC r r r rD � s �zMessage.__repr__)r rt N)r r r r; r
rD r r r r rs � s
rs 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 Z
setsockoptZ
SOL_SOCKETZ SO_SNDBUFZ SO_RCVBUFr r rx �groups�_seqZ
unexpected)r8 Znltyper� Zunexpected_msg_handlerr r r r; � s �zConnection.__init__c C s t | j|� d S r )r r )r8 r r r r r
� s zConnection.sendc C s� t | j�\}\}}t�d|d d� �\}}}}}t||||dd � �} || _| jtkr�t�d| jd d� �d }
|
dkr�t dt
� |
�|
f �} |
| _ | �| S )Nr} r2 rM r/ r zNetlink error: %s (%d))
r r r5 rG rs rx r4 � NLMSG_ERRORr{ �OSErrorr% �strerror�errno) r8 rg ZnlpidZnlgrpsZmsglenr| rv rw rx r r� �errr r r �recv� s
�
�zConnection.recvc C s | j d7 _ | j S r )r� rC r r r rw � s zConnection.seq)r N)r r r r; r
r� rw r r r r r~ � s
r~ c C s\ i }t | �rXt�d| d d� �\}}t|| d|� �||< |d d d@ }| |d � } q|S )Nr< r/ r r= )r* r5 rG r3 )r7 rc Zattr_lenr9 r r r rS � s rS )r )r )r )7�__doc__r% r# r5 r$ r Z
_dummysockr r r r r �errorr � ImportErrorr ZCDLLr' Z Structurer Z
NLM_F_REQUESTZ NLM_F_MULTIZ NLM_F_ACKZ
NLM_F_ECHOZ
NLMSG_NOOPr� Z
NLMSG_DONEZ
NLMSG_OVERRUNZNLMSG_MIN_TYPEr3 rU r[ r\ r` rb Z
NETLINK_ROUTEZNETLINK_UNUSEDZNETLINK_USERSOCKZNETLINK_FIREWALLZNETLINK_INET_DIAGZ
NETLINK_NFLOGZ NETLINK_XFRMZNETLINK_SELINUXZ
NETLINK_ISCSIZ
NETLINK_AUDITZNETLINK_FIB_LOOKUPZNETLINK_CONNECTORZNETLINK_NETFILTERZNETLINK_IP6_FWZNETLINK_DNRTMSGZNETLINK_KOBJECT_UEVENTZNETLINK_GENERICrs r~ rS r r r r �<module> sz