- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for closeWrite (0.3 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/net/net_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K 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) -
src/net/unixsock.go
} return nil } // CloseWrite shuts down the writing side of the Unix domain connection. // Most callers should just use Close. func (c *UnixConn) CloseWrite() error { if !c.ok() { return syscall.EINVAL } if err := c.fd.closeWrite(); err != nil { return &OpError{Op: "close", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.1K 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/crypto/tls/tls_test.go
return fmt.Errorf("Read data = %q; want nothing", data) } if err := srv.CloseWrite(); err != nil { return fmt.Errorf("server CloseWrite: %v", err) } // Wait for clientCloseWrite to finish, so we know we // tested the CloseWrite before we defer the // sconn.Close above, which would also cause the // client to unblock like CloseWrite. <-clientDoneChan return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0)