- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for close (0.14 sec)
-
internal/http/close.go
) // DrainBody close non nil response with any response Body. // convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it. // If resp.Body is not closed, the Client's underlying RoundTripper
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/http/listener.go
} 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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes and
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
} func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
internal/logger/logrotate.go
return err } defer gw.Close() var wc io.WriteCloser wc = gzip.NewWriter(gw) if _, err = io.Copy(wc, r); err != nil { return err } if err = wc.Close(); err != nil { return err } // Persist to disk any caches. if err = gw.Sync(); err != nil { return err } // close everything before we delete. if err = gw.Close(); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w loggingOptions := log.DefaultOptions()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/bitrot.go
} // Close all the readers. func closeBitrotReaders(rs []io.ReaderAt) { for _, r := range rs { if r != nil { if br, ok := r.(io.Closer); ok { br.Close() } } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) { for _, w := range ws { if w != nil { if bw, ok := w.(io.Closer); ok { bw.Close() } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
internal/grid/debug.go
t.cancel() t.cleanupOnce.Do(func() { for _, manager := range t.Managers { manager.debugMsg(debugShutdown) } for _, server := range t.Servers { server.Close() } for _, listener := range t.Listeners { listener.Close() } }) } // WaitAllConnect will wait for all connections to be established. func (t *TestGrid) WaitAllConnect(ctx context.Context) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/untar.go
// the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock() defer d.mu.Unlock() if d.r != nil { return d.r.Read(p) } return 0, errors.New("reader closed") } func (d *disconnectReader) Close() error { d.mu.Lock() d.r = nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/bitrot_test.go
} _, err = writer.Write([]byte("aaaaaaaaaa")) if err != nil { t.Fatal(err) } _, err = writer.Write([]byte("aaaaa")) if err != nil { t.Fatal(err) } if bw, ok := writer.(io.Closer); ok { bw.Close() } reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10) b := make([]byte, 10) if _, err = reader.ReadAt(b, 0); err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 2.1K bytes - Viewed (0)