Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for deleteAll (4.8 sec)

  1. cmd/metacache-manager.go

    		v.status = scanStateError
    		m.mu.Lock()
    		m.trash[k] = v
    		m.mu.Unlock()
    	}
    }
    
    // deleteAll will delete all caches.
    func (m *metacacheManager) deleteAll() {
    	m.init.Do(m.initManager)
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	for bucket, b := range m.buckets {
    		b.deleteAll()
    		delete(m.buckets, bucket)
    	}
    }
    
    // checkMetacacheState should be used if data is not updating.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  2. 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,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.6K bytes
    - Viewed (0)
  4. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. 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)
    
    	shardFileSize := erasure.ShardFileSize(data.Size())
    	inlineBlock := globalStorageClass.InlineBlock()
    	if inlineBlock <= 0 {
    		inlineBlock = 128 * humanize.KiByte
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  6. internal/bucket/lifecycle/expiration.go

    	}
    
    	if !e.DeleteMarker.set && !e.DeleteAll.set && e.IsDaysNull() && e.IsDateNull() {
    		return errXMLNotWellFormed
    	}
    
    	// Both expiration days and date are specified
    	if !e.IsDaysNull() && !e.IsDateNull() {
    		return errLifecycleInvalidExpiration
    	}
    
    	// DeleteAll set without expiration days
    	if e.DeleteAll.set && e.IsDaysNull() {
    		return errLifecycleInvalidDeleteAll
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 6.6K bytes
    - Viewed (1)
  7. internal/bucket/lifecycle/lifecycle.go

    func (a Action) DeleteVersioned() bool {
    	return a == DeleteVersionAction || a == DeleteRestoredVersionAction
    }
    
    // DeleteAll - Returns true if the action demands deleting all versions of an object
    func (a Action) DeleteAll() bool {
    	return a == DeleteAllVersionsAction || a == DelMarkerDeleteAllVersionsAction
    }
    
    // Delete - Returns true if action demands delete on all objects (including restored)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  9. 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(&err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.DeleteVol(ctx, volume, forceDelete) })
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  10. cmd/metacache.go

    		return
    	}
    	ez, ok := objAPI.(deleteAllStorager)
    	if !ok {
    		bugLogIf(ctx, errors.New("metacache.delete: expected objAPI to be 'deleteAllStorager'"))
    		return
    	}
    	ez.deleteAll(ctx, minioMetaBucket, metacachePrefixForID(m.bucket, m.id))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
Back to top