assertFalse(entry.isExpired());
        assertFalse(entry.needsRefresh());

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {
            // Ignore
        }

        assertTrue(entry.isExpired());
        assertTrue(entry.needsRefresh());
    }

    @Test
    public void testNeedsRefresh() {

      for (int i = 0; i < dataLength; i++) {
        dataArray.putData(i, din.readLong());
      }

      return new BloomFilter<>(dataArray, numHashFunctions, funnel, strategy);
    } catch (IOException e) {
      throw e;
    } catch (Exception e) { // sneaky checked exception
      String message =
          "Unable to deserialize BloomFilter from InputStream."
              + " strategyOrdinal: "

  }

  private static void assertCastFails(long value) {
    try {
      Ints.checkedCast(value);
      fail("Cast to int should have failed: " + value);
    } catch (IllegalArgumentException ex) {
      assertWithMessage("%s not found in exception text: %s", value, ex.getMessage())
          .that(ex.getMessage().contains(String.valueOf(value)))
          .isTrue();
    }
  }

        // This test documents the expected behavior
        try {
            String result = ldapManager.normalizePermissionName(null);
            assertNull(result);
        } catch (NullPointerException e) {
            // NPE is acceptable for null input
        }
    }

    @Test
    public void test_normalizePermissionName_withLowercaseEnabled() {

    assertThat(bb).isEqualTo(expectedHashCode.bytes);
    assertEquals(expectedHashCode.asInt, hash.asInt());
    if (expectedHashCode.asLong == null) {
      try {
        hash.asLong();
        fail();
      } catch (IllegalStateException expected) {
      }
    } else {
      assertEquals(expectedHashCode.asLong.longValue(), hash.asLong());
    }
    assertThat(hash.toString()).isEqualTo(expectedHashCode.toString);

            return;
        }

        cleanupScheduler.shutdownNow();
        try {
            cleanupScheduler.awaitTermination(5, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            log.warn("Interrupted while shutting down cleanup scheduler", e);
        }

        log.info("Authentication rate limiter closed");

        DirectoryCacheEntry entry = directoryLeaseManager.getCacheEntry(directoryPath);
        entry.setMaxAge(1); // 1ms to expire immediately
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            // Ignore
        }

        // When lease is lost, cache entry should be removed
        when(baseLeaseManager.getLease(leaseKey)).thenReturn(null);

    public void test_touch() {
        final ChatSession session = new ChatSession();
        final LocalDateTime initialTime = session.getLastAccessedAt();

        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            // ignore
        }

        session.touch();

        assertTrue(session.getLastAccessedAt().isAfter(initialTime) || session.getLastAccessedAt().isEqual(initialTime));

        mockBhv.setTestData(testData);

        relatedContentHelper.update();
        // Give a moment for async execution
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            // ignore
        }

        results = relatedContentHelper.getRelatedContents("test");
        assertEquals("Updated Content", results[0]);
    }

        scheduledJob.setId("nonexistent-job");

        try {
            scheduledJob.start(Map.of(Constants.JOB_LOG_ID, "some-id"));
            fail("Expected JobNotFoundException");
        } catch (final JobNotFoundException e) {
            // expected
        }
    }

    @Test
    public void test_startNoArg_callsLaunchNowWithoutParams() {