int failures = consecutiveFailures.incrementAndGet();
            if (failures >= failureThreshold) {
                if (state.compareAndSet(State.CLOSED, State.OPEN)) {
                    stateChangeTime.set(System.currentTimeMillis());
                    log.warn("Circuit breaker {} opened after {} consecutive failures", name, failures);
                }
            }
        }
    }

    /**

                    // Expected
                }
            }

            // Circuit should be OPEN after 3 failures
            assertEquals(State.OPEN, customCb.getState(), "Circuit should be OPEN after regular failures");
            assertEquals(3, customCb.getFailureCount(), "Should have 3 failures");

            // Reset for custom predicate test
            customCb.reset();

// previous results
func (dt *dynamicTimeout) adjust(entries [dynamicTimeoutLogSize]time.Duration) {
	failures, maxDur := 0, time.Duration(0)
	for _, dur := range entries[:] {
		if dur == maxDuration {
			failures++
		} else if dur > maxDur {
			maxDur = dur
		}
	}

	failPct := float64(failures) / float64(len(entries))

	if failPct > dynamicTimeoutIncreaseThresholdPct {

            log.warn("[{}] Failure in HALF_OPEN state, reopening circuit: {}", name, e.getMessage());
            transitionTo(State.OPEN);
        } else if (currentState == State.CLOSED) {
            int failures = failureCount.incrementAndGet();
            int currentThreshold = this.failureThreshold;
            log.debug("[{}] Failure in CLOSED state ({}/{}): {}", name, failures, currentThreshold, e.getMessage());

     */
    public SsoLoginException(final String message) {
        super(message);
    }

    /**
     * Constructs a new SsoLoginException with the specified detail message and cause.
     *
     * @param message The detail message explaining the SSO login failure
     * @param cause The underlying exception that caused this SSO login failure
     */

                        }
                        allStepsExecuted &= step == projectStep || projectStep.status.get() == EXECUTED;
                    }

                    if (failures != null) {
                        // Handle the stored exception
                        Throwable failure;
                        if (failures.size() == 1) {
                            failure = failures.get(

        int failures = getFailureCount(handle);

        // Base interval starts at 1 second, increases with failures
        // Max interval is 30 seconds for inactive directories
        return Math.min(MAX_POLL_INTERVAL, BASE_POLL_INTERVAL + (failures * 2000));
    }

    /**
     * Get failure count for a handle
     *
     * @param handle notification handle

| `minio_cluster_replication_proxied_head_requests_failures` | (_Site Replication Only_)Number of failures in HEAD requests proxied to replication target                          |

		case tierRequestsFailure:
			fail += metric.Value
		}
	}
	if int(succ) != expSuccess {
		t.Fatalf("Expected %d successes but got %f", expSuccess, succ)
	}
	if int(fail) != expFailure {
		t.Fatalf("Expected %d failures but got %f", expFailure, fail)
	}

                    // Exponential backoff on errors: max 30 seconds, based on consecutive failures
                    try {
                        int failures = Math.min(registration.getHeartbeatFailures(), MAX_FAILURE_LIMIT);
                        long backoffDelay = Math.min(MAX_ERROR_BACKOFF, BASE_ERROR_DELAY * (1L << failures));
                        Thread.sleep(backoffDelay);