OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	12/01/2022 06:13:58 PM	rwxr-xr-x
📄 addrselect.go	9.44 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 addrselect_test.go	6.22 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_aix.go	582 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_android.go	272 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_bsd.go	353 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_linux.go	642 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_netbsd.go	276 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_openbsd.go	276 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_resnew.go	590 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_resold.go	579 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_socknew.go	753 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_sockold.go	852 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_solaris.go	343 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_stub.go	1.03 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_unix.go	9.49 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_unix_test.go	1.84 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 cgo_windows.go	402 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 conf.go	9.65 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 conf_netcgo.go	370 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 conf_test.go	9.7 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 conn_test.go	1.73 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dial.go	22.73 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dial_test.go	26.1 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dial_unix_test.go	2.77 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsclient.go	5.57 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsclient_test.go	1.51 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsclient_unix.go	22.72 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsclient_unix_test.go	57.08 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsconfig.go	1.61 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsconfig_unix.go	4.01 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsconfig_unix_test.go	6.69 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsconfig_windows.go	1.42 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 dnsname_test.go	1.98 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_plan9.go	224 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_plan9_test.go	476 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_posix.go	542 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_posix_test.go	981 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_test.go	19.72 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_unix.go	372 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_unix_test.go	762 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_windows.go	355 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 error_windows_test.go	796 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 example_test.go	8.45 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 external_test.go	4.07 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 fcntl_libc_test.go	374 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 fcntl_syscall_test.go	496 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 fd_plan9.go	3.56 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 fd_posix.go	4.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 fd_unix.go	5.37 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 fd_windows.go	4.62 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 file.go	1.69 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 file_plan9.go	2.68 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 file_stub.go	489 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 file_test.go	6.38 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 file_unix.go	2.46 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 file_windows.go	521 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 hook.go	628 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 hook_plan9.go	283 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 hook_unix.go	690 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 hook_windows.go	875 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 hosts.go	3.02 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 hosts_test.go	4.58 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 http	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 interface.go	7.17 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_aix.go	4.4 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_bsd.go	2.76 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_bsd_test.go	1.44 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_bsdvar.go	718 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_darwin.go	1.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_freebsd.go	1.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_linux.go	6.9 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_linux_test.go	3.65 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_plan9.go	4.68 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_solaris.go	2.07 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_stub.go	812 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_test.go	9.67 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_unix_test.go	4.73 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 interface_windows.go	5.41 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 internal	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 ip.go	17.72 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 ip_test.go	25.33 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 iprawsock.go	7.08 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 iprawsock_plan9.go	874 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 iprawsock_posix.go	3.41 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 iprawsock_test.go	5.62 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 ipsock.go	8.97 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 ipsock_plan9.go	7.5 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 ipsock_plan9_test.go	645 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 ipsock_posix.go	7.66 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 ipsock_test.go	6.81 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 listen_test.go	20.51 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup.go	27.82 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_fake.go	1.64 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_plan9.go	8.86 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_test.go	35.13 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_unix.go	4.46 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_windows.go	12.53 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 lookup_windows_test.go	8.5 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 mac.go	1.88 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 mac_test.go	3.26 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 mail	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 main_cloexec_test.go	693 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_conf_test.go	922 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_noconf_test.go	505 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_plan9_test.go	392 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_posix_test.go	1.38 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_test.go	7.08 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_unix_test.go	1.19 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 main_windows_test.go	1.08 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 mockserver_test.go	10.79 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 net.go	23.25 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 net_fake.go	6.59 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 net_test.go	13.88 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 net_windows_test.go	16.28 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 netgo.go	427 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 netgo_unix_test.go	656 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📁 netip	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 nss.go	3.64 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 nss_test.go	3.35 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 packetconn_test.go	3.03 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 parse.go	7.06 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 parse_test.go	1.46 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 pipe.go	5.43 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 pipe_test.go	1.2 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 platform_test.go	4.57 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 port.go	1.46 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 port_test.go	1.34 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 port_unix.go	1.24 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 protoconn_test.go	7.19 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 rawconn.go	1.89 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 rawconn_stub_test.go	631 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 rawconn_test.go	4.32 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 rawconn_unix_test.go	2.96 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 rawconn_windows_test.go	3.12 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 resolverdialfunc_test.go	8.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 rpc	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 sendfile_linux.go	1.1 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sendfile_stub.go	344 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sendfile_test.go	6.72 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sendfile_unix_alt.go	2.01 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sendfile_windows.go	1.02 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 server_test.go	11.01 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 smtp	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 sock_bsd.go	918 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_cloexec.go	741 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_linux.go	1.53 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_linux_test.go	545 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_plan9.go	262 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_posix.go	6.78 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_stub.go	390 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sock_windows.go	1.16 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockaddr_posix.go	914 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_aix.go	1.43 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_bsd.go	2.21 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_linux.go	1.25 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_plan9.go	406 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_posix.go	2.62 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_solaris.go	1.25 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_stub.go	742 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockopt_windows.go	1.51 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockoptip_bsdvar.go	867 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockoptip_linux.go	735 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockoptip_posix.go	1.38 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockoptip_stub.go	767 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 sockoptip_windows.go	819 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 splice_linux.go	1.09 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 splice_stub.go	287 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 splice_test.go	10.05 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 sys_cloexec.go	962 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsock.go	10.61 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsock_plan9.go	2.21 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsock_posix.go	5.31 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsock_test.go	17.32 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsock_unix_test.go	2.35 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_darwin.go	770 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_dragonfly.go	698 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_openbsd.go	365 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_plan9.go	525 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_posix.go	442 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_solaris.go	1.15 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_stub.go	397 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_unix.go	722 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 tcpsockopt_windows.go	741 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📁 testdata	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📁 textproto	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 timeout_test.go	28.56 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 udpsock.go	11.83 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 udpsock_plan9.go	4.64 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 udpsock_plan9_test.go	1.31 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 udpsock_posix.go	6.78 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 udpsock_test.go	16.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock.go	10.17 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_linux_test.go	2.29 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_plan9.go	1.24 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_posix.go	5.87 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_readmsg_cloexec.go	654 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_readmsg_cmsg_cloexec.go	332 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_readmsg_other.go	275 bytes	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_readmsg_test.go	2.48 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_test.go	10.42 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 unixsock_windows_test.go	2.03 KB	12/01/2022 06:12:59 PM	rw-r--r--
📁 url	-	12/01/2022 06:13:56 PM	rwxr-xr-x
📄 write_unix_test.go	1.61 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 writev_test.go	4.97 KB	12/01/2022 06:12:59 PM	rw-r--r--
📄 writev_unix.go	733 bytes	12/01/2022 06:12:59 PM	rw-r--r--

