retries := 0
	rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))

	const (
		retryDelay    = 50 * time.Millisecond
		retryDelay250 = 250 * time.Millisecond
	)

	for {
		if contextCanceled(ctx) {
			return entries, ctx.Err()
		}

		// If many failures, check the cache state.
		if retries > 10 {

import static com.google.common.util.concurrent.SneakyThrows.sneakyThrow;
import static java.util.concurrent.Executors.callable;
import static java.util.concurrent.Executors.newFixedThreadPool;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.NANOSECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.junit.Assert.assertThrows;

import com.google.common.annotations.GwtIncompatible;

import static com.google.common.util.concurrent.Service.State.STOPPING;
import static com.google.common.util.concurrent.Service.State.TERMINATED;
import static java.util.Collections.sort;
import static java.util.concurrent.TimeUnit.MILLISECONDS;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.base.MoreObjects;
import com.google.common.base.Stopwatch;

import static com.google.common.cache.TestingWeighers.constantWeigher;
import static com.google.common.truth.Truth.assertThat;
import static java.util.concurrent.Executors.newFixedThreadPool;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.NANOSECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;

import static com.google.common.cache.TestingWeighers.constantWeigher;
import static com.google.common.truth.Truth.assertThat;
import static java.util.concurrent.Executors.newFixedThreadPool;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.NANOSECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;

    try {
      CacheBuilder<Object, Object> builder =
          createCacheBuilder()
              .expireAfterWrite(100, MILLISECONDS)
              .refreshAfterWrite(5, MILLISECONDS)
              .ticker(ticker);

      CacheLoader<String, String> loader =
          new CacheLoader<String, String>() {
            @Override

            throw new IllegalArgumentException("Invalid port number: " + port);
        }
    }

    /**
     * Validates timeout value
     *
     * @param timeout timeout in milliseconds
     * @param fieldName the field name for error reporting
     * @throws IllegalArgumentException if timeout is invalid
     */
    public static void validateTimeout(long timeout, String fieldName) {

     * - Time since last successful notification
     * - Events per unit time for more adaptive behavior
     *
     * @param handle notification handle
     * @return polling interval in milliseconds
     */
    private long determinePollInterval(ChangeNotificationHandle handle) {
        int failures = getFailureCount(handle);

        // Base interval starts at 1 second, increases with failures

import jcifs.internal.SMBProtocolDecodingException;

/**
 * Test class for FileBasicInfo
 */
class FileBasicInfoTest {

    private FileBasicInfo fileBasicInfo;
    // Use realistic time values in milliseconds since 1970 (Unix epoch)
    private static final long TEST_CREATE_TIME = System.currentTimeMillis() - 86400000L; // 1 day ago

        scheduleAddressChange(newAddress);
    }
}

private void scheduleReconnection(long delayMs) {
    CompletableFuture.delayedExecutor(delayMs, TimeUnit.MILLISECONDS)
        .execute(() -> {
            try {
                transport.disconnect();
                transport.connect();  // Reconnect
                log.info("Successfully reconnected after witness notification");