- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for closeWrite (0.44 sec)
-
src/net/fd_js.go
func (fd *netFD) closeRead() error { if fd.fakeNetFD != nil { return fd.fakeNetFD.closeRead() } return os.NewSyscallError("closeRead", syscall.ENOTSUP) } func (fd *netFD) closeWrite() error { if fd.fakeNetFD != nil { return fd.fakeNetFD.closeWrite() } return os.NewSyscallError("closeRead", syscall.ENOTSUP)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 627 bytes - Viewed (0) -
src/net/fd_wasip1.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 496 bytes - Viewed (0) -
pkg/hbone/util.go
// read is already closed - we need to close out _ = closeWriter(dst) return } } } // CloseWriter is one of possible interfaces implemented by Out to send a FIN, without closing // the input. Some writers only do this when Close is called. type CloseWriter interface { CloseWrite() error } func closeWriter(dst io.Writer) error { if cw, ok := dst.(CloseWriter); ok { return cw.CloseWrite() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0) -
src/net/write_unix_test.go
// Possibility raised in the discussion of https://golang.org/cl/71973. func TestEndlessWrite(t *testing.T) { t.Parallel() c := make(chan bool) server := func(cs *TCPConn) error { cs.CloseWrite() <-c return nil } client := func(ss *TCPConn) error { // Tell the server to return when we return. defer close(c) // Loop writing to the server. The server is not reading
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.6K bytes - Viewed (0) -
src/runtime/internal/wasitest/testdata/tcpecho.go
defer c.Close() var buf [128]byte n, err := c.Read(buf[:]) if err != nil { return err } if _, err := c.Write(buf[:n]); err != nil { return err } if err := c.(*net.TCPConn).CloseWrite(); err != nil { return err } return c.Close() } func findListener() (net.Listener, error) { // We start looking for pre-opened sockets at fd=3 because 0, 1, and 2
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.4K bytes - Viewed (0) -
build/pause/windows/wincat/wincat.go
wg.Done() }() _, err := io.Copy(os.Stdout, conn) if err != nil { log.Printf("error while copying stream to stdout: %v", err) } }() go func() { defer func() { conn.CloseWrite() wg.Done() }() _, err := io.Copy(conn, os.Stdin) if err != nil { log.Printf("error while copying stream from stdin: %v", err) } }() wg.Wait()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 26 14:37:02 UTC 2020 - 1.7K bytes - Viewed (0) -
src/io/pipe.go
select { case p.wrCh <- b: nw := <-p.rdCh b = b[nw:] n += nw case <-p.done: return n, p.writeCloseError() } } return n, nil } func (p *pipe) closeWrite(err error) error { if err == nil { err = EOF } p.werr.Store(err) p.once.Do(func() { close(p.done) }) return nil } // readCloseError is considered internal to the pipe type.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/net/fd_plan9.go
} return fd.pfd.Write(fd.data.Write, b) } func (fd *netFD) closeRead() error { if !fd.ok() { return syscall.EINVAL } return syscall.EPLAN9 } func (fd *netFD) closeWrite() error { if !fd.ok() { return syscall.EINVAL } return syscall.EPLAN9 } func (fd *netFD) Close() error { if err := fd.pfd.Close(); err != nil { return err } if !fd.ok() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 04 16:01:50 UTC 2018 - 3.6K bytes - Viewed (0) -
src/net/fd_posix.go
err := fd.pfd.Shutdown(how) runtime.KeepAlive(fd) return wrapSyscallError("shutdown", err) } func (fd *netFD) closeRead() error { return fd.shutdown(syscall.SHUT_RD) } func (fd *netFD) closeWrite() error { return fd.shutdown(syscall.SHUT_WR) } func (fd *netFD) Read(p []byte) (n int, err error) { n, err = fd.pfd.Read(p) runtime.KeepAlive(fd) return n, wrapSyscallError(readSyscallName, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 4.3K bytes - Viewed (0) -
src/net/http/export_test.go
// if needed. rstAvoidanceDelay = 1 * time.Nanosecond } // SetRSTAvoidanceDelay sets how long we are willing to wait between calling // CloseWrite on a connection and fully closing the connection. func SetRSTAvoidanceDelay(t *testing.T, d time.Duration) { prevDelay := rstAvoidanceDelay t.Cleanup(func() { rstAvoidanceDelay = prevDelay })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0)