Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for deleteAll (0.06 sec)

  1. cmd/metacache-bucket.go

    	for k, v := range b.cachesRoot {
    		tmp := make([]string, len(v))
    		copy(tmp, v)
    		dst2[k] = tmp
    	}
    
    	return dst, dst2
    }
    
    // deleteAll will delete all on disk data for ALL caches.
    // Deletes are performed concurrently.
    func (b *bucketMetacache) deleteAll() {
    	ctx := context.Background()
    
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return
    	}
    
    	ez, ok := objAPI.(deleteAllStorager)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    func ExecObjectLayerTest(t TestErrHandler, objTest objTestType) {
    	{
    		ctx, cancel := context.WithCancel(context.Background())
    		if localMetacacheMgr != nil {
    			localMetacacheMgr.deleteAll()
    		}
    
    		objLayer, fsDir, err := prepareFS(ctx)
    		if err != nil {
    			t.Fatalf("Initialization of object layer failed for single node setup: %s", err)
    		}
    		setObjectLayer(objLayer)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    		if disk != nil {
    			wg.Add(1)
    			go func(disk StorageAPI) {
    				defer wg.Done()
    				er.cleanupStaleUploadsOnDisk(ctx, disk)
    			}(disk)
    		}
    	}
    	wg.Wait()
    }
    
    func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) {
    	var wg sync.WaitGroup
    	for _, disk := range er.getDisks() {
    		if disk == nil {
    			continue
    		}
    		wg.Add(1)
    		go func(disk StorageAPI) {
    			defer wg.Done()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    	}
    
    	opts.Versioned = globalBucketVersioningSys.PrefixEnabled(obj.Bucket, obj.Name)
    	opts.VersionSuspended = globalBucketVersioningSys.PrefixSuspended(obj.Bucket, obj.Name)
    
    	if lcEvent.Action.DeleteAll() {
    		opts.DeletePrefix = true
    		// use prefix delete on exact object (this is an optimization to avoid fan-out calls)
    		opts.DeletePrefixObject = true
    	}
    	var (
    		dobj ObjectInfo
    		err  error
    	)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    		}
    	}
    
    	if err == nil {
    		// Purge the entire bucket metadata entirely.
    		z.deleteAll(context.Background(), minioMetaBucket, pathJoin(bucketMetaPrefix, bucket))
    	}
    
    	return toObjectErr(err, bucket)
    }
    
    // deleteAll will rename bucket+prefix unconditionally across all disks to
    // minioMetaTmpDeletedBucket + unique uuid,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    			// If all disks are having errors, we give up.
    			if disksToHealCount == 0 {
    				return result, fmt.Errorf("all drives had write errors, unable to heal %s/%s", bucket, object)
    			}
    		}
    	}
    
    	defer er.deleteAll(context.Background(), minioMetaTmpBucket, tmpID)
    
    	// Rename from tmp location to the actual location.
    	for i, disk := range outDatedDisks {
    		if disk == OfflineDisk {
    			continue
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    
    	partName := "part.1"
    	tempErasureObj := pathJoin(uniqueID, fi.DataDir, partName)
    
    	defer er.deleteAll(context.Background(), minioMetaTmpBucket, tempObj)
    
    	var inlineBuffers []*bytes.Buffer
    	if globalStorageClass.ShouldInline(erasure.ShardFileSize(data.ActualSize()), opts.Versioned) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. cmd/peer-s3-server.go

    		g := errgroup.WithNErrs(len(localDrives))
    		for index := range localDrives {
    			g.Go(func() error {
    				if localDrives[index] == nil {
    					return errDiskNotFound
    				}
    				localDrives[index].DeleteVol(ctx, bucket, false)
    				return nil
    			}, index)
    		}
    
    		g.Wait()
    	}
    
    	// Create the lost volume only if its not marked for delete
    	if !opts.Remove {
    		// Initialize sync waitgroup.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  10. 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(t.Context(), pathJoin(bucket, encodeDirObject(object)), true)
    	if err != nil {
    		t.Fatalf("Failed to delete a file - %v", err)
    	}
    
    	// Heal the object
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
Back to top