OwlCyberSecurity - MANAGER
Edit File: netlink.cpython-38.pyc
U $�DYy � @ s� d Z ddlZddlZddlZzDe�ejejd�Ze�d� [dd� Zdd� Z dd � Z d9d d �Z W n� ej k �r z.ddl Z d d� Zdd� Z dd � Z d:dd �Z W n\ ek � r� ddlZe�d�ZG dd� dej�Zdd� Zdd� Z dd � Z d;dd �Z Y nX Y nX 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 �//usr/lib/python3/dist-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 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! r) r' r r r( r r )r r �lenr r r r @ s �c C s t �| �� |t|�d�S r" )r' r r r* r r r r r H 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* Zbuf�rZretr 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 s, || _ t|�r"tj|f|�� | _n|| _d S r )�typer* �struct�pack�data)�self� attr_typer5 �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 ���� )r3 r4 r* r5 r2 )r6 �hdr�lengthZpadr r r �_dumpn s z Attr._dumpc C s d| j t| j�f S )Nz<Attr type %d, data "%s">)r2 �reprr5 �r6 r r r �__repr__t s z Attr.__repr__c C s t �d| j�d S )N�Hr �r3 �unpackr5 rA r r r �u16w s zAttr.u16c C s t �d| j�d S )N�hr rD rA r r r �s16z s zAttr.s16c C s t �d| j�d S )N�Ir rD rA r r r �u32} s zAttr.u32c C s t �d| j�d S )N�ir rD rA r r r �s32� s zAttr.s32c C s | j S r )r5 rA r r r �str� s zAttr.strc C s | j �d�d S )N� r )r5 �splitrA r r r �nulstr� s z Attr.nulstrc C s t | j�S r )�parse_attributesr5 rA r r r �nested� s z Attr.nestedN) r r r r9 r? rB rF rH rJ rL rM rP rR r r r r r1 f s r1 c @ s e Zd Zdd� ZdS )�StrAttrc C s" t �| |dt|� |�d�� d S )Nz%ds�utf-8�r1 r9 r* �encode�r6 r7 r5 r r r r9 � s zStrAttr.__init__N�r r r r9 r r r r rS � s rS c @ s e Zd Zdd� ZdS )� NulStrAttrc C s$ t �| |dt|� |�d�d� d S )Nz%dsBrT r rU rW r r r r9 � s �zNulStrAttr.__init__NrX r r r r rY � s rY c @ s e Zd Zdd� ZdS )�U32Attrc C s t �| |d|� d S )NrI �r1 r9 �r6 r7 �valr r r r9 � s zU32Attr.__init__NrX r r r r rZ � s rZ c @ s e Zd Zdd� ZdS )�U8Attrc C s t �| |d|� d S )N�Br[ r\ r r r r9 � s zU8Attr.__init__NrX r r r r r^ � s r^ c @ s e Zd Zdd� Zdd� ZdS )�Nestedc C s || _ || _d S r )�attrsr2 )r6 r7 ra r r r r9 � s zNested.__init__c C sL g }| j D ]}|�|�� � q d�|�}t|�}t�d|d | j�}|| S )N� r: r- )ra �appendr? �joinr* r3 r4 r2 )r6 �contents�attrr> r= r r r r? � s z Nested._dumpN)r r r r9 r? r r r r r` � s r` � � � � � � � � � � c @ s& e Zd Zd dd�Zdd� Zdd � ZdS ) �Messager ���Nc C s^ || _ || _|| _d| _|p g }t|t�rTg }|D ]}|�|�� � q2d�|�| _ n|| _ d S )Nrr � ) r2 �flags�seq�pid� isinstance�listrc r? rd �payload)r6 �msg_typert ru ry re rf r r r r9 � s zMessage.__init__c C sZ | j dkr|� � | _ |j| _t| j�}t�d|d | j| j| j | j�}|�|| j � d S )Nrr �IHHIIr0 ) ru rv r* ry r3 r4 r2 rt r )r6 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">)r2 rv ru rt r@ ry rA r r r rB � s �zMessage.__repr__)r rr N)r r r r9 r rB r r r r rq � s rq 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 rv �groups�_seqZ unexpected)r6 Znltyper~ Zunexpected_msg_handlerr r r r9 � s �zConnection.__init__c C s t | j|� d S r )r r )r6 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{ r0 rK r- r zNetlink error: %s (%d)) r r r3 rE rq rv r2 � NLMSG_ERRORry �OSErrorr% �strerror�errno) r6 re ZnlpidZnlgrpsZmsglenrz rt ru rv r r� �errr r r �recv� s � �zConnection.recvc C s | j d7 _ | j S r )r rA r r r ru s zConnection.seq)r N)r r r r9 r r� ru 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* r3 rE r1 )r5 ra Zattr_lenr7 r r r rQ s rQ )r )r )r )7�__doc__r% r# r3 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_TYPEr1 rS rY rZ r^ r` 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_GENERICrq r| rQ r r r r �<module> sz ' %