Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ReadVersion (1.46 sec)

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	disk := er.getDisks()[0]
    	fileInfoPreHeal1, err := disk.ReadVersion(t.Context(), "", bucket, object, oi1.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    	fileInfoPreHeal2, err := disk.ReadVersion(t.Context(), "", bucket, object, oi2.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    	}
    	return d.disk.DeleteVersion(ctx, volume, path, fi, forceDelMarker, opts)
    }
    
    func (d *naughtyDisk) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return FileInfo{}, err
    	}
    	return d.disk.ReadVersion(ctx, origvolume, volume, path, versionID, opts)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  3. cmd/xl-storage_test.go

    		{
    			volume: "ab",
    			path:   "as-file",
    			err:    errVolumeNotFound,
    		},
    	}
    
    	// Run through all the test cases and validate for ReadVersion.
    	for i, testCase := range testCases {
    		_, err = xlStorage.ReadVersion(t.Context(), "", testCase.volume, testCase.path, "", ReadOptions{})
    		if err != testCase.err {
    			t.Fatalf("TestXLStorage %d: Expected err \"%s\", got err \"%s\"", i+1, testCase.err, err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    	ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (FileInfo, error)
    	ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. cmd/erasure-metadata-utils.go

    	// Read `xl.meta` in parallel across disks.
    	for index := range disks {
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			metadataArray[index], err = disks[index].ReadVersion(ctx, origbucket, bucket, object, versionID, opts)
    			return err
    		}, index)
    	}
    
    	return metadataArray, g.Wait()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.WriteMetadata(ctx, origvolume, volume, path, fi) })
    }
    
    func (p *xlStorageDiskIDCheck) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadVersion, volume, path)
    	if err != nil {
    		return fi, err
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    		if retries > 0 {
    			for _, disk := range er.getDisks() {
    				if disk == nil {
    					continue
    				}
    				if !disk.IsOnline() {
    					continue
    				}
    				_, err := disk.ReadVersion(ctx, "", minioMetaBucket,
    					o.objectPath(0), "", ReadOptions{})
    				if err != nil {
    					time.Sleep(retryDelay250)
    					retries++
    					continue
    				}
    				break
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    	}, err
    }
    
    // ReadOptions optional inputs for ReadVersion
    type ReadOptions struct {
    	InclFreeVersions bool
    	ReadData         bool
    	Healing          bool
    }
    
    // ReadVersion - reads metadata and returns FileInfo at path `xl.meta`
    // for all objects less than `32KiB` this call returns data as well
    // along with metadata.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  9. cmd/storage-rest-client.go

    }
    
    // readMsgpReaderPoolPut can be used to reuse a *msgp.Reader.
    func readMsgpReaderPoolPut(r *msgp.Reader) {
    	if r != nil {
    		readMsgpReaderPool.Put(r)
    	}
    }
    
    func (client *storageRESTClient) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    	}
    
    	inclFreeVersions, err := strconv.ParseBool(params.Get(storageRESTInclFreeVersions))
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    
    	fi, err := s.getStorage().ReadVersion(context.Background(), origvolume, volume, filePath, versionID, ReadOptions{
    		InclFreeVersions: inclFreeVersions,
    		ReadData:         false,
    		Healing:          healing,
    	})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top