concurrentLimiter.recordSuccess("user" + threadId, "192.168.2." + threadId);
                                    localFailures = 0;
                                }
                            } else {
                                concurrentLimiter.recordSuccess("user" + threadId, "192.168.2." + threadId);

        return true;
    }

    /**
     * Record successful authentication
     *
     * @param username the username
     * @param sourceIp the source IP
     */
    public void recordSuccess(String username, String sourceIp) {
        if (username != null) {
            AccountAttempts account = accountAttempts.get(username);
            if (account != null) {
                account.reset();

            for (int i = 0; i < numberOfBuckets; i++) {
                buckets[i] = new WindowBucket();
            }
        }

        public synchronized void recordSuccess(long responseTimeMs) {
            getCurrentBucket().recordSuccess(responseTimeMs);
        }

        public synchronized void recordFailure() {
            getCurrentBucket().recordFailure();
        }

        consecutiveFailures.remove(key);
        lastFailureTimes.remove(key);

        ConnectionMetrics metrics = connectionMetrics.get(key);
        if (metrics != null) {
            metrics.recordSuccess();
        }
    }

    /**
     * Perform maintenance tasks during health checks
     */
    private void performMaintenanceTasks() {
        // Clean up old failure records