Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Saadat (0.16 sec)

  1. cmd/bitrot-whole.go

    	tillOffset int64           // Affects the length of data requested in disk.ReadFile depending on Read()'s offset
    	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 {
    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)
  2. cmd/bitrot_test.go

    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 10); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 20); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b[:5], 30); err != nil {
    		t.Fatal(err)
    	}
    	if br, ok := reader.(io.Closer); ok {
    		br.Close()
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    	}
    
    	// Verify it is a regular file, otherwise subsequent Seek is
    	// undefined.
    	if !st.Mode().IsRegular() {
    		return 0, errIsNotRegular
    	}
    
    	if verifier == nil {
    		n, err = file.ReadAt(buffer, offset)
    		return int64(n), err
    	}
    
    	h := verifier.algorithm.New()
    	if _, err = io.Copy(h, io.LimitReader(file, offset)); err != nil {
    		return 0, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  4. cmd/sftp-server-driver.go

    			minio.PutObjectOptions{DisableContentSha256: true},
    		)
    		return err
    	}
    
    	return NotImplemented{}
    }
    
    type listerAt []os.FileInfo
    
    // Modeled after strings.Reader's ReadAt() implementation
    func (f listerAt) ListAt(ls []os.FileInfo, offset int64) (int, error) {
    	var n int
    	if offset >= int64(len(f)) {
    		return 0, io.EOF
    	}
    	n = copy(ls, f[offset:])
    	if n < len(ls) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  5. cmd/erasure-decode.go

    	missingPartsHeal := int32(0) // Atomic bool flag.
    	readerIndex := 0
    	var wg sync.WaitGroup
    	// if readTrigger is true, it implies next disk.ReadAt() should be tried
    	// if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need
    	// to try reading the next disk.
    	for readTrigger := range readTriggerCh {
    		newBufLK.RLock()
    		canDecode := p.canDecode(newBuf)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  6. cmd/bitrot-streaming.go

    	}
    	return nil
    }
    
    func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) {
    	var err error
    	if offset%b.shardSize != 0 {
    		// Offset should always be aligned to b.shardSize
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	if b.rc == nil {
    		// For the first ReadAt() call we need to open the stream for reading.
    		b.currOffset = offset
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
Back to top