Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for StatVol (0.26 sec)

  1. cmd/peer-s3-server.go

    		index := index
    		g.Go(func() error {
    			if localDrives[index] == nil {
    				return errDiskNotFound
    			}
    			volInfo, err := localDrives[index].StatVol(ctx, bucket)
    			if err != nil {
    				if opts.Deleted {
    					dvi, derr := localDrives[index].StatVol(ctx, pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, bucket))
    					if derr != nil {
    						return err
    					}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ListVols(ctx)
    }
    
    func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return VolInfo{}, err
    	}
    	return d.disk.StatVol(ctx, volume)
    }
    
    func (d *naughtyDisk) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	// Volume operations.
    	MakeVol(ctx context.Context, volume string) (err error)
    	MakeVolBulk(ctx context.Context, volumes ...string) (err error)
    	ListVols(ctx context.Context) (vols []VolInfo, err error)
    	StatVol(ctx context.Context, volume string) (vol VolInfo, err error)
    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    // ListVols - List all volumes on a remote disk.
    func (client *storageRESTClient) ListVols(ctx context.Context) (vols []VolInfo, err error) {
    	return nil, errInvalidArgument
    }
    
    // StatVol - get volume info over the network.
    func (client *storageRESTClient) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	v, err := storageStatVolRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume)
    	if err != nil {
    		return vol, err
    	}
    	defer done(&err)
    
    	return xioutil.WithDeadline[VolInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result VolInfo, err error) {
    		return p.storage.StatVol(ctx, volume)
    	})
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    					renameAll(pathJoin(drivePath, minioMetaMultipartBucket, uploadIDPath), targetPath, pathJoin(drivePath, minioMetaBucket))
    				}
    				wait()
    				return nil
    			})
    		})
    		vi, err := disk.StatVol(ctx, pathJoin(minioMetaMultipartBucket, shaDir))
    		if err != nil {
    			return nil
    		}
    		w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    		return w.Run(func() error {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    		DryRun: false,
    		Remove: false,
    	})
    	if err != nil {
    		t.Fatal(err)
    	}
    	// Stat the bucket to make sure that it was created.
    	_, err = er.getDisks()[0].StatVol(context.Background(), bucket)
    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    // Tests both object and bucket healing.
    func TestHealingVersioned(t *testing.T) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    	if err != errDiskNotFound {
    		t.Errorf("Expected: \"Drive not found\", got \"%s\"", err)
    	}
    }
    
    // TestXLStorageStatVol - TestXLStorages validate the volume info returned by xlStorage.StatVol() for various inputs.
    func TestXLStorageStatVol(t *testing.T) {
    	// create xlStorage test setup
    	xlStorage, _, err := newXLStorageTestSetup(t)
    	if err != nil {
    		t.Fatalf("Unable to create xlStorage test setup, %s", err)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    			if err != nil {
    				if errors.Is(err, errFileNotFound) {
    					return nil
    				}
    				return err
    			}
    			for _, volName := range volsInfo {
    				vi, err := storageDisks[index].StatVol(ctx, pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, volName))
    				if err == nil {
    					vi.Name = strings.TrimSuffix(volName, SlashSeparator)
    					mu.Lock()
    					if _, ok := delBuckets[volName]; !ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  10. cmd/xl-storage.go

    			continue
    		}
    		volsInfo = append(volsInfo, VolInfo{
    			Name: pathutil.Clean(entry),
    		})
    	}
    	return volsInfo, nil
    }
    
    // StatVol - get volume info.
    func (s *xlStorage) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	// Verify if volume is valid and it exists.
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return VolInfo{}, err
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top