- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for closeWrite (0.94 sec)
-
src/net/http/server.go
// // TODO(bcmills): This should arguably be a server configuration parameter, // not a hard-coded value. var rstAvoidanceDelay = 500 * time.Millisecond type closeWriter interface { CloseWrite() error } var _ closeWriter = (*net.TCPConn)(nil) // closeWriteAndWait flushes any outstanding data and sends a FIN packet (if // client is connected via TCP), signaling that we're done. We then
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
internal/ringbuffer/README.md
`TryRead` and `TryWrite` are still available for non-blocking reads and writes. To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()` Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. Any reads or writes will return the error on next call.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"(*Config).Clone", Method, 8}, {"(*Config).DecryptTicket", Method, 21}, {"(*Config).EncryptTicket", Method, 21}, {"(*Config).SetSessionTicketKeys", Method, 5}, {"(*Conn).Close", Method, 0}, {"(*Conn).CloseWrite", Method, 8}, {"(*Conn).ConnectionState", Method, 0}, {"(*Conn).Handshake", Method, 0}, {"(*Conn).HandshakeContext", Method, 17}, {"(*Conn).LocalAddr", Method, 0}, {"(*Conn).NetConn", Method, 18},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0) -
src/net/http/h2_bundle.go
if clientGone { // TODO: could we also get into this state if // the peer does a half close // (e.g. CloseWrite) because they're done // sending frames but they're still wanting // our open replies? Investigate. // TODO: add CloseWrite to crypto/tls.Conn first // so we have a way to test this? I suppose // just for testing we could have a non-TLS mode. return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
// and always returns nil. func (r *RingBuffer) CloseWithError(err error) { if err == nil { err = io.EOF } r.setErr(err, false) } // CloseWriter closes the writer. // Reads will return any remaining bytes and io.EOF. func (r *RingBuffer) CloseWriter() { r.setErr(io.EOF, false) } // Flush waits for the buffer to be empty and fully read.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
} if doSleep && writeRng.Intn(10) == 0 { time.Sleep(time.Duration(writeRng.Intn(maxSleep))) } } if err := rb.Flush(); err != nil { t.Fatalf("flush failed: %v", err) } rb.CloseWriter() } wg.Wait() if !errors.Is(readErr, io.EOF) { t.Fatalf("expect io.EOF but got %v", readErr) } if readBytes != wroteBytes { a, b := readBuf.Bytes(), wroteBuf.Bytes()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
api/go1.txt
pkg net, method (*TCPAddr) Network() string pkg net, method (*TCPAddr) String() string pkg net, method (*TCPConn) Close() error pkg net, method (*TCPConn) CloseRead() error pkg net, method (*TCPConn) CloseWrite() error pkg net, method (*TCPConn) File() (*os.File, error) pkg net, method (*TCPConn) LocalAddr() Addr pkg net, method (*TCPConn) Read([]uint8) (int, error) pkg net, method (*TCPConn) ReadFrom(io.Reader) (int64, error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
api/go1.1.txt
pkg net, method (*UDPConn) WriteMsgUDP([]uint8, []uint8, *UDPAddr) (int, int, error) pkg net, method (*UnixConn) CloseRead() error pkg net, method (*UnixConn) CloseWrite() error pkg net, type Dialer struct pkg net, type Dialer struct, Deadline time.Time pkg net, type Dialer struct, LocalAddr Addr pkg net, type Dialer struct, Timeout time.Duration
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 31 20:37:15 UTC 2022 - 2.6M bytes - Viewed (0)