Lines Matching refs:rx_msg
49 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
50 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
51 family = rx_msg.base_hdr.ifa_family
52 ret.append((ifname, family, rx_msg))
71 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
72 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
73 family = rx_msg.base_hdr.ifa_family
74 ret.append((ifname, family, rx_msg))
94 for rx_msg in self.read_msg_list(hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
95 ifname = socket.if_indextoname(rx_msg.base_hdr.ifa_index)
96 family = rx_msg.base_hdr.ifa_family
97 ret.append((ifname, family, rx_msg))
111 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
112 assert family == rx_msg.base_hdr.ifa_family
113 assert epair_ifname == socket.if_indextoname(rx_msg.base_hdr.ifa_index)
114 ret.append(rx_msg)
180 rx_msg = self.get_reply(msg)
181 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
182 assert rx_msg.error_code == 0
227 rx_msg = nlsock.get_reply(msg)
229 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
230 assert rx_msg.error_code == 0
248 rx_msg = lst[0]
250 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
251 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
253 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
254 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
255 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
283 rx_msg = lst[0]
285 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
286 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
288 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
289 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
290 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
328 rx_msg = lst[0]
330 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
331 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
333 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
334 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
335 assert rx_msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == str(ifa_brd)
336 ifa_bsd = rx_msg.get_nla(IfaAttrType.IFA_FREEBSD)
380 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
381 assert rx_msg is not None
383 ci = rx_msg.get_nla(IfaAttrType.IFA_CACHEINFO).ci
429 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
430 assert rx_msg is not None
432 assert rx_msg.get_nla(IfaAttrType.IFA_FLAGS).u32 == nl_flags
433 ifa_bsd = rx_msg.get_nla(IfaAttrType.IFA_FREEBSD)
444 rx_msg = self.get_reply(msg)
445 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
446 assert rx_msg.error_code != 0
458 rx_msg = self.get_reply(msg)
459 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
460 assert rx_msg.error_code != 0
470 rx_msg = self.get_reply(msg)
471 assert rx_msg.is_type(NlMsgType.NLMSG_ERROR)
472 assert rx_msg.error_code != 0
502 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
503 assert rx_msg is not None
518 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
519 assert rx_msg is None
549 rx_msg = lst[0]
551 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
552 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
554 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
555 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(peer_ip)
629 rx_msg = self.find_msg_by_ifa(lst, peer_ip)
630 assert rx_msg is not None
649 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
650 assert rx_msg is None
675 rx_msg = lst[0]
677 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
678 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
680 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
681 assert rx_msg.get_nla(IfaAttrType.IFA_LOCAL).addr == str(ifa.ip)
702 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
703 assert rx_msg is not None
705 assert rx_msg.base_hdr.ifa_prefixlen == ifa.network.prefixlen
706 assert rx_msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
707 assert rx_msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ifa.ip)
735 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
736 assert rx_msg is not None
751 rx_msg = self.find_msg_by_ifa(lst, ifa.ip)
752 assert rx_msg is None