eachQueue@ for (queue in readyQueues) {
        val candidate = queue.futureTasks[0]
        val candidateDelay = maxOf(0L, candidate.nextExecuteNanoTime - now)

        when {
          // Compute the delay of the soonest-executable task.
          candidateDelay > 0L -> {
            minDelayNanos = minOf(candidateDelay, minDelayNanos)
            continue@eachQueue
          }

        // We've chosen a connection to evict. Confirm it's still okay to be evicted, then close it.
        toEvict.withLock {
          if (toEvict.calls.isNotEmpty()) return 0L // No longer idle.
          if (toEvict.idleAtNs != toEvictIdleAtNs) return 0L // No longer oldest.
          toEvict.noNewExchanges = true
          connections.remove(toEvict)
        }
        toEvict.socket().closeQuietly()

  public void testFlatMapToLong_nullStream() {
    SpliteratorTester.ofLong(
            () ->
                CollectSpliterators.flatMapToLong(
                    Arrays.spliterator(new Long[] {1L, 0L, 1L, 2L, 3L}),
                    (Long i) -> i == 0L ? null : LongStream.of(i).spliterator(),
                    Spliterator.SIZED | Spliterator.DISTINCT | Spliterator.NONNULL,
                    4))
        .expect(1L, 1L, 2L, 3L);
  }

    @Test
    public void test_setRequestInterval() {
        indexingHelper.setRequestInterval(1000L);
        assertEquals(1000L, indexingHelper.requestInterval);

        indexingHelper.setRequestInterval(0L);
        assertEquals(0L, indexingHelper.requestInterval);
    }

    @Test
    public void test_deleteBySessionId_withClient() {
        final Map<String, String> resultMap = new HashMap<>();

  }

internal fun checkDuration(
  name: String,
  duration: Long,
  unit: TimeUnit,
): Int {
  check(duration >= 0L) { "$name < 0" }
  val millis = unit.toMillis(duration)
  require(millis <= Integer.MAX_VALUE) { "$name too large" }
  require(millis != 0L || duration <= 0L) { "$name too small" }
  return millis.toInt()
}

internal fun checkDuration(
  name: String,
  duration: Duration,
): Int {

     * @throws CIFSException
     */
    @Test
    void testGetServerTimeZoneOffset() throws CIFSException {
        when(smbTreeHandle.getServerTimeZoneOffset()).thenReturn(0L);
        assertEquals(0L, smbTreeHandle.getServerTimeZoneOffset(), "Server time zone offset should be 0");
        when(smbTreeHandle.getServerTimeZoneOffset()).thenReturn(3600000L);

            return true;
        }

        this.attributes = ATTR_READONLY | ATTR_DIRECTORY;
        this.createTime = 0L;
        this.lastModified = 0L;
        this.lastAccess = 0L;
        this.isExists = false;

        try {
            if (this.url.getHost().length() == 0) {

    }

    @Test
    public void test_getAllWordsNum() {
        try {
            assertEquals(0L, suggestHelper.getAllWordsNum());
        } catch (Exception e) {
            assertTrue(true);
        }
    }

    @Test
    public void test_getDocumentWordsNum() {
        try {
            assertEquals(0L, suggestHelper.getDocumentWordsNum());
        } catch (Exception e) {
            assertTrue(true);

    @Test
    @DisplayName("Test with maximum and minimum values")
    void testWithBoundaryValues() {
        // Test with minimum values
        trans2SetFileInfo = new Trans2SetFileInformation(config, 0, 0, 0L, 0L, 0L);
        assertNotNull(trans2SetFileInfo);

        // Test with maximum values
        trans2SetFileInfo = new Trans2SetFileInformation(config, 0xFFFF, Integer.MAX_VALUE, Long.MAX_VALUE, Long.MAX_VALUE, Long.MAX_VALUE);

    override val isReady: Boolean
      get() = connectState == ConnectState.TLS_CONNECTED

    var tcpConnectDelayNanos = 0L
    var tcpConnectThrowable: Throwable? = null
    var yieldBeforeTcpConnectReturns = false
    var connectTcpNextPlan: FakePlan? = null
    var tlsConnectDelayNanos = 0L
    var tlsConnectThrowable: Throwable? = null
    var connectTlsNextPlan: FakePlan? = null

    fun createRetry(): FakePlan {