Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for Immediate (0.04 sec)

  1. 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)
  2. 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
            }
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/test/java/org/codelibs/fess/job/PythonJobTest.java

                this.output = output;
            }
    
            @Override
            public void start() {
                // Override start to do nothing in test - simulate immediate completion
            }
    
            @Override
            public void run() {
                // Override run to do nothing in test
            }
    
            @Override
            public String getOutput() {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top