- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 52 for deleteAll (0.08 sec)
-
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) -
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) -
internal/bucket/lifecycle/lifecycle_test.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 55.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)