ó
oBú]c @ sË d d l m Z d d l m Z d d l m Z d d l Z d d l Z d d l Z d d l Z e j
e ƒ Z d Z
d Z d Z d Z d Z d Z d
Z d Z d Z d
Z d Z d Z d Z d Z e j e ƒ Z e j e ƒ Z e e Z d Z d Z d Z! d Z" d Z# d Z$ d Z% d Z& d Z' d Z( d Z) e d d d d g ƒ Z* e d d d g ƒ Z+ e d d d d d d g ƒ Z, d! e- f d" „ ƒ YZ. d# „ Z/ d$ „ Z0 d d% „ Z2 d& „ Z3 d' „ Z4 d( „ Z5 d S() iÿÿÿÿ( t log( t util( t
namedtupleNi i i i i i i iÿÿ i i< t IHHIIt BHiIIi i i i t RTAAttrt lengtht rta_typet datat InterfaceOperstatet ifnamet operstatet
NetlinkHeadert typet flagst seqt pidt NetlinkCreateSocketErrorc B s e Z d Z RS( s5 Raised if netlink socket fails during create or bind.( t __name__t
__module__t __doc__( ( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyR 8 s c C sˆ yH t j t j t j t j ƒ } | j t j ƒ t f ƒ | j d ƒ Wn, t j k
rv } d | } t
| ƒ ‚ n Xt j d ƒ | S( su 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
i s* Exception during netlink socket create: %ss Created netlink socket(
t sockett
AF_NETLINKt SOCK_RAWt
NETLINK_ROUTEt bindt ost getpidt RTMGRP_LINKt setblockingt errorR t LOGt debug( t netlink_sockett et msg( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt create_bound_netlink_socket= s
c C sK t j t | t ƒ \ } } } } } t j d | ƒ t | | | | | ƒ S( s 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 */
};
s Got netlink msg of type %d( t structt unpackt NLMSGHDR_FMTt MSG_TYPE_OFFSETR R R ( R t msg_lent msg_typeR R R ( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt get_netlink_msg_headerS s c C sp t j | g g g | ƒ \ } } } | | k r4 d St j d ƒ | j t ƒ } | d k rl t j d ƒ n | S( sÁ 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
s netlink socket ready for reads, Reading from Netlink socket returned no dataN( t selectt NoneR R t recvt MAX_SIZER ( R! t timeoutt read_sett _R ( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt read_netlink_socketj s $
c C s d } } d } y@ t j d | d | ƒd } t j d | d | d ƒd } Wn t j k
rg d SX| | t | | !} t | | | ƒ S( s( 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.
i t Ht offseti N( R- R% t unpack_fromR t RTA_DATA_START_OFFSETR ( R R5 R R t attr_data( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt unpack_rta_attr s
$c C s d } } t } x¼ | t | ƒ k rÎ t | | ƒ } | sJ | j d k rN Pn t | j t t } | | j | 7} | j t k r• t | j ƒ } q | j t
k r t j | j d ƒ } | j
d ƒ } q q W| sâ | d k ræ d St j d | | ƒ t | | ƒ S( s 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.
i s utf-8t s! rta attrs: ifname %s operstate %dN( R- t RTATTR_START_OFFSETt lenR9 R t
PAD_ALIGNMENTR t IFLA_OPERSTATEt ordR t IFLA_IFNAMER t
decode_binaryt stripR R R ( R R
R R5 t attrt padlent interface_name( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt read_rta_oper_stateš s$
c
C s t } t } t ƒ } t j d ƒ xót rt | t ƒ } | d k rL q% n t j d t | ƒ ƒ | | 7} t j d t | ƒ ƒ d } t | ƒ } xs| | k r | | } t | ƒ t k rÐ t j d ƒ Pn t
| ƒ } t | ƒ | j k rt j d ƒ Pn | j t d t d @}
| |
} t j d | ƒ | j
t t g k rQq— n t | ƒ } | d k rt j d | ƒ q— n | j | k rªt j d
| j | ƒ q— n | j t t g k rÅq— n | } | j } | t k oé| t k } | r— t j d | ƒ d Sq— W| | } q% Wd S(
s» 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.
s1 Wait for media disconnect and reconnect to happens read %d bytes from sockets Length of data after concat %di s# Data is smaller than netlink headers* Partial data. Smaller than netlink messagei s" offset to next netlink message: %ds! Failed to read rta attributes: %ss6 Ignored netlink event on interface %s. Waiting for %s.s Media switch happened on %s.N( t OPER_UPt bytesR R t TrueR3 t SELECT_TIMEOUTR- R< t
NLMSGHDR_SIZER+ R R= R
t RTM_NEWLINKt RTM_DELLINKRF R
R t OPER_DOWN(
R! R
t carriert prevCarrierR t recv_dataR5 t datalent nl_msgt nlheaderRD t interface_statet isVnetSwitch( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt! wait_for_media_disconnect_connect½ sZ
(6 t cloudinitR t loggingR t collectionsR R R, R R% t getLoggerR R R t
NLMSG_NOOPt NLMSG_ERRORt
NLMSG_DONERL RM t RTM_GETLINKt RTM_SETLINKR/ t RTA_DATA_OFFSETR( RJ R' t
IFINFOMSG_FMTt calcsizeRK t IFINFOMSG_SIZER; R7 R= R@ R> t OPER_UNKNOWNt OPER_NOTPRESENTRN t OPER_LOWERLAYERDOWNt OPER_TESTINGt OPER_DORMANTRG R R R t RuntimeErrorR R$ R+ R- R3 R9 RF RW ( ( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt <module> s\
#