public void awaitTermination() {
        awaitTermination(0);
    }

    /**
     * Waits for the crawling process to terminate for a specified duration.
     * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely.
     */
    public void awaitTermination(final long millis) {
        if (parentThread != null) {
            try {
                parentThread.join(millis);

            // Verify timeout occurs
            assertThrows(TimeoutException.class, () -> {
                future.get(100, TimeUnit.MILLISECONDS);
            });

            // Cancel the future
            future.cancel(true);
        } finally {
            executor.shutdownNow();
        }
    }

    server.enqueue(MockResponse(body = "a"))
    server.enqueue(MockResponse(body = "b"))
    client =
      client
        .newBuilder()
        .connectionPool(ConnectionPool(5, 250, TimeUnit.MILLISECONDS))
        .build()
    val request = Request(server.url("/"))
    val response1 = client.newCall(request).execute()
    assertThat(response1.body.string()).isEqualTo("a")

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.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.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) {

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