- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 61 for Glover (0.14 sec)
-
cmd/erasure-object.go
} return fi.ToObjectInfo(srcBucket, srcObject, srcOpts.Versioned || srcOpts.VersionSuspended), nil } // GetObjectNInfo - returns object info and an object // Read(Closer). When err != nil, the returned reader is always nil. func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/object-handlers.go
return } if r.ContentLength <= 0 { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEmptyRequestBody), r.URL) return } // Take read lock on object, here so subsequent lower-level // calls do not need to. lock := objectAPI.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/bitrot_test.go
t.Fatal(err) } _, 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) -
cmd/bitrot.go
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) -
cmd/data-usage-cache_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgallTierStats(b *testing.B) { v := allTierStats{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jan 13 07:51:08 GMT 2024 - 28.1K bytes - Viewed (0) -
internal/http/request-recorder.go
io.Reader // Response body should be logged LogBody bool // internal recording buffer buf bytes.Buffer // total bytes read including header size bytesRead int } // Close is a no operation closer func (r *RequestRecorder) Close() error { // no-op return nil } // Read reads from the internal reader and counts/save the body in the memory func (r *RequestRecorder) Read(p []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 12 21:37:19 GMT 2023 - 1.8K bytes - Viewed (0) -
cmd/batch-replicate_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBatchJobReplicateCredentials(b *testing.B) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 14.2K bytes - Viewed (1) -
cmd/bucket-lifecycle.go
reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts) if err != nil { return nil, err } closer := func() { timeTierAction(reader.Close()) } return fn(reader, h, closer) } // RestoreRequestType represents type of restore. type RestoreRequestType string const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/batch-expire_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBatchJobExpire(b *testing.B) { v := BatchJobExpire{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 6.9K bytes - Viewed (0) -
cmd/last-minute_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgAccElem(b *testing.B) { v := AccElem{} b.ReportAllocs()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 6.8K bytes - Viewed (0)