Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top