Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for offlet (0.14 sec)

  1. internal/s3select/select.go

    		rsc.offset = rsc.size + offset
    	}
    	if rsc.offset < 0 {
    		return rsc.offset, errors.New("seek to invalid negative offset")
    	}
    	if rsc.offset >= rsc.size {
    		return rsc.offset, errors.New("seek past end of object")
    	}
    	if rsc.reader != nil {
    		_ = rsc.reader.Close()
    		rsc.reader = nil
    	}
    	return rsc.offset, nil
    }
    
    // Read call to implement io.Reader
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  2. cmd/bitrot-whole.go

    	buf        []byte          // Holds bit-rot verified data
    }
    
    func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) {
    	if b.buf == nil {
    		b.buf = make([]byte, b.tillOffset-offset)
    		if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
    			return 0, err
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    func (d *naughtyDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	if err := d.calcError(); err != nil {
    		return 0, err
    	}
    	return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier)
    }
    
    func (d *naughtyDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if err := d.calcError(); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	return p.storage.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    // Legacy API - does not have any deadlines
    func (p *xlStorageDiskIDCheck) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadFile, volume, path)
    	if err != nil {
    		return 0, err
    	}
    	defer done(&err)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. internal/hash/checksum.go

    			if typ.Is(ChecksumIncludesMultipart) {
    				wantLen := int(t) * length
    				if len(b) < wantLen {
    					break
    				}
    				// Read part checksum
    				if part > 0 && uint64(part) <= t {
    					offset := (part - 1) * length
    					partCs := b[offset:]
    					cs = base64.StdEncoding.EncodeToString(partCs[:length])
    				}
    				b = b[wantLen:]
    			}
    		} else if part > 1 {
    			// For non-multipart, checksum is part 1.
    			cs = ""
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/httprange_test.go

    		}
    		o, l, err := rs.GetOffsetLength(resourceSize)
    		if err != nil {
    			t.Errorf("unexpected err: %v", err)
    		}
    		if o != testCase.expOffset || l != testCase.expLength {
    			t.Errorf("Case %d: got bad offset/length: %d,%d expected: %d,%d",
    				i, o, l, testCase.expOffset, testCase.expLength)
    		}
    	}
    
    	unparsableRangeSpecs := []string{
    		"bytes=-",
    		"bytes==",
    		"bytes==1-10",
    		"bytes=",
    		"bytes=aa",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  7. cmd/encryption-v1_test.go

    		if err == nil {
    			if etag != test.ETag {
    				t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag)
    			}
    		}
    	}
    }
    
    // Tests for issue reproduced when getting the right encrypted
    // offset of the object.
    func TestGetDecryptedRange_Issue50(t *testing.T) {
    	rs, err := parseRequestRangeSpec("bytes=594870256-594870263")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	objInfo := ObjectInfo{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  8. cmd/object-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objectRSC := s3select.NewObjectReadSeekCloser(
    		func(offset int64) (io.ReadCloser, error) {
    			rs := &HTTPRangeSpec{
    				IsSuffixLength: false,
    				Start:          offset,
    				End:            -1,
    			}
    			opts.NoLock = true
    			return getObjectNInfo(ctx, bucket, object, rs, r.Header, opts)
    		},
    		actualSize,
    	)
    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)
  9. cmd/object-multipart-handlers.go

    	// Special care for CopyObjectPart
    	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
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  10. 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)
Back to top