Lines Matching full:msg
44 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
45 msg.set_request()
46 self.write_message(msg)
49 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
65 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
66 msg.set_request()
67 msg.base_hdr.ifa_index = socket.if_nametoindex(epair_ifname)
68 self.write_message(msg)
71 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
104 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
105 msg.set_request()
106 msg.base_hdr.ifa_family = family
107 msg.base_hdr.ifa_index = socket.if_nametoindex(epair_ifname)
108 self.write_message(msg)
111 for rx_msg in self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR):
122 msg = ret[0]
124 assert msg.base_hdr.ifa_prefixlen == 24
126 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
128 assert msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == "192.0.2.1"
129 assert msg.get_nla(IfaAttrType.IFA_LOCAL).addr == "192.0.2.1"
130 assert msg.get_nla(IfaAttrType.IFA_BROADCAST).addr == "192.0.2.255"
133 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
144 msg = gmsg
146 assert msg.base_hdr.ifa_prefixlen == 64
148 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_UNIVERSE.value
150 assert msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == "2001:db8::1"
151 assert msg.get_nla(IfaAttrType.IFA_LOCAL) is None
152 assert msg.get_nla(IfaAttrType.IFA_BROADCAST) is None
155 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
158 msg = lmsg
159 assert msg.base_hdr.ifa_prefixlen == 64
161 assert msg.base_hdr.ifa_scope == RtScope.RT_SCOPE_LINK.value
163 addr = ipaddress.ip_address(msg.get_nla(IfaAttrType.IFA_ADDRESS).addr)
167 assert msg.get_nla(IfaAttrType.IFA_LOCAL) is None
168 assert msg.get_nla(IfaAttrType.IFA_BROADCAST) is None
171 assert msg.get_nla(IfaAttrType.IFA_LABEL).text == epair_ifname
179 def send_check_success(self, msg): argument
180 rx_msg = self.get_reply(msg)
193 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_NEWADDR.value)
194 msg.set_request()
195 msg.nl_hdr.nlmsg_flags |= (
198 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
199 msg.base_hdr.ifa_index = iface.ifindex
200 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
201 return msg
204 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_GETADDR.value)
205 msg.set_request()
206 msg.base_hdr.ifa_family = family
207 msg.base_hdr.ifa_index = ifindex
208 self.write_message(msg)
209 return self.read_msg_list(msg.nl_hdr.nlmsg_seq, NlRtMsgType.RTM_NEWADDR)
212 for msg in msg_list:
213 if msg.get_nla(IfaAttrType.IFA_ADDRESS).addr == str(ip):
214 return msg
223 msg = CarpGenMessage(self.helper, family_id, CarpMsgType.CARP_NL_CMD_SET)
224 msg.set_request()
225 msg.add_nla(NlAttrU32(CarpAttrType.CARP_NL_VHID, vhid))
226 msg.add_nla(NlAttrU32(CarpAttrType.CARP_NL_IFINDEX, ifindex))
227 rx_msg = nlsock.get_reply(msg)
240 msg = self.create_msg(ifa)
241 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
242 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
244 self.send_check_success(msg)
274 msg = self.create_msg(ifa)
275 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
277 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
279 self.send_check_success(msg)
296 msg = self.create_msg(ifa)
297 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
299 self.send_check_success(msg)
318 msg = self.create_msg(ifa)
319 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
320 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
322 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
324 self.send_check_success(msg)
346 msg = self.create_msg(ifa)
347 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
349 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
351 self.send_check_success(msg)
372 msg = self.create_msg(ifa)
373 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
374 msg.add_nla(NlAttr(IfaAttrType.IFA_CACHEINFO, bytes(ci)))
376 self.send_check_success(msg)
419 msg = self.create_msg(ifa)
420 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
421 msg.add_nla(NlAttrU32(IfaAttrType.IFA_FLAGS, nl_flags))
423 msg.add_nla(NlAttrNested(IfaAttrType.IFA_FREEBSD, attrs_bsd))
425 self.send_check_success(msg)
438 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_NEWADDR.value)
439 msg.set_request()
440 msg.nl_hdr.nlmsg_flags |= (
444 rx_msg = self.get_reply(msg)
453 msg = self.create_msg(ifa)
454 msg.base_hdr.ifa_index = 0
455 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
456 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
458 rx_msg = self.get_reply(msg)
467 msg = self.create_msg(ifa)
468 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
470 rx_msg = self.get_reply(msg)
496 msg = self.create_msg(ifa)
497 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
498 msg.add_nla(NlAttrIp(IfaAttrType.IFA_BROADCAST, str(ifa_brd)))
500 self.send_check_success(msg)
505 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
506 msg.set_request()
507 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
508 msg.base_hdr.ifa_index = iface.ifindex
509 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
512 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
514 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
516 self.send_check_success(msg)
541 msg = self.create_msg(ifa)
542 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
543 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
545 self.send_check_success(msg)
584 msg = self.create_msg(ifa)
585 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
586 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
588 self.send_check_success(msg)
623 msg = self.create_msg(ifa)
624 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
625 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
627 self.send_check_success(msg)
632 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
633 msg.set_request()
634 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
635 msg.base_hdr.ifa_index = iface.ifindex
636 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
639 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
641 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(peer_ip)))
643 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
645 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(peer_ip)))
647 self.send_check_success(msg)
668 msg = self.create_msg(ifa)
669 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
671 self.send_check_success(msg)
695 msg = self.create_msg(ifa)
696 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
698 self.send_check_success(msg)
730 msg = self.create_msg(ifa)
731 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
733 self.send_check_success(msg)
738 msg = NetlinkIfaMessage(self.helper, NlRtMsgType.RTM_DELADDR.value)
739 msg.set_request()
740 msg.base_hdr.ifa_family = self.get_family_from_ip(ifa.ip)
741 msg.base_hdr.ifa_index = iface.ifindex
742 msg.base_hdr.ifa_prefixlen = ifa.network.prefixlen
745 msg.add_nla(NlAttrIp(IfaAttrType.IFA_LOCAL, str(ifa.ip)))
747 msg.add_nla(NlAttrIp(IfaAttrType.IFA_ADDRESS, str(ifa.ip)))
749 self.send_check_success(msg)