Editing: pipe.go

// Copyright 2010 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.

package net

import (
	"io"
	"os"
	"sync"
	"time"
)

// pipeDeadline is an abstraction for handling timeouts.
type pipeDeadline struct {
	mu     sync.Mutex // Guards timer and cancel
	timer  *time.Timer
	cancel chan struct{} // Must be non-nil
}

func makePipeDeadline() pipeDeadline {
	return pipeDeadline{cancel: make(chan struct{})}
}

// set sets the point in time when the deadline will time out.
// A timeout event is signaled by closing the channel returned by waiter.
// Once a timeout has occurred, the deadline can be refreshed by specifying a
// t value in the future.
//
// A zero value for t prevents timeout.
func (d *pipeDeadline) set(t time.Time) {
	d.mu.Lock()
	defer d.mu.Unlock()

if d.timer != nil && !d.timer.Stop() {
		<-d.cancel // Wait for the timer callback to finish and close cancel
	}
	d.timer = nil

// Time is zero, then there is no deadline.
	closed := isClosedChan(d.cancel)
	if t.IsZero() {
		if closed {
			d.cancel = make(chan struct{})
		}
		return
	}

// Time in the future, setup a timer to cancel in the future.
	if dur := time.Until(t); dur > 0 {
		if closed {
			d.cancel = make(chan struct{})
		}
		d.timer = time.AfterFunc(dur, func() {
			close(d.cancel)
		})
		return
	}

// Time in the past, so close immediately.
	if !closed {
		close(d.cancel)
	}
}

// wait returns a channel that is closed when the deadline is exceeded.
func (d *pipeDeadline) wait() chan struct{} {
	d.mu.Lock()
	defer d.mu.Unlock()
	return d.cancel
}

func isClosedChan(c <-chan struct{}) bool {
	select {
	case <-c:
		return true
	default:
		return false
	}
}

type pipeAddr struct{}

func (pipeAddr) Network() string { return "pipe" }
func (pipeAddr) String() string  { return "pipe" }

