Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for MakeVol (0.12 sec)

  1. cmd/xl-storage_test.go

    		if err != nil {
    			t.Fatalf("Unable to initialize xlStorage, %s", err)
    		}
    
    		// change backend permissions for MakeVol error.
    		if err = os.Chmod(permDeniedDir, 0o400); err != nil {
    			t.Fatalf("Unable to change permission to temporary directory %v. %v", permDeniedDir, err)
    		}
    
    		if err := xlStorageNew.MakeVol(context.Background(), "test-vol"); err != errDiskAccessDenied {
    			t.Fatalf("expected: %s, got: %s", errDiskAccessDenied, 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)
  2. cmd/xl-storage_windows_test.go

    	// Instantiate posix object to manage a disk
    	fs, err := newLocalXLStorage(dir)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Create volume to use in conjunction with other StorageAPI's file API(s)
    	err = fs.MakeVol(context.Background(), "voldir")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		t.Run(fmt.Sprint(i), func(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Nov 29 06:35:16 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.MakeVolBulk(ctx, volumes...)
    }
    
    func (d *naughtyDisk) MakeVol(ctx context.Context, volume string) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.MakeVol(ctx, volume)
    }
    
    func (d *naughtyDisk) ListVols(ctx context.Context) (vols []VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. cmd/peer-s3-server.go

    		// Make a volume entry on all underlying storage disks.
    		for index := range localDrives {
    			index := index
    			g.Go(func() error {
    				if beforeState[index] == madmin.DriveStateMissing {
    					err := localDrives[index].MakeVol(ctx, bucket)
    					if err == nil {
    						afterState[index] = madmin.DriveStateOk
    					}
    					return err
    				}
    				return errs[index]
    			}, index)
    		}
    
    		errs = g.Wait()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    	registerStorageRESTHandlers(tg.Mux[1], poolEps, tg.Managers[1])
    
    	storage := globalLocalSetDrives[0][0][0]
    	if err = storage.MakeVol(context.Background(), "foo"); err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    
    	if err = storage.MakeVol(context.Background(), "bar"); err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    
    	restClient, err := newStorageRESTClient(endpoint, false, tg.Managers[0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. cmd/bitrot_test.go

    	tmpDir := t.TempDir()
    
    	volume := "testvol"
    	filePath := "testfile"
    
    	disk, err := newLocalXLStorage(tmpDir)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	disk.MakeVol(context.Background(), volume)
    
    	writer := newBitrotWriter(disk, "", volume, filePath, 35, bitrotAlgo, 10)
    
    	_, err = writer.Write([]byte("aaaaaaaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. cmd/storage-interface.go

    	NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error)
    
    	// 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. cmd/storage-rest-client.go

    func (client *storageRESTClient) MakeVolBulk(ctx context.Context, volumes ...string) (err error) {
    	return errInvalidArgument
    }
    
    // MakeVol - create a volume on a remote disk.
    func (client *storageRESTClient) MakeVol(ctx context.Context, volume string) (err error) {
    	return errInvalidArgument
    }
    
    // ListVols - List all volumes on a remote disk.
    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-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) MakeVol(ctx context.Context, volume string) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricMakeVol, volume)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.MakeVol(ctx, volume) })
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    		return hr, nil
    	}
    
    	for i, err := range errs {
    		if err == errVolumeNotFound || err == errFileNotFound {
    			// Bucket or prefix/directory not found
    			merr := storageDisks[i].MakeVol(ctx, pathJoin(bucket, object))
    			switch merr {
    			case nil, errVolumeExists:
    				hr.After.Drives[i].State = madmin.DriveStateOk
    			case errDiskNotFound:
    				hr.After.Drives[i].State = madmin.DriveStateOffline
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
Back to top