Lines Matching full:msg
47 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
48 msg.set_request()
49 self.write_message(msg)
52 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
75 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
76 msg.set_request()
77 msg.base_hdr.ifa_index = socket.if_nametoindex(epair_ifname)
78 self.write_message(msg)
81 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
114 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
115 msg.set_request()
116 msg.base_hdr.ifa_family = family
117 msg.base_hdr.ifa_index = socket.if_nametoindex(epair_ifname)
118 self.write_message(msg)
121 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
132 msg = ret[0]
134 assert msg.base_hdr.ifa_prefixlen == 24
136 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
138 assert msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == "192.0.2.1"
139 assert msg.get_nla(IfaAttrType.IFA_LOCAL).addr == "192.0.2.1"
140 assert msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == "192.0.2.255"
143 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
154 msg = gmsg
156 assert msg.base_hdr.ifa_prefixlen == 64
158 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
160 assert msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == "2001:db8::1"
161 assert msg.get_nla(IfaAttrType.IFA_LOCAL) is None
162 assert msg.get_nla(IfaAttrType.IFA_BROADCAST) is None
165 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
168 msg = lmsg
169 assert msg.base_hdr.ifa_prefixlen == 64
171 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_LINK.value
173 addr = ipaddress.ip_address(msg.get_nla(IfaAttrType.IFA_ADDRESS).addr)
177 assert msg.get_nla(IfaAttrType.IFA_LOCAL) is None
178 assert msg.get_nla(IfaAttrType.IFA_BROADCAST) is None
181 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
189 def send_check_success(self, msg): argument
190 rx_msg = self.get_reply(msg)
203 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_NEWADDR.value)
204 msg.set_request()
205 msg.nl_hdr.nlmsg_flags |= (
208 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
209 msg.base_hdr.ifa_index = iface.ifindex
210 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
211 return msg
214 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
215 msg.set_request()
216 msg.base_hdr.ifa_family = family
217 msg.base_hdr.ifa_index = ifindex
218 self.write_message(msg)
219 return self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR)
222 for msg in msg_list:
223 if msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ip):
224 return msg
233 msg = CarpGenMessage(self.helper, family_id, CarpMsgType.CARP_NL_CMD_SET)
234 msg.set_request()
235 msg.add_nla(NlAttrU32(CarpAttrType.CARP_NL_VHID, vhid))
236 msg.add_nla(NlAttrU32(CarpAttrType.CARP_NL_IFINDEX, ifindex))
237 rx_msg = nlsock.get_reply(msg)
250 msg = self.create_msg(ifa)
251 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
252 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
254 self.send_check_success(msg)
284 msg = self.create_msg(ifa)
285 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
287 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
289 self.send_check_success(msg)
306 msg = self.create_msg(ifa)
307 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
309 self.send_check_success(msg)
328 msg = self.create_msg(ifa)
329 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
330 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
332 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
334 self.send_check_success(msg)
356 msg = self.create_msg(ifa)
357 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
359 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
361 self.send_check_success(msg)
382 msg = self.create_msg(ifa)
383 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
384 msg.add_nla(NlAttr(IfaAttrType.IFA_CACHEINFO, bytes(ci)))
386 self.send_check_success(msg)
429 msg = self.create_msg(ifa)
430 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
431 msg.add_nla(NlAttrU32(IfaAttrType.IFA_FLAGS, nl_flags))
433 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
435 self.send_check_success(msg)
448 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_NEWADDR.value)
449 msg.set_request()
450 msg.nl_hdr.nlmsg_flags |= (
454 rx_msg = self.get_reply(msg)
463 msg = self.create_msg(ifa)
464 msg.base_hdr.ifa_index = 0
465 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
466 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
468 rx_msg = self.get_reply(msg)
477 msg = self.create_msg(ifa)
478 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
480 rx_msg = self.get_reply(msg)
506 msg = self.create_msg(ifa)
507 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
508 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
510 self.send_check_success(msg)
515 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
516 msg.set_request()
517 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
518 msg.base_hdr.ifa_index = iface.ifindex
519 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
522 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
524 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
526 self.send_check_success(msg)
551 msg = self.create_msg(ifa)
552 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
553 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
555 self.send_check_success(msg)
594 msg = self.create_msg(ifa)
595 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
596 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
598 self.send_check_success(msg)
633 msg = self.create_msg(ifa)
634 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
635 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
637 self.send_check_success(msg)
642 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
643 msg.set_request()
644 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
645 msg.base_hdr.ifa_index = iface.ifindex
646 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
649 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
651 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
653 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
655 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(peer_ip)))
657 self.send_check_success(msg)
678 msg = self.create_msg(ifa)
679 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
681 self.send_check_success(msg)
705 msg = self.create_msg(ifa)
706 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
708 self.send_check_success(msg)
740 msg = self.create_msg(ifa)
741 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
743 self.send_check_success(msg)
748 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
749 msg.set_request()
750 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
751 msg.base_hdr.ifa_index = iface.ifindex
752 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
755 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
757 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
759 self.send_check_success(msg)