- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,175 for close1 (0.13 sec)
-
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.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/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/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/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) -
src/mime/quotedprintable/writer.go
if n == len(p) { return n, nil } if err := w.write(p[n:]); err != nil { return n, err } return len(p), nil } // Close closes the [Writer], flushing any unwritten data to the underlying // [io.Writer], but does not close the underlying io.Writer. func (w *Writer) Close() error { if err := w.checkLastByte(); err != nil { return err } return w.flush() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
.github/workflows/stale-issues.yml
It will be closed if no further activity occurs. Thank you. close-issue-message: > This issue was closed because it has been inactive for 7 days since being marked as stale. Please reopen if you'd like to work on this further. days-before-pr-stale: 14 days-before-pr-close: 14
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Nov 23 20:04:38 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// - Timer has passed. // - Buffer channel is closed and empty. // - stopCh is closed. func (b *bufferedBackend) collectEvents(timer <-chan time.Time, stopCh <-chan struct{}) []*auditinternal.Event { var events []*auditinternal.Event L: for i := 0; i < b.maxBatchSize; i++ { select { case ev, ok := <-b.buffer: // Buffer channel was closed and no new events will follow. if !ok { break L
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0)