| // Copyright 2013 The Go Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style |
| // license that can be found in the LICENSE file. |
| |
| package ipv6_test |
| |
| import ( |
| "bytes" |
| "fmt" |
| "net" |
| "runtime" |
| "strings" |
| "sync" |
| "testing" |
| "time" |
| |
| "golang.org/x/net/internal/iana" |
| "golang.org/x/net/ipv6" |
| "golang.org/x/net/nettest" |
| ) |
| |
| func BenchmarkReadWriteUnicast(b *testing.B) { |
| switch runtime.GOOS { |
| case "fuchsia", "hurd", "js", "nacl", "plan9", "windows": |
| b.Skipf("not supported on %s", runtime.GOOS) |
| } |
| |
| c, err := nettest.NewLocalPacketListener("udp6") |
| if err != nil { |
| b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) |
| } |
| defer c.Close() |
| |
| dst := c.LocalAddr() |
| wb, rb := []byte("HELLO-R-U-THERE"), make([]byte, 128) |
| |
| b.Run("NetUDP", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := c.WriteTo(wb, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, err := c.ReadFrom(rb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| b.Run("IPv6UDP", func(b *testing.B) { |
| p := ipv6.NewPacketConn(c) |
| cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU |
| if err := p.SetControlMessage(cf, true); err != nil { |
| b.Fatal(err) |
| } |
| cm := ipv6.ControlMessage{ |
| TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, |
| HopLimit: 1, |
| } |
| ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) |
| if ifi != nil { |
| cm.IfIndex = ifi.Index |
| } |
| |
| for i := 0; i < b.N; i++ { |
| if _, err := p.WriteTo(wb, &cm, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, _, err := p.ReadFrom(rb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| } |
| |
| func BenchmarkPacketConnReadWriteUnicast(b *testing.B) { |
| switch runtime.GOOS { |
| case "fuchsia", "hurd", "js", "nacl", "plan9", "windows": |
| b.Skipf("not supported on %s", runtime.GOOS) |
| } |
| |
| payload := []byte("HELLO-R-U-THERE") |
| iph := []byte{ |
| 0x69, 0x8b, 0xee, 0xf1, 0xca, 0xfe, 0xff, 0x01, |
| 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x01, 0x00, 0x00, |
| 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, |
| 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x02, 0x00, 0x00, |
| 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, |
| } |
| greh := []byte{0x00, 0x00, 0x86, 0xdd, 0x00, 0x00, 0x00, 0x00} |
| datagram := append(greh, append(iph, payload...)...) |
| bb := make([]byte, 128) |
| cm := ipv6.ControlMessage{ |
| TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, |
| HopLimit: 1, |
| Src: net.IPv6loopback, |
| } |
| ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) |
| if ifi != nil { |
| cm.IfIndex = ifi.Index |
| } |
| |
| b.Run("UDP", func(b *testing.B) { |
| c, err := nettest.NewLocalPacketListener("udp6") |
| if err != nil { |
| b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) |
| } |
| defer c.Close() |
| p := ipv6.NewPacketConn(c) |
| dst := c.LocalAddr() |
| cf := ipv6.FlagHopLimit | ipv6.FlagInterface |
| if err := p.SetControlMessage(cf, true); err != nil { |
| b.Fatal(err) |
| } |
| wms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{payload}, |
| Addr: dst, |
| OOB: cm.Marshal(), |
| }, |
| } |
| rms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{bb}, |
| OOB: ipv6.NewControlMessage(cf), |
| }, |
| } |
| b.Run("Net", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := c.WriteTo(payload, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, err := c.ReadFrom(bb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| b.Run("ToFrom", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := p.WriteTo(payload, &cm, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, _, err := p.ReadFrom(bb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| b.Run("Batch", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := p.WriteBatch(wms, 0); err != nil { |
| b.Fatal(err) |
| } |
| if _, err := p.ReadBatch(rms, 0); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| }) |
| b.Run("IP", func(b *testing.B) { |
| switch runtime.GOOS { |
| case "netbsd": |
| b.Skip("need to configure gre on netbsd") |
| case "openbsd": |
| b.Skip("net.inet.gre.allow=0 by default on openbsd") |
| } |
| |
| c, err := net.ListenPacket(fmt.Sprintf("ip6:%d", iana.ProtocolGRE), "::1") |
| if err != nil { |
| b.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) |
| } |
| defer c.Close() |
| p := ipv6.NewPacketConn(c) |
| dst := c.LocalAddr() |
| cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU |
| if err := p.SetControlMessage(cf, true); err != nil { |
| b.Fatal(err) |
| } |
| wms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{datagram}, |
| Addr: dst, |
| OOB: cm.Marshal(), |
| }, |
| } |
| rms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{bb}, |
| OOB: ipv6.NewControlMessage(cf), |
| }, |
| } |
| b.Run("Net", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := c.WriteTo(datagram, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, err := c.ReadFrom(bb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| b.Run("ToFrom", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := p.WriteTo(datagram, &cm, dst); err != nil { |
| b.Fatal(err) |
| } |
| if _, _, _, err := p.ReadFrom(bb); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| b.Run("Batch", func(b *testing.B) { |
| for i := 0; i < b.N; i++ { |
| if _, err := p.WriteBatch(wms, 0); err != nil { |
| b.Fatal(err) |
| } |
| if _, err := p.ReadBatch(rms, 0); err != nil { |
| b.Fatal(err) |
| } |
| } |
| }) |
| }) |
| } |
| |
| func TestPacketConnConcurrentReadWriteUnicastUDP(t *testing.T) { |
| switch runtime.GOOS { |
| case "fuchsia", "hurd", "js", "nacl", "plan9", "windows": |
| t.Skipf("not supported on %s", runtime.GOOS) |
| } |
| if !nettest.SupportsIPv6() { |
| t.Skip("ipv6 is not supported") |
| } |
| |
| c, err := nettest.NewLocalPacketListener("udp6") |
| if err != nil { |
| t.Fatal(err) |
| } |
| defer c.Close() |
| p := ipv6.NewPacketConn(c) |
| defer p.Close() |
| |
| dst := c.LocalAddr() |
| ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) |
| cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU |
| wb := []byte("HELLO-R-U-THERE") |
| |
| if err := p.SetControlMessage(cf, true); err != nil { // probe before test |
| if protocolNotSupported(err) { |
| t.Skipf("not supported on %s", runtime.GOOS) |
| } |
| t.Fatal(err) |
| } |
| |
| var firstError sync.Once |
| fatalf := func(format string, args ...interface{}) { |
| // On the first error, close the PacketConn to unblock the remaining |
| // goroutines. Suppress any further errors, which may occur simply due to |
| // closing the PacketConn. |
| first := false |
| firstError.Do(func() { |
| first = true |
| p.Close() |
| }) |
| if first { |
| t.Helper() |
| t.Errorf(format, args...) |
| } |
| runtime.Goexit() |
| } |
| |
| var wg sync.WaitGroup |
| reader := func() { |
| defer wg.Done() |
| rb := make([]byte, 128) |
| if n, cm, _, err := p.ReadFrom(rb); err != nil { |
| fatalf("%v", err) |
| } else if !bytes.Equal(rb[:n], wb) { |
| fatalf("got %v; want %v", rb[:n], wb) |
| } else { |
| s := cm.String() |
| if strings.Contains(s, ",") { |
| t.Errorf("should be space-separated values: %s", s) |
| } |
| } |
| } |
| writer := func(toggle bool) { |
| defer wg.Done() |
| cm := ipv6.ControlMessage{ |
| TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, |
| Src: net.IPv6loopback, |
| } |
| if ifi != nil { |
| cm.IfIndex = ifi.Index |
| } |
| if err := p.SetControlMessage(cf, toggle); err != nil { |
| fatalf("%v", err) |
| } |
| |
| backoff := time.Millisecond |
| for { |
| n, err := p.WriteTo(wb, &cm, dst) |
| if err != nil { |
| if n == 0 && isENOBUFS(err) { |
| time.Sleep(backoff) |
| backoff *= 2 |
| continue |
| } |
| fatalf("%v", err) |
| } |
| if n != len(wb) { |
| fatalf("got %d; want %d", n, len(wb)) |
| } |
| break |
| } |
| } |
| |
| const N = 10 |
| wg.Add(N) |
| for i := 0; i < N; i++ { |
| go reader() |
| } |
| wg.Add(2 * N) |
| for i := 0; i < 2*N; i++ { |
| go writer(i%2 != 0) |
| } |
| wg.Add(N) |
| for i := 0; i < N; i++ { |
| go reader() |
| } |
| wg.Wait() |
| } |
| |
| func TestPacketConnConcurrentReadWriteUnicast(t *testing.T) { |
| switch runtime.GOOS { |
| case "fuchsia", "hurd", "js", "nacl", "plan9", "windows": |
| t.Skipf("not supported on %s", runtime.GOOS) |
| } |
| |
| payload := []byte("HELLO-R-U-THERE") |
| iph := []byte{ |
| 0x69, 0x8b, 0xee, 0xf1, 0xca, 0xfe, 0xff, 0x01, |
| 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x01, 0x00, 0x00, |
| 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, |
| 0x20, 0x01, 0x0d, 0xb8, 0x00, 0x02, 0x00, 0x00, |
| 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, |
| } |
| greh := []byte{0x00, 0x00, 0x86, 0xdd, 0x00, 0x00, 0x00, 0x00} |
| datagram := append(greh, append(iph, payload...)...) |
| |
| t.Run("UDP", func(t *testing.T) { |
| c, err := nettest.NewLocalPacketListener("udp6") |
| if err != nil { |
| t.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) |
| } |
| defer c.Close() |
| p := ipv6.NewPacketConn(c) |
| t.Run("ToFrom", func(t *testing.T) { |
| testPacketConnConcurrentReadWriteUnicast(t, p, payload, c.LocalAddr(), false) |
| }) |
| t.Run("Batch", func(t *testing.T) { |
| testPacketConnConcurrentReadWriteUnicast(t, p, payload, c.LocalAddr(), true) |
| }) |
| }) |
| t.Run("IP", func(t *testing.T) { |
| switch runtime.GOOS { |
| case "netbsd": |
| t.Skip("need to configure gre on netbsd") |
| case "openbsd": |
| t.Skip("net.inet.gre.allow=0 by default on openbsd") |
| } |
| |
| c, err := net.ListenPacket(fmt.Sprintf("ip6:%d", iana.ProtocolGRE), "::1") |
| if err != nil { |
| t.Skipf("not supported on %s/%s: %v", runtime.GOOS, runtime.GOARCH, err) |
| } |
| defer c.Close() |
| p := ipv6.NewPacketConn(c) |
| t.Run("ToFrom", func(t *testing.T) { |
| testPacketConnConcurrentReadWriteUnicast(t, p, datagram, c.LocalAddr(), false) |
| }) |
| t.Run("Batch", func(t *testing.T) { |
| testPacketConnConcurrentReadWriteUnicast(t, p, datagram, c.LocalAddr(), true) |
| }) |
| }) |
| } |
| |
| func testPacketConnConcurrentReadWriteUnicast(t *testing.T, p *ipv6.PacketConn, data []byte, dst net.Addr, batch bool) { |
| ifi, _ := nettest.RoutedInterface("ip6", net.FlagUp|net.FlagLoopback) |
| cf := ipv6.FlagTrafficClass | ipv6.FlagHopLimit | ipv6.FlagSrc | ipv6.FlagDst | ipv6.FlagInterface | ipv6.FlagPathMTU |
| |
| if err := p.SetControlMessage(cf, true); err != nil { // probe before test |
| if protocolNotSupported(err) { |
| t.Skipf("not supported on %s", runtime.GOOS) |
| } |
| t.Fatal(err) |
| } |
| |
| var firstError sync.Once |
| fatalf := func(format string, args ...interface{}) { |
| // On the first error, close the PacketConn to unblock the remaining |
| // goroutines. Suppress any further errors, which may occur simply due to |
| // closing the PacketConn. |
| first := false |
| firstError.Do(func() { |
| first = true |
| p.Close() |
| }) |
| if first { |
| t.Helper() |
| t.Errorf(format, args...) |
| } |
| runtime.Goexit() |
| } |
| |
| var wg sync.WaitGroup |
| reader := func() { |
| defer wg.Done() |
| b := make([]byte, 128) |
| n, cm, _, err := p.ReadFrom(b) |
| if err != nil { |
| fatalf("%v", err) |
| } |
| if !bytes.Equal(b[:n], data) { |
| fatalf("got %#v; want %#v", b[:n], data) |
| } |
| s := cm.String() |
| if strings.Contains(s, ",") { |
| fatalf("should be space-separated values: %s", s) |
| } |
| } |
| batchReader := func() { |
| defer wg.Done() |
| ms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{make([]byte, 128)}, |
| OOB: ipv6.NewControlMessage(cf), |
| }, |
| } |
| n, err := p.ReadBatch(ms, 0) |
| if err != nil { |
| fatalf("%v", err) |
| } |
| if n != len(ms) { |
| fatalf("got %d; want %d", n, len(ms)) |
| } |
| var cm ipv6.ControlMessage |
| if err := cm.Parse(ms[0].OOB[:ms[0].NN]); err != nil { |
| fatalf("%v", err) |
| } |
| b := ms[0].Buffers[0][:ms[0].N] |
| if !bytes.Equal(b, data) { |
| fatalf("got %#v; want %#v", b, data) |
| } |
| s := cm.String() |
| if strings.Contains(s, ",") { |
| fatalf("should be space-separated values: %s", s) |
| } |
| } |
| writer := func(toggle bool) { |
| defer wg.Done() |
| cm := ipv6.ControlMessage{ |
| TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, |
| HopLimit: 1, |
| Src: net.IPv6loopback, |
| } |
| if ifi != nil { |
| cm.IfIndex = ifi.Index |
| } |
| if err := p.SetControlMessage(cf, toggle); err != nil { |
| fatalf("%v", err) |
| } |
| |
| backoff := time.Millisecond |
| for { |
| n, err := p.WriteTo(data, &cm, dst) |
| if err != nil { |
| if n == 0 && isENOBUFS(err) { |
| time.Sleep(backoff) |
| backoff *= 2 |
| continue |
| } |
| fatalf("%v", err) |
| } |
| if n != len(data) { |
| fatalf("got %d; want %d", n, len(data)) |
| } |
| break |
| } |
| } |
| batchWriter := func(toggle bool) { |
| defer wg.Done() |
| cm := ipv6.ControlMessage{ |
| TrafficClass: iana.DiffServAF11 | iana.CongestionExperienced, |
| HopLimit: 1, |
| Src: net.IPv6loopback, |
| } |
| if ifi != nil { |
| cm.IfIndex = ifi.Index |
| } |
| if err := p.SetControlMessage(cf, toggle); err != nil { |
| fatalf("%v", err) |
| } |
| ms := []ipv6.Message{ |
| { |
| Buffers: [][]byte{data}, |
| OOB: cm.Marshal(), |
| Addr: dst, |
| }, |
| } |
| |
| backoff := time.Millisecond |
| for { |
| n, err := p.WriteBatch(ms, 0) |
| if err != nil { |
| if n == 0 && isENOBUFS(err) { |
| time.Sleep(backoff) |
| backoff *= 2 |
| continue |
| } |
| fatalf("%v", err) |
| } |
| if n != len(ms) { |
| fatalf("got %d; want %d", n, len(ms)) |
| } |
| if ms[0].N != len(data) { |
| fatalf("got %d; want %d", ms[0].N, len(data)) |
| } |
| break |
| } |
| } |
| |
| const N = 10 |
| wg.Add(N) |
| for i := 0; i < N; i++ { |
| if batch { |
| go batchReader() |
| } else { |
| go reader() |
| } |
| } |
| wg.Add(2 * N) |
| for i := 0; i < 2*N; i++ { |
| if batch { |
| go batchWriter(i%2 != 0) |
| } else { |
| go writer(i%2 != 0) |
| } |
| } |
| wg.Add(N) |
| for i := 0; i < N; i++ { |
| if batch { |
| go batchReader() |
| } else { |
| go reader() |
| } |
| } |
| wg.Wait() |
| } |