- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for startOffset (0.07 sec)
-
docs/debugging/xl-meta/main.go
for shardsIdx, ok := range shardConfig { if ok == 0 { copy(splitData[shardsIdx][startOffset:], shards[shardsIdx]) for i := range shards[shardsIdx] { if splitFilled[shardsIdx][startOffset+i] == 1 { fmt.Println("Internal error: Found filled data at", startOffset+i) } splitFilled[shardsIdx][startOffset+i] = 1 } reconstructed += len(shards[shardsIdx]) } else {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 05 11:57:44 UTC 2024 - 40.3K bytes - Viewed (0) -
cmd/warm-backend-s3.go
gopts := minio.GetObjectOptions{} if rv != "" { gopts.VersionID = string(rv) } if opts.startOffset >= 0 && opts.length > 0 { if err := gopts.SetRange(opts.startOffset, opts.startOffset+opts.length-1); err != nil { return nil, s3.ToObjectError(err, object) } } c := &minio.Core{Client: s3.client}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/SourceSinkFactories.java
public byte[] getExpected(byte[] bytes) { byte[] baseExpected = factory.getExpected(bytes); int startOffset = (int) min(off, baseExpected.length); int actualLen = (int) min(len, baseExpected.length - startOffset); return Arrays.copyOfRange(baseExpected, startOffset, startOffset + actualLen); } @Override public void tearDown() throws IOException { factory.tearDown();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 12.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/SourceSinkFactories.java
public byte[] getExpected(byte[] bytes) { byte[] baseExpected = factory.getExpected(bytes); int startOffset = (int) min(off, baseExpected.length); int actualLen = (int) min(len, baseExpected.length - startOffset); return Arrays.copyOfRange(baseExpected, startOffset, startOffset + actualLen); } @Override public void tearDown() throws IOException { factory.tearDown();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.7K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if opts.startOffset < 0 { return nil, InvalidRange{} } resp, err := az.clnt.DownloadStream(ctx, az.Bucket, az.getDest(object), &azblob.DownloadStreamOptions{ Range: blob.HTTPRange{Offset: opts.startOffset, Count: opts.length}, }) if err != nil { return nil, azureToObjectError(err, az.Bucket, az.getDest(object)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
cmd/erasure-object.go
if length < 0 { length = fi.Size - startOffset } // Reply back invalid range if the input offset and length fall out of range. if startOffset > fi.Size || startOffset+length > fi.Size { return InvalidRange{startOffset, length, fi.Size} } // Get start part index and offset. partIndex, partOffset, err := fi.ObjectToPartOffset(ctx, startOffset) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
// Calling ReadCompressed with true accomplishes that. object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true) r, err = object.NewRangeReader(ctx, opts.startOffset, opts.length) if err != nil { return nil, gcsToObjectError(err, gcs.Bucket, key) } return r, nil } func (gcs *warmBackendGCS) Remove(ctx context.Context, key string, rv remoteVersionID) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/warm-backend.go
xhttp "github.com/minio/minio/internal/http" ) // WarmBackendGetOpts is used to express byte ranges within an object. The zero // value represents the entire byte range of an object. type WarmBackendGetOpts struct { startOffset int64 length int64 } // WarmBackend provides interface to be implemented by remote tier backends type WarmBackend interface {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
if partRangeErr := checkCopyPartRangeWithSize(rs, actualPartSize); partRangeErr != nil { writeCopyPartErr(ctx, w, partRangeErr, r.URL) return } // Get the object offset & length startOffset, length, err := rs.GetOffsetLength(actualPartSize) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // maximum copy size for multipart objects in a single operation
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if err != nil { return nil, ErrorRespToObjectError(err, bucket, object) } gopts := WarmBackendGetOpts{} // get correct offsets for object if off >= 0 && length >= 0 { gopts.startOffset = off gopts.length = length } timeTierAction := auditTierActions(ctx, oi.TransitionedObject.Tier, length)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0)