Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for readData (0.33 sec)

  1. cmd/erasure-object.go

    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    func (er erasureObjects) getObjectFileInfo(ctx context.Context, bucket, object string, opts ObjectOptions, readData bool) (FileInfo, []FileInfo, []StorageAPI, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    func (client *storageRESTClient) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	// Use websocket when not reading data.
    	if !readData {
    		resp, err := storageReadXLRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    	// Validate file path length, before reading.
    	filePath := pathJoin(volumeDir, path)
    	if err = checkPathLength(filePath); err != nil {
    		return fi, err
    	}
    
    	readData := opts.ReadData
    
    	buf, _, err := s.readRaw(ctx, volume, volumeDir, filePath, readData)
    	if err != nil {
    		if err == errFileNotFound {
    			if versionID != "" {
    				return fi, errFileVersionNotFound
    			}
    		}
    		return fi, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadAll(ctx, volume, path)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadXL, volume, path)
    	if err != nil {
    		return RawFileInfo{}, err
    	}
    	defer func() {
    		done(int64(len(rf.Buf)), &err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top