private static final Logger logger = LogManager.getLogger(FileConfig.class);

    private static final long serialVersionUID = 1L;

    protected volatile Pattern[] includedDocPathPatterns;

    protected volatile Pattern[] excludedDocPathPatterns;

    protected transient volatile Map<ConfigName, Map<String, String>> configParameterMap;

    protected CrawlerClientFactory crawlerClientFactory = null;

    public FileConfig() {

     */
    private static class IpAttempts {
        private final AtomicInteger recentAttempts = new AtomicInteger(0);
        private volatile Instant lastAttempt = Instant.now();
        private volatile Instant windowStart = Instant.now();
        private volatile Instant blockExpiry = null;
        private final AtomicBoolean blocked = new AtomicBoolean(false);

        void recordAttempt() {

    private final ExecutorService executor = newSingleThreadExecutor();

    FakeService() {
      tearDownStack.addTearDown(this);
    }

    volatile int startupCalled = 0;
    volatile int shutdownCalled = 0;
    volatile int runCalled = 0;

    @Override
    protected void startUp() throws Exception {
      assertEquals(0, startupCalled);
      assertEquals(0, runCalled);

    private final String classifier;

    private volatile String scope;

    private volatile File file;

    private ArtifactRepository repository;

    private String downloadUrl;

    private ArtifactFilter dependencyFilter;

    private ArtifactHandler artifactHandler;

    private List<String> dependencyTrail;

    private volatile String version;

    private VersionRange versionRange;

class HttpLoggingInterceptor
  @JvmOverloads
  constructor(
    private val logger: Logger = Logger.DEFAULT,
  ) : Interceptor {
    @Volatile private var headersToRedact = emptySet<String>()

    @Volatile private var queryParamsNameToRedact = emptySet<String>()

    @set:JvmName("level")
    @Volatile
    var level = Level.NONE

    enum class Level {
      /** No logs. */
      NONE,

      /**

     */
    public static class LeaseEntry {
        private final Smb2LeaseKey leaseKey;
        private volatile int leaseState;
        private volatile int epoch;
        private final long createTime;
        private volatile long lastAccessTime;
        private final String path;
        private volatile boolean breaking;

        /**
         * Create a new lease entry
         *
         * @param key lease key

    private static final Logger logger = LogManager.getLogger(LabelTypeHelper.class);

    /** A list of label type items. */
    protected volatile List<LabelTypeItem> labelTypeItemList;

    /** A list of label type patterns. */
    protected volatile List<LabelTypePattern> labelTypePatternList;

    /**
     * Default constructor.
     */
    public LabelTypeHelper() {
        super();
    }

  Callback {
  constructor(call: Call, listener: EventSourceListener) : this(call, call.request(), listener)

  constructor(response: Response, listener: EventSourceListener) : this(null, response.request, listener)

  @Volatile private var canceled = false

  override fun onResponse(
    call: Call,
    response: Response,
  ) {
    processResponse(response)
  }

  internal fun processResponse(response: Response) {

 */
public class ChannelInfo {

    private final String channelId;
    private volatile SmbTransport transport;
    private final NetworkInterfaceInfo localInterface;
    private final NetworkInterfaceInfo remoteInterface;
    private volatile ChannelState state;
    private final long establishedTime;
    private volatile long lastActivityTime;

    // Performance metrics
    private final AtomicLong bytesSent;

  private val http2Connection: Http2Connection,
) : ExchangeCodec {
  @Volatile private var stream: Http2Stream? = null

  private val protocol: Protocol =
    if (Protocol.H2_PRIOR_KNOWLEDGE in client.protocols) {
      Protocol.H2_PRIOR_KNOWLEDGE
    } else {
      Protocol.HTTP_2
    }

  @Volatile
  private var canceled = false

  override val isResponseComplete: Boolean