Lines Matching refs:rx_msg
52 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
53 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
54 family = rx_msg.base_hdr.ifa_family
55 scope = rx_msg.base_hdr.ifa_scope
81 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
82 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
83 family = rx_msg.base_hdr.ifa_family
84 ret.append((ifname, family, rx_msg))
104 for rx_msg in self.read_msg_list(hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
105 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
106 family = rx_msg.base_hdr.ifa_family
107 ret.append((ifname, family, rx_msg))
121 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
122 assert family == rx_msg.base_hdr.ifa_family
123 assert epair_ifname == socket.if_indextoname(rx_msg.base_hdr.ifa_index)
124 ret.append(rx_msg)
190 rx_msg = self.get_reply(msg)
191 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
192 assert rx_msg.error_code == 0
237 rx_msg = nlsock.get_reply(msg)
239 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
240 assert rx_msg.error_code == 0
258 rx_msg = lst[0]
260 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
261 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
263 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
264 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
265 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
293 rx_msg = lst[0]
295 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
296 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
298 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
299 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
300 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
338 rx_msg = lst[0]
340 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
341 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
343 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
344 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
345 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
346 ifa_bsd = rx_msg.get_nla(IfaAttrType.IFA_FREEBSD)
390 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
391 assert rx_msg is not None
393 ci = rx_msg.get_nla(IfaAttrType.IFA_CACHEINFO).ci
439 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
440 assert rx_msg is not None
442 assert rx_msg.get_nla(IfaAttrType.IFA_FLAGS).u32 == nl_flags
443 ifa_bsd = rx_msg.get_nla(IfaAttrType.IFA_FREEBSD)
454 rx_msg = self.get_reply(msg)
455 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
456 assert rx_msg.error_code != 0
468 rx_msg = self.get_reply(msg)
469 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
470 assert rx_msg.error_code != 0
480 rx_msg = self.get_reply(msg)
481 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
482 assert rx_msg.error_code != 0
512 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
513 assert rx_msg is not None
528 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
529 assert rx_msg is None
559 rx_msg = lst[0]
561 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
562 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
564 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
565 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(peer_ip)
639 rx_msg = self.find_msg_by_ifa(lst, peer_ip)
640 assert rx_msg is not None
659 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
660 assert rx_msg is None
685 rx_msg = lst[0]
687 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
688 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
690 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
691 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
712 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
713 assert rx_msg is not None
715 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
716 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
717 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
745 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
746 assert rx_msg is not None
761 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
762 assert rx_msg is None