- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for rc (0.4 sec)
-
cmd/bucket-replication.go
} // load mrf entries from disk func (p *ReplicationPool) loadMRF() (mrfRec MRFReplicateEntries, err error) { loadMRF := func(rc io.ReadCloser) (re MRFReplicateEntries, err error) { defer rc.Close() if !p.initialized() { return re, nil } var data [4]byte n, err := rc.Read(data[:]) if err != nil { return re, err } if n != len(data) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/grid/handlers.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
} z, err := zip.NewReader(bytes.NewReader(f), int64(len(f))) if err != nil { t.Fatal(err) } for _, f := range z.File { if f.Name == file { rc, err := f.Open() if err != nil { t.Fatal(err) } defer rc.Close() b, err := io.ReadAll(rc) if err != nil { t.Fatal(err) } return b } } t.Fatal(file, "not found in testdata/testdata.zip") return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 38.5K bytes - Viewed (0) -
cmd/object-api-utils.go
// properly, because we do not wish to create an object even if // client closed the stream prematurely. func newS2CompressReader(r io.Reader, on int64, encrypted bool) (rc io.ReadCloser, idx func() []byte) { pr, pw := io.Pipe() // Copy input to compressor opts := compressOpts if encrypted { // The values used for padding are not a security concern,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/s3select/progress.go
if pr.closer != nil { pr.closer.Close() } return pr.rc.Close() } func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) { if pr == nil { return 0, 0 } return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead() } func newProgressReader(rc io.ReadCloser, compType CompressionType) (*progressReader, error) { if rc == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/s3select/json/reader.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
cmd/bitrot-streaming.go
disk StorageAPI data []byte rc io.Reader volume string filePath string tillOffset int64 currOffset int64 h hash.Hash shardSize int64 hashBytes []byte } func (b *streamingBitrotReader) Close() error { if b.rc == nil { return nil } if closer, ok := b.rc.(io.Closer); ok { // drain the body for connection reuse at network layer.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer gr.Close() rc, err = file.Open(gr) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } else { rc = io.NopCloser(bytes.NewReader([]byte{})) } defer rc.Close() if err = setObjectHeaders(w, fileObjInfo, nil, opts); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0) -
cmd/ftp-server-driver.go
DisableContentSha256: true, }) return err } // GetFile implements ftpDriver func (driver *ftpDriver) GetFile(ctx *ftp.Context, objPath string, offset int64) (n int64, rc io.ReadCloser, err error) { stopFn := globalFtpMetrics.log(ctx, objPath) defer stopFn(err) bucket, object := path2BucketObject(objPath) if bucket == "" { return 0, nil, errors.New("bucket name cannot be empty")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0)