"bytes"
"runtime"
"testing"
+ "time"
)
func TestRawConnReadWrite(t *testing.T) {
t.Fatalf("got %q; want %q", b[:n], data)
}
})
+ t.Run("Deadline", func(t *testing.T) {
+ switch runtime.GOOS {
+ case "windows":
+ t.Skipf("not supported on %s", runtime.GOOS)
+ }
+
+ ln, err := newLocalListener("tcp")
+ if err != nil {
+ t.Fatal(err)
+ }
+ defer ln.Close()
+
+ c, err := Dial(ln.Addr().Network(), ln.Addr().String())
+ if err != nil {
+ t.Fatal(err)
+ }
+ defer c.Close()
+
+ cc, err := c.(*TCPConn).SyscallConn()
+ if err != nil {
+ t.Fatal(err)
+ }
+ var b [1]byte
+
+ c.SetDeadline(noDeadline)
+ if err := c.SetDeadline(time.Now().Add(-1)); err != nil {
+ t.Fatal(err)
+ }
+ if err = writeRawConn(cc, b[:]); err == nil {
+ t.Fatal("Write should fail")
+ }
+ if perr := parseWriteError(err); perr != nil {
+ t.Error(perr)
+ }
+ if nerr, ok := err.(Error); !ok || !nerr.Timeout() {
+ t.Errorf("got %v; want timeout", err)
+ }
+ if _, err = readRawConn(cc, b[:]); err == nil {
+ t.Fatal("Read should fail")
+ }
+ if perr := parseReadError(err); perr != nil {
+ t.Error(perr)
+ }
+ if nerr, ok := err.(Error); !ok || !nerr.Timeout() {
+ t.Errorf("got %v; want timeout", err)
+ }
+
+ c.SetReadDeadline(noDeadline)
+ if err := c.SetReadDeadline(time.Now().Add(-1)); err != nil {
+ t.Fatal(err)
+ }
+ if _, err = readRawConn(cc, b[:]); err == nil {
+ t.Fatal("Read should fail")
+ }
+ if perr := parseReadError(err); perr != nil {
+ t.Error(perr)
+ }
+ if nerr, ok := err.(Error); !ok || !nerr.Timeout() {
+ t.Errorf("got %v; want timeout", err)
+ }
+
+ c.SetWriteDeadline(noDeadline)
+ if err := c.SetWriteDeadline(time.Now().Add(-1)); err != nil {
+ t.Fatal(err)
+ }
+ if err = writeRawConn(cc, b[:]); err == nil {
+ t.Fatal("Write should fail")
+ }
+ if perr := parseWriteError(err); perr != nil {
+ t.Error(perr)
+ }
+ if nerr, ok := err.(Error); !ok || !nerr.Timeout() {
+ t.Errorf("got %v; want timeout", err)
+ }
+ })
}
func TestRawConnControl(t *testing.T) {