x[h.SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr \R"\ 5r Sr Sr SrSrSrS rSrS rS rS r\R,"\5r\R,"\5r\\-rS rS rSrSrSrSrSr Sr!S r"Sr#Sr$\"S/SQ5r%\"SSS/5r&\"S/SQ5r'"SS\(5r)Sr*Sr+S$Sjr,Sr-Sr.S r/S!r0S"r1S#r2g)%N) namedtuple)utili<IHHIIBHiIIRTAAttr)lengthrta_typedataInterfaceOperstateifname operstate NetlinkHeader)rtypeflagsseqpidc\rSrSrSrSrg)NetlinkCreateSocketError5z5Raised if netlink socket fails during create or bind.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r!C/usr/lib/python3/dist-packages/cloudinit/sources/helpers/netlink.pyrr5s?r(rc[R"[R[R[R5nUR [ R "5[45 URS5 [RS5 U$![RanSU-n[U5UeSnAff=f)a]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 rz*Exception during netlink socket create: %sNzCreated netlink socket) socket AF_NETLINKSOCK_RAW NETLINK_ROUTEbindosgetpid RTMGRP_LINK setblockingerrorrLOGdebug)netlink_socketemsgs r)create_bound_netlink_socketr:9s3   v0D0D  RYY[+67""1%II&'  <<3:Q>&s+23sA=BC*B;;CcUcS5e[U5[:dS5e[R"[US[ 5upp4n[ RSU5 [XX4U5$)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_OFFSETr5r6r)rmsg_lenmsg_typerrrs r)get_netlink_msg_headerrEOss  +^+  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)selectr5r6recvMAX_SIZEr4)r7timeoutread_set_rs r)read_netlink_socketrNhsr  %?'?? %]]N#3RWENHa%II-.   x (D | @A Kr(cHUcS5e[U[5(dS5eU[:dS5eS=p#Sn[R"SXS9Sn[R"SXS-S9SnX[ -X-n[X#U5$![R a gf=f) 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 lengthrH)offsetr) isinstanceintRTATTR_START_OFFSETr? unpack_fromr4RTA_DATA_START_OFFSETr)rrQrr attr_datas r)unpack_rta_attrrXs  +^+  fc " ";$;; "%%101%FI##C=a@%%c4 CAF 33foFI 6Y // <<s3B B! B!c~UcS5e[U5[:dS5eS=p[nU[U5::a[X5nU(aURS:XaO[UR[-- [-nX4RU-- nUR [ :Xa[UR5nOFUR [:Xa2[R"URS5nURS5nU[U5::aMU(aUcg[RSX5 [X5$)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_OFFSETrzutf-8z!rta attrs: ifname %s operstate %d)r=rTrXr PAD_ALIGNMENTrIFLA_OPERSTATEordr IFLA_IFNAMEr decode_binarystripr5r6r)rrrrQattrpadleninterface_names r)read_rta_oper_staterds  +^+  D ''<;<'F F CI t,t{{a'  T[[=8 9  ++&& ==N *DIII ]]k )!// 7CN#))$/F CI  Y&II16E f 00r(c^^[RS5 SmUU4Sjn[US[/[[ /U5 T$)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>UT;agUmg)NTFr!)inamecarrier prevCarrier existing_nicsrs r)should_continue_cb5wait_for_nic_attach_event..should_continue_cbs M !r()r5r6read_netlink_messages RTM_NEWLINKOPER_UP OPER_DOWN)r7rjrkrs ` @r)wait_for_nic_attach_eventrqsCII12 F  )  Mr(ct^[RS5 SmU4Sjn[US[/[/U5 T$)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 >Umg)NFr!)rgrhrirs r)rk5wait_for_nic_detach_event..should_continue_cbs r()r5r6rm RTM_DELLINKrp)r7rkrs @r)wait_for_nic_detach_eventrvs= II12 F {mi[:L Mr(c^UcS5eTcS5e[T5S:dS5eU4Sjn[RS5 [UT[[ /[ [/U5 g)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. NrGzinterface name is nonerzinterface name cannot be emptyct>U[:H=(a U[:HnU(a[RST5 gg)NzMedia switch happened on %s.FT)rpror5r6)rgrhri isVnetSwitchrs r)rk=wait_for_media_disconnect_connect..should_continue_cbs/#y0Jw'7I  II4f =r(z1Wait for media disconnect and reconnect to happen)r=r5r6rmrnrurorp)r7rrks ` r)!wait_for_media_disconnect_connectr{st  %?'?? %  777  v;?<<rErr[rrdrr)r7 ifname_filter rtm_types operstatesshould_continue_callbackrrhri recv_datarQdatalennl_msgnlheaderrbinterface_states r)rmrms 344 7DGK 'G    -s9~>  2CI>d)']F6{]* ?@-f5H6{X__, FGoo 59!>F_F II:F C}}I-1&9O& =O)#**m; L#**! (( :!K%//G+&&MNG}a r()N)3loggingr0rHr+r? collectionsr cloudinitr getLoggerr"r5r2rnru RTM_GETLINK RTM_SETLINKrJrBrrA IFINFOMSG_FMTcalcsizer>IFINFOMSG_SIZErTrVr[r^r\ OPER_UNKNOWNOPER_NOTPRESENTrpOPER_LOWERLAYERDOWN OPER_TESTING OPER_DORMANTrorrrr}rr:rErNrXrdrqrvr{rmr!r(r)rs0  " !        - /#n4       Y > ? 4x6MN> @|@,=2.04"1J:&@Er(