Commit 258bf65d authored by Mikio Hara's avatar Mikio Hara

net: relax IP interface address determination on linux

Linux allows to have a peer IP address on IP interface over ethernet
link encapsulation, though it only installs a static route with the peer
address as an on-link nexthop.

Fixes #11338.

Change-Id: Ie2583737e4c7cec39baabb89dd732463d3f10a61
Reviewed-on: https://go-review.googlesource.com/11352Reviewed-by: 's avatarRuss Cox <rsc@golang.org>
parent aea348a3
...@@ -28,10 +28,8 @@ func (ti *testInterface) setBroadcast(suffix int) error { ...@@ -28,10 +28,8 @@ func (ti *testInterface) setBroadcast(suffix int) error {
return nil return nil
} }
func (ti *testInterface) setPointToPoint(suffix int, local, remote string) error { func (ti *testInterface) setPointToPoint(suffix int) error {
ti.name = fmt.Sprintf("gif%d", suffix) ti.name = fmt.Sprintf("gif%d", suffix)
ti.local = local
ti.remote = remote
xname, err := exec.LookPath("ifconfig") xname, err := exec.LookPath("ifconfig")
if err != nil { if err != nil {
return err return err
......
...@@ -176,17 +176,15 @@ func newAddr(ifi *Interface, ifam *syscall.IfAddrmsg, attrs []syscall.NetlinkRou ...@@ -176,17 +176,15 @@ func newAddr(ifi *Interface, ifam *syscall.IfAddrmsg, attrs []syscall.NetlinkRou
var ipPointToPoint bool var ipPointToPoint bool
// Seems like we need to make sure whether the IP interface // Seems like we need to make sure whether the IP interface
// stack consists of IP point-to-point numbered or unnumbered // stack consists of IP point-to-point numbered or unnumbered
// addressing over point-to-point link encapsulation. // addressing.
if ifi.Flags&FlagPointToPoint != 0 { for _, a := range attrs {
for _, a := range attrs { if a.Attr.Type == syscall.IFA_LOCAL {
if a.Attr.Type == syscall.IFA_LOCAL { ipPointToPoint = true
ipPointToPoint = true break
break
}
} }
} }
for _, a := range attrs { for _, a := range attrs {
if ipPointToPoint && a.Attr.Type == syscall.IFA_ADDRESS || !ipPointToPoint && a.Attr.Type == syscall.IFA_LOCAL { if ipPointToPoint && a.Attr.Type == syscall.IFA_ADDRESS {
continue continue
} }
switch ifam.Family { switch ifam.Family {
......
...@@ -20,6 +20,14 @@ func (ti *testInterface) setBroadcast(suffix int) error { ...@@ -20,6 +20,14 @@ func (ti *testInterface) setBroadcast(suffix int) error {
Path: xname, Path: xname,
Args: []string{"ip", "link", "add", ti.name, "type", "dummy"}, Args: []string{"ip", "link", "add", ti.name, "type", "dummy"},
}) })
ti.setupCmds = append(ti.setupCmds, &exec.Cmd{
Path: xname,
Args: []string{"ip", "address", "add", ti.local, "peer", ti.remote, "dev", ti.name},
})
ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{
Path: xname,
Args: []string{"ip", "address", "del", ti.local, "peer", ti.remote, "dev", ti.name},
})
ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{ ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{
Path: xname, Path: xname,
Args: []string{"ip", "link", "delete", ti.name, "type", "dummy"}, Args: []string{"ip", "link", "delete", ti.name, "type", "dummy"},
...@@ -27,29 +35,27 @@ func (ti *testInterface) setBroadcast(suffix int) error { ...@@ -27,29 +35,27 @@ func (ti *testInterface) setBroadcast(suffix int) error {
return nil return nil
} }
func (ti *testInterface) setPointToPoint(suffix int, local, remote string) error { func (ti *testInterface) setPointToPoint(suffix int) error {
ti.name = fmt.Sprintf("gotest%d", suffix) ti.name = fmt.Sprintf("gotest%d", suffix)
ti.local = local
ti.remote = remote
xname, err := exec.LookPath("ip") xname, err := exec.LookPath("ip")
if err != nil { if err != nil {
return err return err
} }
ti.setupCmds = append(ti.setupCmds, &exec.Cmd{ ti.setupCmds = append(ti.setupCmds, &exec.Cmd{
Path: xname, Path: xname,
Args: []string{"ip", "tunnel", "add", ti.name, "mode", "gre", "local", local, "remote", remote}, Args: []string{"ip", "tunnel", "add", ti.name, "mode", "gre", "local", ti.local, "remote", ti.remote},
})
ti.setupCmds = append(ti.setupCmds, &exec.Cmd{
Path: xname,
Args: []string{"ip", "address", "add", ti.local, "peer", ti.remote, "dev", ti.name},
}) })
ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{ ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{
Path: xname, Path: xname,
Args: []string{"ip", "tunnel", "del", ti.name, "mode", "gre", "local", local, "remote", remote}, Args: []string{"ip", "address", "del", ti.local, "peer", ti.remote, "dev", ti.name},
}) })
xname, err = exec.LookPath("ifconfig") ti.teardownCmds = append(ti.teardownCmds, &exec.Cmd{
if err != nil {
return err
}
ti.setupCmds = append(ti.setupCmds, &exec.Cmd{
Path: xname, Path: xname,
Args: []string{"ifconfig", ti.name, "inet", local, "dstaddr", remote}, Args: []string{"ip", "tunnel", "del", ti.name, "mode", "gre", "local", ti.local, "remote", ti.remote},
}) })
return nil return nil
} }
......
...@@ -54,8 +54,8 @@ func TestPointToPointInterface(t *testing.T) { ...@@ -54,8 +54,8 @@ func TestPointToPointInterface(t *testing.T) {
local, remote := "169.254.0.1", "169.254.0.254" local, remote := "169.254.0.1", "169.254.0.254"
ip := ParseIP(remote) ip := ParseIP(remote)
for i := 0; i < 3; i++ { for i := 0; i < 3; i++ {
ti := &testInterface{} ti := &testInterface{local: local, remote: remote}
if err := ti.setPointToPoint(5963+i, local, remote); err != nil { if err := ti.setPointToPoint(5963 + i); err != nil {
t.Skipf("test requries external command: %v", err) t.Skipf("test requries external command: %v", err)
} }
if err := ti.setup(); err != nil { if err := ti.setup(); err != nil {
...@@ -69,17 +69,18 @@ func TestPointToPointInterface(t *testing.T) { ...@@ -69,17 +69,18 @@ func TestPointToPointInterface(t *testing.T) {
t.Fatal(err) t.Fatal(err)
} }
for _, ifi := range ift { for _, ifi := range ift {
if ti.name == ifi.Name { if ti.name != ifi.Name {
ifat, err := ifi.Addrs() continue
if err != nil { }
ifat, err := ifi.Addrs()
if err != nil {
ti.teardown()
t.Fatal(err)
}
for _, ifa := range ifat {
if ip.Equal(ifa.(*IPNet).IP) {
ti.teardown() ti.teardown()
t.Fatal(err) t.Fatalf("got %v", ifa)
}
for _, ifa := range ifat {
if ip.Equal(ifa.(*IPNet).IP) {
ti.teardown()
t.Fatalf("got %v; want %v", ip, local)
}
} }
} }
} }
...@@ -99,12 +100,14 @@ func TestInterfaceArrivalAndDeparture(t *testing.T) { ...@@ -99,12 +100,14 @@ func TestInterfaceArrivalAndDeparture(t *testing.T) {
t.Skip("must be root") t.Skip("must be root")
} }
local, remote := "169.254.0.1", "169.254.0.254"
ip := ParseIP(remote)
for i := 0; i < 3; i++ { for i := 0; i < 3; i++ {
ift1, err := Interfaces() ift1, err := Interfaces()
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
ti := &testInterface{} ti := &testInterface{local: local, remote: remote}
if err := ti.setBroadcast(5682 + i); err != nil { if err := ti.setBroadcast(5682 + i); err != nil {
t.Skipf("test requires external command: %v", err) t.Skipf("test requires external command: %v", err)
} }
...@@ -128,6 +131,22 @@ func TestInterfaceArrivalAndDeparture(t *testing.T) { ...@@ -128,6 +131,22 @@ func TestInterfaceArrivalAndDeparture(t *testing.T) {
ti.teardown() ti.teardown()
t.Fatalf("got %v; want gt %v", len(ift2), len(ift1)) t.Fatalf("got %v; want gt %v", len(ift2), len(ift1))
} }
for _, ifi := range ift2 {
if ti.name != ifi.Name {
continue
}
ifat, err := ifi.Addrs()
if err != nil {
ti.teardown()
t.Fatal(err)
}
for _, ifa := range ifat {
if ip.Equal(ifa.(*IPNet).IP) {
ti.teardown()
t.Fatalf("got %v", ifa)
}
}
}
if err := ti.teardown(); err != nil { if err := ti.teardown(); err != nil {
t.Fatal(err) t.Fatal(err)
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment