123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- // Copyright 2012 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.
- // This file implements API tests across platforms and will never have a build
- // tag.
- //go:build !js
- package net
- import (
- "os"
- "testing"
- )
- // The full stack test cases for IPConn have been moved to the
- // following:
- // golang.org/x/net/ipv4
- // golang.org/x/net/ipv6
- // golang.org/x/net/icmp
- func packetConnTestData(t *testing.T, network string) ([]byte, func()) {
- if !testableNetwork(network) {
- return nil, func() { t.Logf("skipping %s test", network) }
- }
- return []byte("PACKETCONN TEST"), nil
- }
- func TestPacketConn(t *testing.T) {
- var packetConnTests = []struct {
- net string
- addr1 string
- addr2 string
- }{
- {"udp", "127.0.0.1:0", "127.0.0.1:0"},
- {"unixgram", testUnixAddr(t), testUnixAddr(t)},
- }
- closer := func(c PacketConn, net, addr1, addr2 string) {
- c.Close()
- switch net {
- case "unixgram":
- os.Remove(addr1)
- os.Remove(addr2)
- }
- }
- for _, tt := range packetConnTests {
- wb, skipOrFatalFn := packetConnTestData(t, tt.net)
- if skipOrFatalFn != nil {
- skipOrFatalFn()
- continue
- }
- c1, err := ListenPacket(tt.net, tt.addr1)
- if err != nil {
- t.Fatal(err)
- }
- defer closer(c1, tt.net, tt.addr1, tt.addr2)
- c1.LocalAddr()
- c2, err := ListenPacket(tt.net, tt.addr2)
- if err != nil {
- t.Fatal(err)
- }
- defer closer(c2, tt.net, tt.addr1, tt.addr2)
- c2.LocalAddr()
- rb2 := make([]byte, 128)
- if _, err := c1.WriteTo(wb, c2.LocalAddr()); err != nil {
- t.Fatal(err)
- }
- if _, _, err := c2.ReadFrom(rb2); err != nil {
- t.Fatal(err)
- }
- if _, err := c2.WriteTo(wb, c1.LocalAddr()); err != nil {
- t.Fatal(err)
- }
- rb1 := make([]byte, 128)
- if _, _, err := c1.ReadFrom(rb1); err != nil {
- t.Fatal(err)
- }
- }
- }
- func TestConnAndPacketConn(t *testing.T) {
- var packetConnTests = []struct {
- net string
- addr1 string
- addr2 string
- }{
- {"udp", "127.0.0.1:0", "127.0.0.1:0"},
- {"unixgram", testUnixAddr(t), testUnixAddr(t)},
- }
- closer := func(c PacketConn, net, addr1, addr2 string) {
- c.Close()
- switch net {
- case "unixgram":
- os.Remove(addr1)
- os.Remove(addr2)
- }
- }
- for _, tt := range packetConnTests {
- var wb []byte
- wb, skipOrFatalFn := packetConnTestData(t, tt.net)
- if skipOrFatalFn != nil {
- skipOrFatalFn()
- continue
- }
- c1, err := ListenPacket(tt.net, tt.addr1)
- if err != nil {
- t.Fatal(err)
- }
- defer closer(c1, tt.net, tt.addr1, tt.addr2)
- c1.LocalAddr()
- c2, err := Dial(tt.net, c1.LocalAddr().String())
- if err != nil {
- t.Fatal(err)
- }
- defer c2.Close()
- c2.LocalAddr()
- c2.RemoteAddr()
- if _, err := c2.Write(wb); err != nil {
- t.Fatal(err)
- }
- rb1 := make([]byte, 128)
- if _, _, err := c1.ReadFrom(rb1); err != nil {
- t.Fatal(err)
- }
- var dst Addr
- switch tt.net {
- case "unixgram":
- continue
- default:
- dst = c2.LocalAddr()
- }
- if _, err := c1.WriteTo(wb, dst); err != nil {
- t.Fatal(err)
- }
- rb2 := make([]byte, 128)
- if _, err := c2.Read(rb2); err != nil {
- t.Fatal(err)
- }
- }
- }
|