File: //opt/alt/python37/lib/python3.7/site-packages/exabgp/netlink/__pycache__/netlink.cpython-37.pyc
B
RP�em � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z dd l
mZ yeed
� W n ek
r� ed ��Y nX G d d
� d
e�ZdS )z�
netlink.py
Created by Thomas Mangin on 2015-03-31.
Copyright (c) 2009-2017 Exa Networks. All rights reserved.
License: 3-clause BSD. (See the COPYRIGHT file)
� N)�pack)�unpack)�calcsize)�
namedtuple)� NetLinkError)�Sequence)�
Attributes�
AF_NETLINKz;This module only works on unix version with netlink supportc @ s� e Zd ZdZdZedd�Ze�ejej e�Z
G dd� de �Z G dd� de �Z
G d d
� d
e �Ze
jd e
jd iZed
d� �Zedd� �Zeejdfdd��ZdS )�NetLinkTr �Messagez+format_type control_flags sequence pid datac @ s e Zd ZdZee�ZdS )zNetLink.HeaderZIHHIIN)�__name__�
__module__� __qualname__�PACKr �LEN� r r �G/opt/alt/python37/lib/python3.7/site-packages/exabgp/netlink/netlink.py�HeaderC s r c @ s e Zd ZdZdZdZdZdS )zNetLink.Command� � � � N)r r
r Z
NLMSG_NOOP� NLMSG_ERROR�
NLMSG_DONE�
NLMSG_OVERRUNr r r r �CommandH s r c @ s@ e Zd ZdZdZdZdZdZdZeeB Z dZ
dZ dZ dZ
dZd S )
z
NetLink.Flagsr r r � � i i i N)r r
r Z
NLM_F_REQUESTZ NLM_F_MULTIZ NLM_F_ACKZ
NLM_F_ECHOZ
NLM_F_ROOTZ NLM_F_MATCHZ
NLM_F_DUMPZ NLM_F_ATOMICZ
NLM_F_REPLACEZ
NLM_F_EXCLZ NLM_F_CREATEZ NLM_F_APPENDr r r r �FlagsN s r z
netlink errorznetlink overrunc C s@ t �|�}| jjt|� t|� }t| jj|||||�| | S )N)r �encoder r �lenr r ) �cls� format_type�sequence�
control_flags�pid�body�
attributes�attrs�lengthr r r r e s
zNetLink.encodec c sr xl|rlt | jj|d | jj� �\}}}}}t|�|k r>td��| �|||||| jj|� �V ||d � }qW d S )NzBuffer underrun)r r r r r r �format)r! �datar) r" r$ r# r% r r r �decodek s $ zNetLink.decodeNc c s� t � }t�� }|d kri }| �||||td|�|�}| j�|� x�| j�d�}x|| �|�D ]n\} }
} } }
| |kr�| j rxqZt
d��n.| |kr�t
d��n | | j kr�t
| j | ||��| t j
jkr�t� �|
V qZW qBW d S )NZBxxxi � znetlink sequence mismatchznetlink pid mismatch)r �os�getpidr r �netlink�send�recvr, �_IGNORE_SEQ_FAULTSr �errorsr
r r �
StopIteration)r! r" r$ �familyr' r# r% �message�responseZ
response_typeZresponse_flagsZresponse_sequenceZ response_pidZ
response_datar r r r0 w s(
z NetLink.send)r r
r r2 �
NETLINK_ROUTEr r* �socketr �SOCK_RAWr/ �objectr r r r r r3 � classmethodr r, � AF_UNSPECr0 r r r r r
; s
r
)�__doc__r- r9 �structr r r � collectionsr Zexabgp.netlinkr Zexabgp.netlink.sequencer Zexabgp.netlink.attributesr �getattr�AttributeError� ImportErrorr; r
r r r r �<module> s "