mirror of
https://github.com/netbirdio/gvisor.git
synced 2026-05-22 17:12:49 -07:00
Merge pull request #6803 from pkit:pkit/copy_arp
PiperOrigin-RevId: 407177936
This commit is contained in:
@@ -78,6 +78,11 @@ type DefaultRoute struct {
|
||||
Name string
|
||||
}
|
||||
|
||||
type Neighbor struct {
|
||||
IP net.IP
|
||||
HardwareAddr net.HardwareAddr
|
||||
}
|
||||
|
||||
// FDBasedLink configures an fd-based link.
|
||||
type FDBasedLink struct {
|
||||
Name string
|
||||
@@ -90,6 +95,7 @@ type FDBasedLink struct {
|
||||
RXChecksumOffload bool
|
||||
LinkAddress net.HardwareAddr
|
||||
QDisc config.QueueingDiscipline
|
||||
Neighbors []Neighbor
|
||||
|
||||
// NumChannels controls how many underlying FD's are to be used to
|
||||
// create this endpoint.
|
||||
@@ -241,6 +247,11 @@ func (n *Network) CreateLinksAndRoutes(args *CreateLinksAndRoutesArgs, _ *struct
|
||||
}
|
||||
routes = append(routes, route)
|
||||
}
|
||||
|
||||
for _, neigh := range link.Neighbors {
|
||||
proto, tcpipAddr := ipToAddressAndProto(neigh.IP)
|
||||
n.Stack.AddStaticNeighbor(nicID, proto, tcpipAddr, tcpip.LinkAddress(neigh.HardwareAddr))
|
||||
}
|
||||
}
|
||||
|
||||
if !args.Defaultv4Gateway.Route.Empty() {
|
||||
|
||||
@@ -173,6 +173,23 @@ func createInterfacesAndRoutesFromNS(conn *urpc.Client, nsPath string, hardwareG
|
||||
continue
|
||||
}
|
||||
|
||||
// Collect data from the ARP table.
|
||||
dump, err := netlink.NeighList(iface.Index, 0)
|
||||
if err != nil {
|
||||
return fmt.Errorf("fetching ARP table for %q: %w", iface.Name, err)
|
||||
}
|
||||
|
||||
var neighbors []boot.Neighbor
|
||||
for _, n := range dump {
|
||||
// There are only two "good" states NUD_PERMANENT and NUD_REACHABLE,
|
||||
// but NUD_REACHABLE is fully dynamic and will be re-probed anyway.
|
||||
if n.State == netlink.NUD_PERMANENT {
|
||||
log.Debugf("Copying a static ARP entry: %+v %+v", n.IP, n.HardwareAddr)
|
||||
// No flags are copied because Stack.AddStaticNeighbor does not support flags right now.
|
||||
neighbors = append(neighbors, boot.Neighbor{IP: n.IP, HardwareAddr: n.HardwareAddr})
|
||||
}
|
||||
}
|
||||
|
||||
// Scrape the routes before removing the address, since that
|
||||
// will remove the routes as well.
|
||||
routes, defv4, defv6, err := routesForIface(iface)
|
||||
@@ -203,6 +220,7 @@ func createInterfacesAndRoutesFromNS(conn *urpc.Client, nsPath string, hardwareG
|
||||
RXChecksumOffload: rxChecksumOffload,
|
||||
NumChannels: numNetworkChannels,
|
||||
QDisc: qDisc,
|
||||
Neighbors: neighbors,
|
||||
}
|
||||
|
||||
// Get the link for the interface.
|
||||
|
||||
Reference in New Issue
Block a user