mirror of https://go.googlesource.com/go
102 lines
2.1 KiB
Go
102 lines
2.1 KiB
Go
// Copyright 2023 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.
|
|
|
|
//go:build unix
|
|
|
|
package net
|
|
|
|
import (
|
|
"internal/syscall/unix"
|
|
"testing"
|
|
)
|
|
|
|
// For backward compatibility, opening a net.Conn, turning it into an os.File,
|
|
// and calling the Fd method should return a blocking descriptor.
|
|
func TestFileFdBlocks(t *testing.T) {
|
|
if !testableNetwork("unix") {
|
|
t.Skipf("skipping: unix sockets not supported")
|
|
}
|
|
|
|
ls := newLocalServer(t, "unix")
|
|
defer ls.teardown()
|
|
|
|
errc := make(chan error, 1)
|
|
done := make(chan bool)
|
|
handler := func(ls *localServer, ln Listener) {
|
|
server, err := ln.Accept()
|
|
errc <- err
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer server.Close()
|
|
<-done
|
|
}
|
|
if err := ls.buildup(handler); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer close(done)
|
|
|
|
client, err := Dial(ls.Listener.Addr().Network(), ls.Listener.Addr().String())
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer client.Close()
|
|
|
|
if err := <-errc; err != nil {
|
|
t.Fatalf("server error: %v", err)
|
|
}
|
|
|
|
// The socket should be non-blocking.
|
|
rawconn, err := client.(*UnixConn).SyscallConn()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
err = rawconn.Control(func(fd uintptr) {
|
|
nonblock, err := unix.IsNonblock(int(fd))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if !nonblock {
|
|
t.Fatal("unix socket is in blocking mode")
|
|
}
|
|
})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
file, err := client.(*UnixConn).File()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
// At this point the descriptor should still be non-blocking.
|
|
rawconn, err = file.SyscallConn()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
err = rawconn.Control(func(fd uintptr) {
|
|
nonblock, err := unix.IsNonblock(int(fd))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if !nonblock {
|
|
t.Fatal("unix socket as os.File is in blocking mode")
|
|
}
|
|
})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
fd := file.Fd()
|
|
|
|
// Calling Fd should have put the descriptor into blocking mode.
|
|
nonblock, err := unix.IsNonblock(int(fd))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if nonblock {
|
|
t.Error("unix socket through os.File.Fd is non-blocking")
|
|
}
|
|
}
|