| Server IP : 153.92.12.72 / Your IP : 216.73.216.217 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/golang/1.22.0/src/net/ |
Upload File : |
// Copyright 2021 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"
"os"
"syscall"
"testing"
"time"
)
func TestUnixConnReadMsgUnixSCMRightsCloseOnExec(t *testing.T) {
if !testableNetwork("unix") {
t.Skip("not unix system")
}
scmFile, err := os.Open(os.DevNull)
if err != nil {
t.Fatalf("file open: %v", err)
}
defer scmFile.Close()
rights := syscall.UnixRights(int(scmFile.Fd()))
fds, err := syscall.Socketpair(syscall.AF_LOCAL, syscall.SOCK_STREAM, 0)
if err != nil {
t.Fatalf("Socketpair: %v", err)
}
writeFile := os.NewFile(uintptr(fds[0]), "write-socket")
defer writeFile.Close()
readFile := os.NewFile(uintptr(fds[1]), "read-socket")
defer readFile.Close()
cw, err := FileConn(writeFile)
if err != nil {
t.Fatalf("FileConn: %v", err)
}
defer cw.Close()
cr, err := FileConn(readFile)
if err != nil {
t.Fatalf("FileConn: %v", err)
}
defer cr.Close()
ucw, ok := cw.(*UnixConn)
if !ok {
t.Fatalf("got %T; want UnixConn", cw)
}
ucr, ok := cr.(*UnixConn)
if !ok {
t.Fatalf("got %T; want UnixConn", cr)
}
oob := make([]byte, syscall.CmsgSpace(4))
err = ucw.SetWriteDeadline(time.Now().Add(5 * time.Second))
if err != nil {
t.Fatalf("Can't set unix connection timeout: %v", err)
}
_, _, err = ucw.WriteMsgUnix(nil, rights, nil)
if err != nil {
t.Fatalf("UnixConn readMsg: %v", err)
}
err = ucr.SetReadDeadline(time.Now().Add(5 * time.Second))
if err != nil {
t.Fatalf("Can't set unix connection timeout: %v", err)
}
_, oobn, _, _, err := ucr.ReadMsgUnix(nil, oob)
if err != nil {
t.Fatalf("UnixConn readMsg: %v", err)
}
scms, err := syscall.ParseSocketControlMessage(oob[:oobn])
if err != nil {
t.Fatalf("ParseSocketControlMessage: %v", err)
}
if len(scms) != 1 {
t.Fatalf("got scms = %#v; expected 1 SocketControlMessage", scms)
}
scm := scms[0]
gotFDs, err := syscall.ParseUnixRights(&scm)
if err != nil {
t.Fatalf("syscall.ParseUnixRights: %v", err)
}
if len(gotFDs) != 1 {
t.Fatalf("got FDs %#v: wanted only 1 fd", gotFDs)
}
defer func() {
if err := syscall.Close(gotFDs[0]); err != nil {
t.Fatalf("fail to close gotFDs: %v", err)
}
}()
flags, err := unix.Fcntl(gotFDs[0], syscall.F_GETFD, 0)
if err != nil {
t.Fatalf("Can't get flags of fd:%#v, with err:%v", gotFDs[0], err)
}
if flags&syscall.FD_CLOEXEC == 0 {
t.Fatalf("got flags %#x, want %#x (FD_CLOEXEC) set", flags, syscall.FD_CLOEXEC)
}
}