Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ReadVersion (3.8 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/erasure-multipart.go

    						modTime = time.Unix(0, t)
    					}
    				}
    			}
    			// Fallback for older uploads without time in the ID.
    			if modTime.IsZero() {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
    				if err != nil {
    					return nil
    				}
    				modTime = fi.ModTime
    				wait()
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    				defer wg.Done()
    
    				var (
    					fi  FileInfo
    					rfi RawFileInfo
    					err error
    				)
    
    				if opts.VersionID != "" {
    					// Read a specific version ID
    					fi, err = disk.ReadVersion(ctx, "", bucket, object, opts.VersionID, ropts)
    				} else {
    					// Read the latest version
    					rfi, err = disk.ReadXL(ctx, bucket, object, readData)
    					if err == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top