Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for startOffset (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. cmd/erasure-server-pool.go

    // Copies a part of an object from source hashedSet to destination hashedSet.
    func (z *erasureServerPools) CopyObjectPart(ctx context.Context, srcBucket, srcObject, destBucket, destObject string, uploadID string, partID int, startOffset int64, length int64, srcInfo ObjectInfo, srcOpts, dstOpts ObjectOptions) (PartInfo, error) {
    	if err := checkNewMultipartArgs(ctx, srcBucket, srcObject); err != nil {
    		return PartInfo{}, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  9. 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)
    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)
  10. 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)
Back to top