// 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. package net import ( "internal/testenv" "os" "runtime" "testing" "time" ) // 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 TestTCPListenerSpecificMethods(t *testing.T) { switch runtime.GOOS { case "plan9": t.Skipf("not supported on %s", runtime.GOOS) } la, err := ResolveTCPAddr("tcp4", "127.0.0.1:0") if err != nil { t.Fatal(err) } ln, err := ListenTCP("tcp4", la) if err != nil { t.Fatal(err) } defer ln.Close() ln.Addr() mustSetDeadline(t, ln.SetDeadline, 30*time.Nanosecond) if c, err := ln.Accept(); err != nil { if !err.(Error).Timeout() { t.Fatal(err) } } else { c.Close() } if c, err := ln.AcceptTCP(); err != nil { if !err.(Error).Timeout() { t.Fatal(err) } } else { c.Close() } if f, err := ln.File(); err != nil { condFatalf(t, "file+net", "%v", err) } else { f.Close() } } func TestTCPConnSpecificMethods(t *testing.T) { la, err := ResolveTCPAddr("tcp4", "127.0.0.1:0") if err != nil { t.Fatal(err) } ln, err := ListenTCP("tcp4", la) if err != nil { t.Fatal(err) } ch := make(chan error, 1) handler := func(ls *localServer, ln Listener) { ls.transponder(ls.Listener, ch) } ls := (&streamListener{Listener: ln}).newLocalServer() defer ls.teardown() if err := ls.buildup(handler); err != nil { t.Fatal(err) } ra, err := ResolveTCPAddr("tcp4", ls.Listener.Addr().String()) if err != nil { t.Fatal(err) } c, err := DialTCP("tcp4", nil, ra) if err != nil { t.Fatal(err) } defer c.Close() c.SetKeepAlive(false) c.SetKeepAlivePeriod(3 * time.Second) c.SetLinger(0) c.SetNoDelay(false) c.LocalAddr() c.RemoteAddr() c.SetDeadline(time.Now().Add(someTimeout)) c.SetReadDeadline(time.Now().Add(someTimeout)) c.SetWriteDeadline(time.Now().Add(someTimeout)) if _, err := c.Write([]byte("TCPCONN TEST")); err != nil { t.Fatal(err) } rb := make([]byte, 128) if _, err := c.Read(rb); err != nil { t.Fatal(err) } for err := range ch { t.Error(err) } } func TestUDPConnSpecificMethods(t *testing.T) { la, err := ResolveUDPAddr("udp4", "127.0.0.1:0") if err != nil { t.Fatal(err) } c, err := ListenUDP("udp4", la) if err != nil { t.Fatal(err) } defer c.Close() c.LocalAddr() c.RemoteAddr() c.SetDeadline(time.Now().Add(someTimeout)) c.SetReadDeadline(time.Now().Add(someTimeout)) c.SetWriteDeadline(time.Now().Add(someTimeout)) c.SetReadBuffer(2048) c.SetWriteBuffer(2048) wb := []byte("UDPCONN TEST") rb := make([]byte, 128) if _, err := c.WriteToUDP(wb, c.LocalAddr().(*UDPAddr)); err != nil { t.Fatal(err) } if _, _, err := c.ReadFromUDP(rb); err != nil { t.Fatal(err) } if _, _, err := c.WriteMsgUDP(wb, nil, c.LocalAddr().(*UDPAddr)); err != nil { condFatalf(t, c.LocalAddr().Network(), "%v", err) } if _, _, _, _, err := c.ReadMsgUDP(rb, nil); err != nil { condFatalf(t, c.LocalAddr().Network(), "%v", err) } if f, err := c.File(); err != nil { condFatalf(t, "file+net", "%v", err) } else { f.Close() } defer func() { if p := recover(); p != nil { t.Fatalf("panicked: %v", p) } }() c.WriteToUDP(wb, nil) c.WriteMsgUDP(wb, nil, nil) } func TestIPConnSpecificMethods(t *testing.T) { if !testableNetwork("ip4") { t.Skip("skipping: ip4 not supported") } la, err := ResolveIPAddr("ip4", "127.0.0.1") if err != nil { t.Fatal(err) } c, err := ListenIP("ip4:icmp", la) if testenv.SyscallIsNotSupported(err) { // May be inside a container that disallows creating a socket or // not running as root. t.Skipf("skipping: %v", err) } else if err != nil { t.Fatal(err) } defer c.Close() c.LocalAddr() c.RemoteAddr() c.SetDeadline(time.Now().Add(someTimeout)) c.SetReadDeadline(time.Now().Add(someTimeout)) c.SetWriteDeadline(time.Now().Add(someTimeout)) c.SetReadBuffer(2048) c.SetWriteBuffer(2048) if f, err := c.File(); err != nil { condFatalf(t, "file+net", "%v", err) } else { f.Close() } defer func() { if p := recover(); p != nil { t.Fatalf("panicked: %v", p) } }() wb := []byte("IPCONN TEST") c.WriteToIP(wb, nil) c.WriteMsgIP(wb, nil, nil) } func TestUnixListenerSpecificMethods(t *testing.T) { if !testableNetwork("unix") { t.Skip("unix test") } addr := testUnixAddr(t) la, err := ResolveUnixAddr("unix", addr) if err != nil { t.Fatal(err) } ln, err := ListenUnix("unix", la) if err != nil { t.Fatal(err) } defer ln.Close() defer os.Remove(addr) ln.Addr() mustSetDeadline(t, ln.SetDeadline, 30*time.Nanosecond) if c, err := ln.Accept(); err != nil { if !err.(Error).Timeout() { t.Fatal(err) } } else { c.Close() } if c, err := ln.AcceptUnix(); err != nil { if !err.(Error).Timeout() { t.Fatal(err) } } else { c.Close() } if f, err := ln.File(); err != nil { condFatalf(t, "file+net", "%v", err) } else { f.Close() } } func TestUnixConnSpecificMethods(t *testing.T) { if !testableNetwork("unixgram") { t.Skip("unixgram test") } addr1, addr2, addr3 := testUnixAddr(t), testUnixAddr(t), testUnixAddr(t) a1, err := ResolveUnixAddr("unixgram", addr1) if err != nil { t.Fatal(err) } c1, err := DialUnix("unixgram", a1, nil) if err != nil { t.Fatal(err) } defer c1.Close() defer os.Remove(addr1) c1.LocalAddr() c1.RemoteAddr() c1.SetDeadline(time.Now().Add(someTimeout)) c1.SetReadDeadline(time.Now().Add(someTimeout)) c1.SetWriteDeadline(time.Now().Add(someTimeout)) c1.SetReadBuffer(2048) c1.SetWriteBuffer(2048) a2, err := ResolveUnixAddr("unixgram", addr2) if err != nil { t.Fatal(err) } c2, err := DialUnix("unixgram", a2, nil) if err != nil { t.Fatal(err) } defer c2.Close() defer os.Remove(addr2) c2.LocalAddr() c2.RemoteAddr() c2.SetDeadline(time.Now().Add(someTimeout)) c2.SetReadDeadline(time.Now().Add(someTimeout)) c2.SetWriteDeadline(time.Now().Add(someTimeout)) c2.SetReadBuffer(2048) c2.SetWriteBuffer(2048) a3, err := ResolveUnixAddr("unixgram", addr3) if err != nil { t.Fatal(err) } c3, err := ListenUnixgram("unixgram", a3) if err != nil { t.Fatal(err) } defer c3.Close() defer os.Remove(addr3) c3.LocalAddr() c3.RemoteAddr() c3.SetDeadline(time.Now().Add(someTimeout)) c3.SetReadDeadline(time.Now().Add(someTimeout)) c3.SetWriteDeadline(time.Now().Add(someTimeout)) c3.SetReadBuffer(2048) c3.SetWriteBuffer(2048) wb := []byte("UNIXCONN TEST") rb1 := make([]byte, 128) rb2 := make([]byte, 128) rb3 := make([]byte, 128) if _, _, err := c1.WriteMsgUnix(wb, nil, a2); err != nil { t.Fatal(err) } if _, _, _, _, err := c2.ReadMsgUnix(rb2, nil); err != nil { t.Fatal(err) } if _, err := c2.WriteToUnix(wb, a1); err != nil { t.Fatal(err) } if _, _, err := c1.ReadFromUnix(rb1); err != nil { t.Fatal(err) } if _, err := c3.WriteToUnix(wb, a1); err != nil { t.Fatal(err) } if _, _, err := c1.ReadFromUnix(rb1); err != nil { t.Fatal(err) } if _, err := c2.WriteToUnix(wb, a3); err != nil { t.Fatal(err) } if _, _, err := c3.ReadFromUnix(rb3); err != nil { t.Fatal(err) } if f, err := c1.File(); err != nil { condFatalf(t, "file+net", "%v", err) } else { f.Close() } defer func() { if p := recover(); p != nil { t.Fatalf("panicked: %v", p) } }() c1.WriteToUnix(wb, nil) c1.WriteMsgUnix(wb, nil, nil) c3.WriteToUnix(wb, nil) c3.WriteMsgUnix(wb, nil, nil) }