mirror of
https://github.com/golang/sys.git
synced 2026-02-08 11:46:04 +03:00
unix: fix darwin pipe implementation
The raw syscall returned the two pipes whereas the libc call takes a pointer to a location to write the two pipes. When we switched over from raw syscalls to libc calls, this change in behavior was missed. Fixes golang/go#43498 Change-Id: Icee2204dcb8be8fc94be0df106e1ff061cafa446 Reviewed-on: https://go-review.googlesource.com/c/sys/+/281432 Trust: Keith Randall <khr@golang.org> Run-TryBot: Keith Randall <khr@golang.org> TryBot-Result: Go Bot <gobot@golang.org> Reviewed-by: Ian Lance Taylor <iant@golang.org>
This commit is contained in:
@@ -119,13 +119,16 @@ type attrList struct {
|
||||
Forkattr uint32
|
||||
}
|
||||
|
||||
//sysnb pipe() (r int, w int, err error)
|
||||
//sysnb pipe(p *[2]int32) (err error)
|
||||
|
||||
func Pipe(p []int) (err error) {
|
||||
if len(p) != 2 {
|
||||
return EINVAL
|
||||
}
|
||||
p[0], p[1], err = pipe()
|
||||
var x [2]int32
|
||||
err = pipe(&x)
|
||||
p[0] = int(x[0])
|
||||
p[1] = int(x[1])
|
||||
return
|
||||
}
|
||||
|
||||
|
||||
@@ -896,3 +896,39 @@ func chtmpdir(t *testing.T) func() {
|
||||
os.RemoveAll(d)
|
||||
}
|
||||
}
|
||||
|
||||
func TestPipe(t *testing.T) {
|
||||
const s = "hello"
|
||||
var pipes [2]int
|
||||
unix.Pipe(pipes[:])
|
||||
r := pipes[0]
|
||||
w := pipes[1]
|
||||
go func() {
|
||||
n, err := unix.Write(w, []byte(s))
|
||||
if err != nil {
|
||||
t.Fatalf("bad write: %s\n", err)
|
||||
}
|
||||
if n != len(s) {
|
||||
t.Fatalf("bad write count: %d\n", n)
|
||||
}
|
||||
err = unix.Close(w)
|
||||
if err != nil {
|
||||
t.Fatalf("bad close: %s\n", err)
|
||||
}
|
||||
}()
|
||||
var buf [10 + len(s)]byte
|
||||
n, err := unix.Read(r, buf[:])
|
||||
if err != nil {
|
||||
t.Fatalf("bad read: %s\n", err)
|
||||
}
|
||||
if n != len(s) {
|
||||
t.Fatalf("bad read count: %d\n", n)
|
||||
}
|
||||
if string(buf[:n]) != s {
|
||||
t.Fatalf("bad contents: %s\n", string(buf[:n]))
|
||||
}
|
||||
err = unix.Close(r)
|
||||
if err != nil {
|
||||
t.Fatalf("bad close: %s\n", err)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -462,10 +462,8 @@ func libc_munlockall_trampoline()
|
||||
|
||||
// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
|
||||
|
||||
func pipe() (r int, w int, err error) {
|
||||
r0, r1, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), 0, 0, 0)
|
||||
r = int(r0)
|
||||
w = int(r1)
|
||||
func pipe(p *[2]int32) (err error) {
|
||||
_, _, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), uintptr(unsafe.Pointer(p)), 0, 0)
|
||||
if e1 != 0 {
|
||||
err = errnoErr(e1)
|
||||
}
|
||||
|
||||
@@ -462,10 +462,8 @@ func libc_munlockall_trampoline()
|
||||
|
||||
// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
|
||||
|
||||
func pipe() (r int, w int, err error) {
|
||||
r0, r1, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), 0, 0, 0)
|
||||
r = int(r0)
|
||||
w = int(r1)
|
||||
func pipe(p *[2]int32) (err error) {
|
||||
_, _, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), uintptr(unsafe.Pointer(p)), 0, 0)
|
||||
if e1 != 0 {
|
||||
err = errnoErr(e1)
|
||||
}
|
||||
|
||||
@@ -462,10 +462,8 @@ func libc_munlockall_trampoline()
|
||||
|
||||
// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
|
||||
|
||||
func pipe() (r int, w int, err error) {
|
||||
r0, r1, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), 0, 0, 0)
|
||||
r = int(r0)
|
||||
w = int(r1)
|
||||
func pipe(p *[2]int32) (err error) {
|
||||
_, _, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), uintptr(unsafe.Pointer(p)), 0, 0)
|
||||
if e1 != 0 {
|
||||
err = errnoErr(e1)
|
||||
}
|
||||
|
||||
@@ -462,10 +462,8 @@ func libc_munlockall_trampoline()
|
||||
|
||||
// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
|
||||
|
||||
func pipe() (r int, w int, err error) {
|
||||
r0, r1, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), 0, 0, 0)
|
||||
r = int(r0)
|
||||
w = int(r1)
|
||||
func pipe(p *[2]int32) (err error) {
|
||||
_, _, e1 := syscall_rawSyscall(funcPC(libc_pipe_trampoline), uintptr(unsafe.Pointer(p)), 0, 0)
|
||||
if e1 != 0 {
|
||||
err = errnoErr(e1)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user