Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DeleteVol (0.52 sec)

  1. cmd/peer-s3-server.go

    		for index := range localDrives {
    			index := index
    			g.Go(func() error {
    				if localDrives[index] == nil {
    					return errDiskNotFound
    				}
    				localDrives[index].DeleteVol(ctx, bucket, false)
    				return nil
    			}, index)
    		}
    
    		g.Wait()
    	}
    
    	// Create the quorum lost volume only if its nor makred for delete
    	if !opts.Remove {
    		// Initialize sync waitgroup.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    	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) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.DeleteVol(ctx, volume, forceDelete)
    }
    
    func (d *naughtyDisk) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	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.
    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		return vol, toStorageErr(err)
    	}
    	vol = *v
    	// Performs shallow copy, so we can reuse.
    	storageStatVolRPC.PutResponse(v)
    	return vol, nil
    }
    
    // DeleteVol - Deletes a volume over the network.
    func (client *storageRESTClient) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	return errInvalidArgument
    }
    
    // AppendFile - append to a file.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  5. cmd/xl-storage_test.go

    			t.Fatalf("expected: %s, got: %s", errDiskAccessDenied, err)
    		}
    	}
    }
    
    // TestXLStorageDeleteVol - Validates the expected behavior of xlStorage.DeleteVol for various cases.
    func TestXLStorageDeleteVol(t *testing.T) {
    	// create xlStorage test setup
    	xlStorage, path, err := newXLStorageTestSetup(t)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 11 17:45:28 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    	})
    }
    
    func (p *xlStorageDiskIDCheck) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDeleteVol, volume)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.DeleteVol(ctx, volume, forceDelete) })
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	// as CreatedTime.
    	createdTime := st.ModTime()
    	return VolInfo{
    		Name:    volume,
    		Created: createdTime,
    	}, nil
    }
    
    // DeleteVol - delete a volume.
    func (s *xlStorage) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	// Verify if volume is valid and it exists.
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return err
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    		t.Fatal(err)
    	}
    
    	// Remove the object backend files from the first disk.
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    	firstDisk := er.getDisks()[0]
    	err = firstDisk.DeleteVol(context.Background(), pathJoin(bucket, encodeDirObject(object)), true)
    	if err != nil {
    		t.Fatalf("Failed to delete a file - %v", err)
    	}
    
    	// Heal the object
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top