mirror of
https://github.com/moby/moby.git
synced 2026-08-08 00:52:17 +00:00
00bf437d84
A recent change to the vishvananda/netlink package exposes NLM_F_DUMP_INTR in some netlink responses as an EINTR (with no data). Retry the requests when that happens, up to five times, before returning the error. The limit of five is arbitrary, on most systems a single retry will be rare but, there's no guarantee that a retry will succeed. So, on a very busy or misbehaving system the error may still be returned. In most cases, this will lead to failure of the operation being attempted (which may lead to daemon startup failure, network initialisation failure etc). Signed-off-by: Rob Murray <rob.murray@docker.com>
90 lines
2.0 KiB
Go
90 lines
2.0 KiB
Go
package bridge
|
|
|
|
import (
|
|
"net"
|
|
"testing"
|
|
|
|
"github.com/docker/docker/internal/nlwrap"
|
|
"github.com/docker/docker/internal/testutils/netnsutils"
|
|
"github.com/vishvananda/netlink"
|
|
)
|
|
|
|
func setupTestInterface(t *testing.T, nh nlwrap.Handle) (*networkConfiguration, *bridgeInterface) {
|
|
config := &networkConfiguration{
|
|
BridgeName: DefaultBridgeName,
|
|
}
|
|
br := &bridgeInterface{nlh: nh}
|
|
|
|
if err := setupDevice(config, br); err != nil {
|
|
t.Fatalf("Bridge creation failed: %v", err)
|
|
}
|
|
return config, br
|
|
}
|
|
|
|
func TestSetupBridgeIPv4Fixed(t *testing.T) {
|
|
defer netnsutils.SetupTestOSContext(t)()
|
|
|
|
ip, netw, err := net.ParseCIDR("192.168.1.1/24")
|
|
if err != nil {
|
|
t.Fatalf("Failed to parse bridge IPv4: %v", err)
|
|
}
|
|
|
|
nh, err := nlwrap.NewHandle()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer nh.Close()
|
|
|
|
config, br := setupTestInterface(t, nh)
|
|
config.AddressIPv4 = &net.IPNet{IP: ip, Mask: netw.Mask}
|
|
if err := setupBridgeIPv4(config, br); err != nil {
|
|
t.Fatalf("Failed to setup bridge IPv4: %v", err)
|
|
}
|
|
|
|
addrsv4, err := nh.AddrList(br.Link, netlink.FAMILY_V4)
|
|
if err != nil {
|
|
t.Fatalf("Failed to list device IPv4 addresses: %v", err)
|
|
}
|
|
|
|
var found bool
|
|
for _, addr := range addrsv4 {
|
|
if config.AddressIPv4.String() == addr.IPNet.String() {
|
|
found = true
|
|
break
|
|
}
|
|
}
|
|
|
|
if !found {
|
|
t.Fatalf("Bridge device does not have requested IPv4 address %v", config.AddressIPv4)
|
|
}
|
|
}
|
|
|
|
func TestSetupGatewayIPv4(t *testing.T) {
|
|
defer netnsutils.SetupTestOSContext(t)()
|
|
|
|
nh, err := nlwrap.NewHandle()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer nh.Close()
|
|
|
|
ip, nw, _ := net.ParseCIDR("192.168.0.24/16")
|
|
nw.IP = ip
|
|
gw := net.ParseIP("192.168.2.254")
|
|
|
|
config := &networkConfiguration{
|
|
BridgeName: DefaultBridgeName,
|
|
DefaultGatewayIPv4: gw,
|
|
}
|
|
|
|
br := &bridgeInterface{bridgeIPv4: nw, nlh: nh}
|
|
|
|
if err := setupGatewayIPv4(config, br); err != nil {
|
|
t.Fatalf("Set Default Gateway failed: %v", err)
|
|
}
|
|
|
|
if !gw.Equal(br.gatewayIPv4) {
|
|
t.Fatalf("Set Default Gateway failed. Expected %v, Found %v", gw, br.gatewayIPv4)
|
|
}
|
|
}
|