+ qgj.^RIt^RIt^RIt^RIt^RIt^RIHt^RIHt]P!] 4t ^t ^t ^t^t^tRt^t^&s+23sA=BC+CCcVfQR4h\V4\8gQR4h\P!\VR\ 4wrr4p\ PRV4\WW4V4#)aGets 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 */ }; N data is nonez+data is smaller than netlink message headerzGot netlink msg of type %d) len NLMSGHDR_SIZEstructunpack NLMSGHDR_FMTMSG_TYPE_OFFSETr"r#r )datamsg_lenmsg_typeflagsseqpids& rget_netlink_msg_headerr6Oss  +^+  D ]"545")/d+O,*&Gu3II*H5 E <) from socket, if no data read, returns None :raises: AssertionError if netlink_socket is None Nnetlink socket is noneznetlink socket ready for readz,Reading from Netlink socket returned no data)selectr"r#recvMAX_SIZEr!)r$timeoutread_set_r0s&& rread_netlink_socketr?hsr  %?'?? %]]N#3RWENHa%II-.   x (D | @A KrcVfQR4h\V\4'gQR4hV\8gQR4h^;r#Rp\P!RWR7^,p\P!RW^,R7^,pY\ ,Y,p\Y#T4# \P dR#i;i)aUnpack 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. Nr)zoffset is not integerz'rta offset is less than expected lengthH)offset) isinstanceintRTATTR_START_OFFSETr, unpack_fromr!RTA_DATA_START_OFFSETr)r0rBlengthrta_type attr_datas&& runpack_rta_attrrKs  +^+  fc " ";$;; "%%101%FI##C=a@%%c4 CAF 33foFI 6Y // <<sAB''C?CcVfQR4h\V4\8gQR4hR;r\pV\V48:d\W4pV'dVP^8XdM\VP\,, \,pW4PV,, pVP \ 8Xd\VP4pKVP \8XgK\P!VPR4pVPR4pKV'dVfR#\PRW4\W4#)aReads 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. Nr)z2length of data is smaller than RTATTR_START_OFFSETzutf-8z!rta attrs: ifname %s operstate %d)r*rErKrH PAD_ALIGNMENTrIIFLA_OPERSTATEordr0 IFLA_IFNAMEr decode_binarystripr"r#r)r0r r rBattrpadleninterface_names& rread_rta_oper_staterWs  +^+  D ''<;<'F F CI t,t{{a'  T[[=8 9  ++&& ==N *DIII ]]k )!// 7CN#))$/F Y&II16E f 00rcaa\PR4RoVV3Rlp\VR\.\\ .V4S#)zBlock until a single nic is attached. :param: netlink_socket: netlink_socket to receive events :param: existing_nics: List of existing nics so that we can skip them. :raises: AssertionError if netlink_socket is none. z!Preparing to wait for nic attach.Nc<VS9dR#VoR#)TFr)inamecarrier prevCarrier existing_nicsr s&&&rshould_continue_cb5wait_for_nic_attach_event..should_continue_cbs M !r)r"r#read_netlink_messages RTM_NEWLINKOPER_UP OPER_DOWN)r$r]r^r s&f @rwait_for_nic_attach_eventrdsCII12 F  )  Mrcta\PR4RoV3Rlp\VR\.\.V4S#)zBlock until a single nic is detached and its operational state is down. :param: netlink_socket: netlink_socket to receive events. z!Preparing to wait for nic detach.Nc <VoR#)Fr)rZr[r\r s&&&rr^5wait_for_nic_detach_event..should_continue_cbs r)r"r#r` RTM_DELLINKrc)r$r^r s& @rwait_for_nic_detach_eventris= II12 F {mi[:L MrcaVfQR4hSfQR4h\S4^8gQR4hV3Rlp\PR4\VS\\ .\ \.V4R#)aBlock 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. Nr8zinterface name is nonezinterface name cannot be emptyc|<V\8H;'d V\8HpV'd\PRS4R#R#)zMedia switch happened on %s.FT)rcrbr"r#)rZr[r\ isVnetSwitchr s&&& rr^=wait_for_media_disconnect_connect..should_continue_cbs2#y0JJw'7I  II4f =rz1Wait for media disconnect and reconnect to happen)r*r"r#r`rarhrbrc)r$r r^s&f r!wait_for_media_disconnect_connectrnst  %?'?? %  777  v;?<<\V 4p \V 4V P8d\ P R4EMV P\,^, \^, (,p W,p \ P RV 4V PV9dK\V 4pVf\ P RV4KVe6VPV8wd%\ P R VPV4EK4VPV9dEKHTpVPpV!VPWg4'dEKrR#WYRpEK) aReads from the netlink socket until the condition specified by the continuation callback is met. :param: netlink_socket: netlink_socket to receive events. :param: ifname_filter: if not None, will only listen for this interface. :param: rtm_types: Type of netlink events to listen for. :param: operstates: Operational states to listen. :param: should_continue_callback: Specifies when to stop listening. NzNetlink socket is nonezread %d bytes from socketzLength of data after concat %dz#Data is smaller than netlink headerz*Partial data. Smaller than netlink messagez"offset to next netlink message: %dz!Failed to read rta attributes: %sz6Ignored netlink event on interface %s. Waiting for %s.) RuntimeErrorbytesrbr?SELECT_TIMEOUTr"r#r*r+r6rHrNtyperWr r )r$ ifname_filter rtm_types operstatesshould_continue_callbackr0r[r\ recv_datarBdatalennl_msgnlheaderrUinterface_states&&&&& rr`r`s 344 7DGK 'G    -s9~>  2CI>d)']F6{]* ?@-f5H6{X__, FGoo 59!>F_F II:F C}}I-1&9O& =O)#**m; L#**! (( :!K%//G+&&G}r)rHrIr0)rHrsr3r4r5)N)3loggingrr9rr, collectionsr cloudinitr getLoggerrr"rrarh RTM_GETLINK RTM_SETLINKr;r/rrr. IFINFOMSG_FMTcalcsizer+IFINFOMSG_SIZErErGrNrQrO OPER_UNKNOWNOPER_NOTPRESENTrcOPER_LOWERLAYERDOWN OPER_TESTING OPER_DORMANTrbrrr rpr r'r6r?rKrWrdrirnr`rrrrs0  " !        - /#n4       Y > ? 4x6MN> @|@,=2.04"1J:&@Er