Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 52 for deleteAll (0.33 sec)

  1. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            assertEquals(2, suggester.getAllWordsNum());
            assertEquals(2, suggester.getDocumentWordsNum());
            assertEquals(1, suggester.getQueryWordsNum());
    
            suggester.indexer().deleteAll();
            suggester.refresh();
            assertEquals(0, suggester.getAllWordsNum());
            assertEquals(0, suggester.getDocumentWordsNum());
            assertEquals(0, suggester.getQueryWordsNum());
        }
    
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 37.4K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/lifecycle_test.go

    	lc := Lifecycle{
    		Rules: []Rule{
    			{
    				ID:     "ExpiredObjectDeleteAllVersions-20",
    				Status: "Enabled",
    				Expiration: Expiration{
    					set:       true,
    					DeleteAll: Boolean{val: true, set: true},
    					Days:      20,
    				},
    			},
    			{
    				ID:     "Transition-10",
    				Status: "Enabled",
    				Transition: Transition{
    					set:          true,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 55.5K bytes
    - Viewed (0)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  7. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K 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(0, &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.DeleteVol(ctx, volume, forceDelete) })
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  10. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
Back to top