Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ReadVersion (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
Back to top