- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for startOffset (0.17 sec)
-
android/guava-tests/test/com/google/common/io/SourceSinkFactories.java
public byte[] getExpected(byte[] bytes) { byte[] baseExpected = factory.getExpected(bytes); int startOffset = (int) Math.min(off, baseExpected.length); int actualLen = (int) Math.min(len, baseExpected.length - startOffset); return Arrays.copyOfRange(baseExpected, startOffset, startOffset + actualLen); } @Override public void tearDown() throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 12.7K bytes - Viewed (0) -
cmd/object-api-utils_test.go
} for i, test := range testCases { startOffset, snappyStartOffset, firstPart, _, _ := getCompressedOffsets(test.objInfo, test.offset, nil) if startOffset != test.startOffset { t.Errorf("Test %d - expected startOffset %d but received %d", i, test.startOffset, startOffset) } if snappyStartOffset != test.snappyStartOffset { t.Errorf("Test %d - expected snappyOffset %d but received %d",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K 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}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/object-api-interface.go
func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) { var header http.Header if etag != "" { header.Set("ETag", etag) } Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length} reader, err := api.GetObjectNInfo(ctx, bucket, object, Range, header, opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K 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) Math.min(off, baseExpected.length); int actualLen = (int) Math.min(len, baseExpected.length - startOffset); return Arrays.copyOfRange(baseExpected, startOffset, startOffset + actualLen); } @Override public void tearDown() throws IOException {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Sep 09 17:57:59 GMT 2021 - 17.9K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if opts.startOffset < 0 { return nil, InvalidRange{} } blobURL := az.serviceURL.NewContainerURL(az.Bucket).NewBlobURL(az.getDest(object)) blob, err := blobURL.Download(ctx, opts.startOffset, opts.length, azblob.BlobAccessConditions{}, false, azblob.ClientProvidedKeyOptions{}) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/erasure-coding.go
} // ShardFileOffset - returns the effective offset where erasure reading begins. func (e *Erasure) ShardFileOffset(startOffset, length, totalLength int64) int64 { shardSize := e.ShardSize() shardFileSize := e.ShardFileSize(totalLength) endShard := (startOffset + length) / e.blockSize tillOffset := endShard*shardSize + shardSize if tillOffset > shardFileSize { tillOffset = shardFileSize }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 8.6K 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 {
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/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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0)