Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	disk := er.getDisks()[0]
    	fileInfoPreHeal1, err := disk.ReadVersion(context.Background(), "", bucket, object, oi1.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    	fileInfoPreHeal2, err := disk.ReadVersion(context.Background(), "", bucket, object, oi2.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. 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(context.Background(), "", testCase.volume, testCase.path, "", ReadOptions{})
    		if err != testCase.err {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  5. cmd/erasure-metadata-utils.go

    	for index := range disks {
    		index := index
    		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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top