*
   * This has important consequences: it means that the RateLimiter doesn't remember the time of the
   * _last_ request, but it remembers the (expected) time of the _next_ request. This also enables
   * us to tell immediately (see tryAcquire(timeout)) whether a particular timeout is enough to get
   * us to the point of the next scheduling time, since we always maintain that. And what we mean by

import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Tag
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout
import org.junit.jupiter.api.extension.RegisterExtension

@Flaky // STDOUT logging enabled for test
@Timeout(30)
@Tag("Slow")
open class ConnectionListenerTest {
  @RegisterExtension
  val platform = PlatformRule()

  @RegisterExtension

      },
    ).hasMessage("timeout too small")
    assertThat(
      assertThrows<IllegalArgumentException> {
        checkDuration(
          "timeout",
          1L + Int.MAX_VALUE.toLong(),
          TimeUnit.MILLISECONDS,
        )
      },
    ).hasMessage("timeout too large")
  }

  @Test
  fun testDurationDuration() {

    private final boolean permanent;

    private long startTime;

    private int status = ACTIVE;

    TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
        this.timeoutTarget = timeoutTarget;
        this.timeoutMillis = timeout * 1000L;
        this.permanent = permanent;
        this.startTime = System.currentTimeMillis();
    }

    /**
     * Returns whether the task has expired.

    public static final String MAX_TOTAL_CONNECTION_PROPERTY = "maxTotalConnection";

    /** Property name for time to live time unit setting */
    public static final String TIME_TO_LIVE_TIME_UNIT_PROPERTY = "timeToLiveTimeUnit";

    /** Property name for time to live setting */
    public static final String TIME_TO_LIVE_PROPERTY = "timeToLive";

    /** Logger instance for this class */

 * It closes expired connections and idle connections that have exceeded a specified timeout.
 * </p>
 *
 * clientConnectionManager the HttpClientConnectionManager used to manage connections
 * idleConnectionTimeout the timeout duration (in milliseconds) for idle connections
 *
 * <p>Methods:</p>
 * <ul>

    }

    /**
     * Get the timeout
     * @return the timeout in milliseconds
     */
    public long getTimeout() {
        return timeout;
    }

    /**
     * Get the create time
     * @return the create time
     */
    public long getCreateTime() {
        return createTime;
    }

    /**
     * Get the last access time
     * @return the last access time
     */

        // Then
        assertEquals(300L, dfsTtl, "Should delegate DFS TTL");
        assertEquals(30000, responseTimeout, "Should delegate response timeout");
        assertEquals(35000, socketTimeout, "Should delegate socket timeout");
        assertEquals(35000, connTimeout, "Should delegate connection timeout");
        assertEquals(10, maxMpx, "Should delegate max MPX count");

        verify(mockDelegate).getDfsTtl();

                return false;
            }

            // Check if we've exceeded time limits
            long totalElapsed = System.currentTimeMillis() - exception.getOperationStartTime();
            if (totalElapsed > maxDelayMs * maxAttempts) {
                log.debug("Retry time limit exceeded for operation");
                return false;
            }

            return true;
        }

  }

  /** Tests that the {@link Future#get(long, TimeUnit)} method times out correctly. */
  public void testTimeoutOnGetWorksCorrectly() throws InterruptedException, ExecutionException {

    // The task thread waits for the latch, so we expect a timeout here.
    try {
      future.get(20, MILLISECONDS);
      fail("Should have timed out trying to get the value.");
    } catch (TimeoutException expected) {
    } finally {