- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 3,889 for close1 (0.13 sec)
-
src/net/http/transfer.go
mu sync.Mutex // guards following, and calls to Read and Close sawEOF bool closed bool earlyClose bool // Close called and we didn't read to the end of src onHitEOF func() // if non-nil, func to call when EOF is Read } // ErrBodyReadAfterClose is returned when reading a [Request] or [Response] // Body after the body has been closed. This typically happens when the body is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 22:14:00 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
// In this case, the `initialSyncTimeout` will never be set // In order not block istiod start up, check close as well. if c.Closed() { return true } return c.initialSync.Load() || c.initialSyncTimeout.Load() } func (c *Cluster) Closed() bool { select { case <-c.stop: return true default: return false } } func (c *Cluster) SyncDidTimeout() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
src/internal/fuzz/sys_posix.go
return &sharedMem{f: f, region: region, removeOnClose: removeOnClose}, nil } // Close unmaps the shared memory and closes the temporary file. If this // sharedMem was created with sharedMemTempFile, Close also removes the file. func (m *sharedMem) Close() error { // Attempt all operations, even if we get an error for an earlier operation. // os.File.Close may fail due to I/O errors, but we still want to delete // the temporary file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 12 19:47:40 UTC 2022 - 4.1K bytes - Viewed (0) -
src/compress/zlib/writer.go
} z.err = z.compressor.Flush() return z.err } // Close closes the Writer, flushing any unwritten data to the underlying // io.Writer, but does not close the underlying io.Writer. func (z *Writer) Close() error { if !z.wroteHeader { z.err = z.writeHeader() } if z.err != nil { return z.err } z.err = z.compressor.Close() if z.err != nil { return z.err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 27 18:51:27 UTC 2023 - 5.2K bytes - Viewed (0) -
internal/http/listener.go
if ok { return result.conn, result.err } case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream.go
// This blocks until the connection is closed. // Client should not send anything. IgnoreReceives(ws, r.timeout) // Once the client closes, we should also close closeConn() }() r.err <- messageCopy(ws, r.r, !r.protocols[r.selectedProtocol].Binary, r.ping, r.timeout) } func resetTimeout(ws *websocket.Conn, timeout time.Duration) { if timeout > 0 { ws.SetDeadline(time.Now().Add(timeout)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 5.2K bytes - Viewed (0) -
src/net/http/client.go
// Body which the user is expected to close. If the Body is not both // read to EOF and closed, the [Client]'s underlying [RoundTripper] // (typically [Transport]) may not be able to re-use a persistent TCP // connection to the server for a subsequent "keep-alive" request. // // The request Body, if non-nil, will be closed by the underlying // Transport, even on errors. The Body may be closed asynchronously after // Do returns. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0) -
internal/s3select/select.go
} } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the // object for reading and a subsequent Close call is required to ensure // resources are freed. func (rsc *ObjectReadSeekCloser) Close() error { rsc.closerOnce.Do(func() { if rsc.reader != nil { rsc.closerErr = rsc.reader.Close() rsc.reader = nil } }) return rsc.closerErr
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_download_concurrent_read.txt
} // readCache repeatedly globs for go.mod files in the given cache, then opens // those files for reading. When the done chan is closed, readCache closes // files and returns. func readCache(gopath string, done <-chan struct{}) { files := make(map[string]*os.File) defer func() { for _, f := range files { f.Close() } }() pattern := filepath.Join(gopath, "pkg/mod/rsc.io/quote@v1.5.2*/go.mod") for { select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 24 21:26:10 UTC 2022 - 2.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
return webSocket!!.processNextFrame() } override fun close() { if (closed) { throw AssertionError("Already closed") } try { source.close() } catch (ignored: IOException) { } try { sink.close() } catch (ignored: IOException) { } closed = true } override fun cancel() { canceled = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0)