17 def _users_for(rtnl: RtnlAddrFamily, family: int, grp: bytes, ifindex: int):
20     addrs = rtnl.getmulticast({"ifa-family": family}, dump=True)
39             rtnl = RtnlAddrFamily()
41             addresses = rtnl.getmulticast({"ifa-family": socket.AF_INET}, dump=True)
52             before = _users_for(rtnl, socket.AF_INET, IPV4_TEST_MULTICAST, lo_idx)
62                 after_join = _users_for(rtnl, socket.AF_INET,
82             rtnl = RtnlAddrFamily()
84             before = _users_for(rtnl, socket.AF_INET6,
96                 after_join = _users_for(rtnl, socket.AF_INET6,
141         rtnl = RtnlRouteFamily()
142     defer(rtnl.close)
143     rtnl.ntf_subscribe("rtnlgrp-ipv6-route")
144     return rtnl
147 def _wait_route_ntf(rtnl, name, dst_len, dst=None, deadline=10):  argument
150     for msg in rtnl.poll_ntf(duration=deadline):
162 def _collect_route_ntfs(rtnl, name, want, deadline=10):  argument
166     for msg in rtnl.poll_ntf(duration=deadline):
187         rtnl = _rtnl_route_subscribe(ns)
194         attrs = _wait_route_ntf(rtnl, 'delroute-ntf', 64, '2001:db8:2::',
229 def _ra_advertise_routes(rtnl, sock, ifindex, want, **ra_opts):  argument
244         seen.update(_collect_route_ntfs(rtnl, 'newroute-ntf',
276         rtnl = _rtnl_route_subscribe(ns_h)
279         seen = _ra_advertise_routes(rtnl, sock, ifindex, routes,
289         seen = _collect_route_ntfs(rtnl, 'delroute-ntf', routes)
304         rtnl = _rtnl_route_subscribe(ns)
310         attrs = _wait_route_ntf(rtnl, 'delroute-ntf', 64, '2001:db8:1::')