Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for Offset (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/erasure-decode_test.go

    	}
    
    	// To generate random offset/length.
    	r := rand.New(rand.NewSource(UTCNow().UnixNano()))
    
    	buf := &bytes.Buffer{}
    
    	// Verify erasure.Decode() for random offsets and lengths.
    	for i := 0; i < iterations; i++ {
    		offset := r.Int63n(length)
    		readLen := r.Int63n(length - offset)
    
    		expected := data[offset : offset+readLen]
    
    		// Get the checksums of the current part.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  5. cmd/erasure-utils.go

    	for _, block := range enBlocks[:dataBlocks] {
    		// Skip blocks until we have reached our offset.
    		if offset >= int64(len(block)) {
    			// Decrement offset.
    			offset -= int64(len(block))
    			continue
    		}
    
    		// Skip until offset.
    		block = block[offset:]
    
    		// Reset the offset for next iteration to read everything
    		// from subsequent blocks.
    		offset = 0
    
    		// We have written all the blocks, write the last remaining block.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. cmd/erasure-metadata.go

    }
    
    // ObjectToPartOffset - translate offset of an object to offset of its individual part.
    func (fi FileInfo) ObjectToPartOffset(ctx context.Context, offset int64) (partIndex int, partOffset int64, err error) {
    	if offset == 0 {
    		// Special case - if offset is 0, then partIndex and partOffset are always 0.
    		return 0, 0, nil
    	}
    	partOffset = offset
    	// Seek until object offset maps to a particular part offset.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  9. 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)
  10. internal/crypto/sse.go

    }
    
    // DecryptSinglePart decrypts an io.Writer which must an object
    // uploaded with the single-part PUT API. The offset and length
    // specify the requested range.
    func DecryptSinglePart(w io.Writer, offset, length int64, key ObjectKey) io.WriteCloser {
    	const PayloadSize = 1 << 16 // DARE 2.0
    	w = ioutil.LimitedWriter(w, offset%PayloadSize, length)
    
    	decWriter, err := sio.DecryptWriter(w, sio.Config{Key: key[:], CipherSuites: fips.DARECiphers()})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 4.4K bytes
    - Viewed (0)
Back to top