ó
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 s | d k s t d ƒ ‚ t | ƒ t k s6 t d ƒ ‚ 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 data is nones+ data is smaller than netlink message headers Got netlink msg of type %dN( t Nonet AssertionErrort lent
NLMSGHDR_SIZEt 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 sˆ | d k s t d ƒ ‚ t j | g g g | ƒ \ } } } | | k rL d St j d ƒ | j t ƒ } | d k r„ 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 is nones netlink socket ready for reads, Reading from Netlink socket returned no dataN( R% R& t selectR 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 k s t d ƒ ‚ t | ƒ t k s6 t d ƒ ‚ | t k sN t d ƒ ‚ d } } d } y@ t j d | d | ƒd } t j d | d | d ƒd } Wn t j k
rµ 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.
s data is nones offset is not integers' rta offset is less than expected lengthi t Ht offseti N(
R% R& R
t intt RTATTR_START_OFFSETR) t unpack_fromR t RTA_DATA_START_OFFSETR ( R R8 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 k s t d ƒ ‚ t | ƒ t k s6 t d ƒ ‚ d } } t } x¼ | t | ƒ k rt | | ƒ } | s€ | j d k r„ Pn t | j t t } | | j | 7} | j t k rË t | j
ƒ } qI | j t k rI t j
| j
d ƒ } | j d ƒ } qI qI 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.
s data is nones2 length of data is smaller than RTATTR_START_OFFSETi s utf-8t s! rta attrs: ifname %s operstate %dN( R% R& R' R: R> R t
PAD_ALIGNMENTR t IFLA_OPERSTATEt ordR t IFLA_IFNAMER t
decode_binaryt stripR R R ( R R
R R8 t attrt padlent interface_name( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt read_rta_oper_stateš s*
c
C sj | d k s t d ƒ ‚ | d k s0 t d ƒ ‚ t | ƒ d k sN t d ƒ ‚ t } t } t ƒ } t j d ƒ xót ret | t ƒ } | d k rš qs n t j d t | ƒ ƒ | | 7} t j d t | ƒ ƒ d } t | ƒ } xs| | k rW| | } t | ƒ t
k r t j d ƒ Pn t | ƒ } t | ƒ | j k rPt j d ƒ Pn | j t
d
t
d
@}
| |
} t j d | ƒ | j t t g k rŸqå n t | ƒ } | d k rÍt j d | ƒ qå n | j | k røt j d
| j | ƒ qå n | j t t g k rqå n | } | j } | t k o7| t k } | rå t j d | ƒ d Sqå W| | } qs 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.
s netlink socket is nones interface name is nonei s interface name cannot be emptys1 Wait for media disconnect and reconnect to happens read %d bytes from sockets Length of data after concat %ds# 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( R% R& R' t OPER_UPt bytesR R t TrueR6 t SELECT_TIMEOUTR( R/ R R@ R
t RTM_NEWLINKt RTM_DELLINKRI R
R t OPER_DOWN(
R! R
t carriert prevCarrierR t recv_dataR8 t datalent nl_msgt nlheaderRG t interface_statet isVnetSwitch( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt! wait_for_media_disconnect_connect½ s`
(6 t cloudinitR t loggingR t collectionsR R R0 R R) t getLoggerR R R t
NLMSG_NOOPt NLMSG_ERRORt
NLMSG_DONERN RO t RTM_GETLINKt RTM_SETLINKR2 t RTA_DATA_OFFSETR, RM R+ t
IFINFOMSG_FMTt calcsizeR( t IFINFOMSG_SIZER: R< R@ RC RA t OPER_UNKNOWNt OPER_NOTPRESENTRP t OPER_LOWERLAYERDOWNt OPER_TESTINGt OPER_DORMANTRJ R R R t RuntimeErrorR R$ R/ R% R6 R> RI RY ( ( ( sE /usr/lib/python2.7/site-packages/cloudinit/sources/helpers/netlink.pyt <module> s\
#