- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Immediate (0.04 sec)
-
cmd/erasure-healing_test.go
} for i := 0; i < nfi.Erasure.ParityBlocks; i++ { erasureDisks[i].Delete(t.Context(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{ Recursive: false, Immediate: false, }) } // Try healing now, it should heal the content properly. _, err = objLayer.HealObject(ctx, bucket, object, "", hopts) if err != nil { t.Fatal(err) }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
src/main/java/jcifs/SmbException.java
* * @return retry delay or 0 if no retry */ public long getRetryDelay() { switch (severity) { case RECOVERABLE: return 100; // Immediate retry with small delay case TRANSIENT: return 5000; // Wait 5 seconds default: return 0; // No retry } } @OverrideRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 6.4K bytes - Viewed (0) -
cmd/xl-storage_test.go
Recursive: false, Immediate: false, }); err != errFileAccessDenied { t.Errorf("expected: %s, got: %s", errFileAccessDenied, err) } } // TestXLStorage for delete on an removed disk. // should fail with disk not found. err = xlStorageDeletedStorage.Delete(t.Context(), "del-vol", "my-file", DeleteOptions{ Recursive: false, Immediate: false, }) if err != errDiskNotFound {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 66K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// appears in outDatedDisks. tamperedIndex = index dErr := erasureDisks[index].Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{ Recursive: false, Immediate: false, }) if dErr != nil { t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr) } break } case corruptPart: for index, err := range test.errs {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java
assertEquals(2, names.length); assertEquals("Store1", names[0]); assertEquals("Store2", names[1]); assertEquals(1, loadCount[0]); // Second immediate call should use cache names = testFactory.getDataStoreNames(); assertEquals(2, names.length); assertEquals(1, loadCount[0]); // Should not increment
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.8K bytes - Viewed (0) -
cmd/erasure-encode_test.go
for i, disk := range disks { if disk == OfflineDisk { continue } disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{ Recursive: false, Immediate: false, }) writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize()) }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (0) -
cmd/erasure-healing.go
if partsMetadata[i].IsRemote() { rmDataDir := partsMetadata[i].DataDir disk.Delete(ctx, bucket, pathJoin(encodeDirObject(object), rmDataDir), DeleteOptions{ Immediate: true, Recursive: true, }) } for i, v := range result.Before.Drives { if v.Endpoint == disk.Endpoint().String() { result.After.Drives[i].State = madmin.DriveStateOk } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/PythonJobTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 22.1K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
func (h *healingTracker) delete(ctx context.Context) error { return h.disk.Delete(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, healingTrackerFilename), DeleteOptions{ Recursive: false, Immediate: false, }, ) } func (h *healingTracker) isHealed(bucket string) bool { h.mu.RLock() defer h.mu.RUnlock() return slices.Contains(h.HealedBuckets, bucket) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
} catch (Exception e) { log.warn("[{}] Error during dynamic threshold adjustment: {}", name, e.getMessage()); } } private void adjustThresholdBasedOnMetrics() { // Immediate adjustment based on failure patterns int consecutiveFailureCount = consecutiveFailures.get(); if (consecutiveFailureCount > 10) { // Many consecutive failures, be stricter
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0)