type pipe struct {
	wrMu sync.Mutex // Serialize Write operations

// Used by local Read to interact with remote Write.
	// Successful receive on rdRx is always followed by send on rdTx.
	rdRx <-chan []byte
	rdTx chan<- int

// Used by local Write to interact with remote Read.
	// Successful send on wrTx is always followed by receive on wrRx.
	wrTx chan<- []byte
	wrRx <-chan int

once       sync.Once // Protects closing localDone
	localDone  chan struct{}
	remoteDone <-chan struct{}

readDeadline  pipeDeadline
	writeDeadline pipeDeadline
}

// Pipe creates a synchronous, in-memory, full duplex
// network connection; both ends implement the Conn interface.
// Reads on one end are matched with writes on the other,
// copying data directly between the two; there is no internal
// buffering.
func Pipe() (Conn, Conn) {
	cb1 := make(chan []byte)
	cb2 := make(chan []byte)
	cn1 := make(chan int)
	cn2 := make(chan int)
	done1 := make(chan struct{})
	done2 := make(chan struct{})

p1 := &pipe{
		rdRx: cb1, rdTx: cn1,
		wrTx: cb2, wrRx: cn2,
		localDone: done1, remoteDone: done2,
		readDeadline:  makePipeDeadline(),
		writeDeadline: makePipeDeadline(),
	}
	p2 := &pipe{
		rdRx: cb2, rdTx: cn2,
		wrTx: cb1, wrRx: cn1,
		localDone: done2, remoteDone: done1,
		readDeadline:  makePipeDeadline(),
		writeDeadline: makePipeDeadline(),
	}
	return p1, p2
}

func (*pipe) LocalAddr() Addr  { return pipeAddr{} }
func (*pipe) RemoteAddr() Addr { return pipeAddr{} }

func (p *pipe) Read(b []byte) (int, error) {
	n, err := p.read(b)
	if err != nil && err != io.EOF && err != io.ErrClosedPipe {
		err = &OpError{Op: "read", Net: "pipe", Err: err}
	}
	return n, err
}

func (p *pipe) read(b []byte) (n int, err error) {
	switch {
	case isClosedChan(p.localDone):
		return 0, io.ErrClosedPipe
	case isClosedChan(p.remoteDone):
		return 0, io.EOF
	case isClosedChan(p.readDeadline.wait()):
		return 0, os.ErrDeadlineExceeded
	}

select {
	case bw := <-p.rdRx:
		nr := copy(b, bw)
		p.rdTx <- nr
		return nr, nil
	case <-p.localDone:
		return 0, io.ErrClosedPipe
	case <-p.remoteDone:
		return 0, io.EOF
	case <-p.readDeadline.wait():
		return 0, os.ErrDeadlineExceeded
	}
}

func (p *pipe) Write(b []byte) (int, error) {
	n, err := p.write(b)
	if err != nil && err != io.ErrClosedPipe {
		err = &OpError{Op: "write", Net: "pipe", Err: err}
	}
	return n, err
}

func (p *pipe) write(b []byte) (n int, err error) {
	switch {
	case isClosedChan(p.localDone):
		return 0, io.ErrClosedPipe
	case isClosedChan(p.remoteDone):
		return 0, io.ErrClosedPipe
	case isClosedChan(p.writeDeadline.wait()):
		return 0, os.ErrDeadlineExceeded
	}

p.wrMu.Lock() // Ensure entirety of b is written together
	defer p.wrMu.Unlock()
	for once := true; once || len(b) > 0; once = false {
		select {
		case p.wrTx <- b:
			nw := <-p.wrRx
			b = b[nw:]
			n += nw
		case <-p.localDone:
			return n, io.ErrClosedPipe
		case <-p.remoteDone:
			return n, io.ErrClosedPipe
		case <-p.writeDeadline.wait():
			return n, os.ErrDeadlineExceeded
		}
	}
	return n, nil
}

func (p *pipe) SetDeadline(t time.Time) error {
	if isClosedChan(p.localDone) || isClosedChan(p.remoteDone) {
		return io.ErrClosedPipe
	}
	p.readDeadline.set(t)
	p.writeDeadline.set(t)
	return nil
}

func (p *pipe) SetReadDeadline(t time.Time) error {
	if isClosedChan(p.localDone) || isClosedChan(p.remoteDone) {
		return io.ErrClosedPipe
	}
	p.readDeadline.set(t)
	return nil
}

func (p *pipe) SetWriteDeadline(t time.Time) error {
	if isClosedChan(p.localDone) || isClosedChan(p.remoteDone) {
		return io.ErrClosedPipe
	}
	p.writeDeadline.set(t)
	return nil
}

func (p *pipe) Close() error {
	p.once.Do(func() { close(p.localDone) })
	return nil
}