- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for closerFunc (0.14 sec)
-
src/net/http/transport_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/file_unix.go
poll.CloseFunc(s) return -1, os.NewSyscallError("setnonblock", err) } return s, nil } func newFileFD(f *os.File) (*netFD, error) { s, err := dupSocket(f) if err != nil { return nil, err } family := syscall.AF_UNSPEC sotype, err := syscall.GetsockoptInt(s, syscall.SOL_SOCKET, syscall.SO_TYPE) if err != nil { poll.CloseFunc(s)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/poll/splice_linux_test.go
"sync/atomic" "testing" "time" ) var closeHook atomic.Value // func(fd int) func init() { closeFunc := poll.CloseFunc poll.CloseFunc = func(fd int) (err error) { if v := closeHook.Load(); v != nil { if hook := v.(func(int)); hook != nil { hook(fd) } } return closeFunc(fd) } } func TestSplicePipePool(t *testing.T) { const N = 64 var ( p *poll.SplicePipe
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 2.8K bytes - Viewed (0) -
src/net/sock_cloexec_solaris.go
if err == nil { syscall.CloseOnExec(s) } syscall.ForkLock.RUnlock() if err != nil { return -1, os.NewSyscallError("socket", err) } if err = syscall.SetNonblock(s, true); err != nil { poll.CloseFunc(s) return -1, os.NewSyscallError("setnonblock", err) } return s, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:25 UTC 2024 - 1.4K bytes - Viewed (0) -
src/internal/poll/sock_cloexec_solaris.go
ns, sa, err := AcceptFunc(s) if err == nil { syscall.CloseOnExec(ns) } if err != nil { return -1, nil, "accept", err } if err = syscall.SetNonblock(ns, true); err != nil { CloseFunc(ns) return -1, nil, "setnonblock", err } return ns, sa, "", nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:25 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
return &splicePipe{splicePipeFields: splicePipeFields{rfd: fds[0], wfd: fds[1]}} } // destroyPipe destroys a pipe. func destroyPipe(p *splicePipe) { CloseFunc(p.rfd) CloseFunc(p.wfd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
src/net/ipsock_posix.go
p.ipv4MappedIPv6Enabled = true return } s, err := sysSocket(syscall.AF_INET, syscall.SOCK_STREAM, syscall.IPPROTO_TCP) switch err { case syscall.EAFNOSUPPORT, syscall.EPROTONOSUPPORT: case nil: poll.CloseFunc(s) p.ipv4Enabled = true } var probes = []struct { laddr TCPAddr value int }{ // IPv6 communication capability {laddr: TCPAddr{IP: ParseIP("::1")}, value: 1},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.6K bytes - Viewed (0) -
src/net/fd_windows.go
err = wrapSyscallError(errcall, err) } return nil, err } // Associate our new socket with IOCP. netfd, err := newFD(s, fd.family, fd.sotype, fd.net) if err != nil { poll.CloseFunc(s) return nil, err } if err := netfd.init(); err != nil { fd.Close() return nil, err } // Get local and peer addr out of AcceptEx buffer. var lrsa, rrsa *syscall.RawSockaddrAny
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 16:46:10 UTC 2024 - 6.2K bytes - Viewed (0) -
src/internal/poll/fd_wasip1.go
// If the descriptor is indeed closed, using a loop would race // with some other goroutine opening a new descriptor. // (The Linux kernel guarantees that it is closed on an EINTR error.) return CloseFunc(fd) } // Copy creates a copy of the FD. // // The FD instance points to the same underlying file descriptor. The file // descriptor isn't closed until all FD instances that refer to it have been // closed/destroyed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 20:14:02 UTC 2024 - 6.7K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
type changeImplConn struct { net.Conn writeFunc func([]byte) (int, error) closeFunc func() error } func (w *changeImplConn) Write(p []byte) (n int, err error) { if w.writeFunc != nil { return w.writeFunc(p) } return w.Conn.Write(p) } func (w *changeImplConn) Close() error { if w.closeFunc != nil { return w.closeFunc() } return w.Conn.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0)