private static final Logger log = LoggerFactory.getLogger(LeaseManager.class);

    private final ConcurrentHashMap<Smb2LeaseKey, LeaseEntry> leases;
    private final ConcurrentHashMap<String, Smb2LeaseKey> pathToLease;
    private final ConcurrentHashMap<String, WeakReference<SmbFile>> fileCache;
    private final ReadWriteLock lock;
    private final CIFSContext context;
    private final ScheduledExecutorService cleanupExecutor;

 */
class OkHttpClientTestRule :
  BeforeEachCallback,
  AfterEachCallback {
  private val clientEventsList = mutableListOf<String>()
  private var testClient: OkHttpClient? = null
  private var uncaughtException: Throwable? = null
  private lateinit var testName: String
  private var defaultUncaughtExceptionHandler: Thread.UncaughtExceptionHandler? = null
  private var taskQueuesWereIdle: Boolean = false

    assertThat(cacheEvents()).containsExactly("CacheMiss")
  }

  private fun cacheEvents(): List<String> =
    eventListener.recordedEventTypes().filter { it.contains("Cache") }.also {
      eventListener.clearAllEvents()
    }

  private fun dnsResponse(s: String): MockResponse =
    MockResponse
      .Builder()
      .body(Buffer().write(s.decodeHex()))

            for (int _i = 0; _i < _uuid_nodes; _i++) {
                this.uuid.node[_i] = (byte) _src.dec_ndr_small();
            }
        }
    }

    /**
     * Unicode string structure for DCE/RPC operations.
     * Represents a Unicode string with length information.
     */
    public static class unicode_string extends NdrObject {

        /**
         * Default constructor for unicode_string.
         */

     * Returns a display-friendly identifier combining the dictionary ID and entry ID.
     * This method creates a composite identifier for UI display purposes.
     *
     * @return A string in the format "dictId:id" for display purposes
     */
    public String getDisplayId() {
        return dictId + ":" + id;
    }

        }
        dictionaryManager.addCreator(this);
    }

    @Override
    protected DictionaryFile<? extends DictionaryItem> newDictionaryFile(final String id, final String path, final Date timestamp) {
        return new ProtwordsFile(id, path, timestamp).manager(dictionaryManager);
    }

     * Constructs a new SSO process exception with the specified detailed message.
     *
     * @param message The detailed error message explaining the cause of the exception
     */
    public SsoProcessException(final String message) {
        super(message);
    }

    /**
     * Constructs a new SSO process exception with the specified detailed message and cause.
     *

    ConsoleHandler().apply {
      level = Level.FINE
      formatter =
        object : SimpleFormatter() {
          override fun format(record: LogRecord) = String.format("[%1\$tF %1\$tT] %2\$s %n", record.millis, record.message)
        }
    }

  fun enable(
    loggerClass: String,
    handler: Handler = logHandler(),
  ): Closeable {
    val logger = Logger.getLogger(loggerClass)
    if (configuredLoggers.add(logger)) {

        println("Response 1 response:          $it")
        println("Response 1 cache response:    ${it.cacheResponse}")
        println("Response 1 network response:  ${it.networkResponse}")
        return@use it.body.string()
      }

    val response2Body =
      client.newCall(request).execute().use {
        if (!it.isSuccessful) throw IOException("Unexpected code $it")

        println("Response 2 response:          $it")

        .build();

    try (Response response = client.newCall(request).execute()) {
      System.out.println(response.body().string());
    }

    server.shutdown();
    socketFile.delete();
  }

  public static void main(String... args) throws Exception {
    new ClientAndServer().run();
  }