*/

/**
 * Abstract base class for network transport implementations in JCIFS.
 * This class handles the low-level transport protocol for SMB communication.
 */
public abstract class Transport implements Runnable, AutoCloseable {

    /**
     * Default constructor for Transport
     */
    protected Transport() {
        // Default constructor
    }

    private static int id = 0;

 * Provides functionality for NetBIOS name resolution and network discovery operations.
 *
 * @author mbechler
 */
public class NameServiceClientImpl implements Runnable, NameServiceClient {

    private static final int NAME_SERVICE_UDP_PORT = 137;

    static final byte[] UNKNOWN_MAC_ADDRESS = { (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00 };

	public final fun getIdleCallback ()Ljava/lang/Runnable;
	public final fun getMaxRequests ()I
	public final fun getMaxRequestsPerHost ()I
	public final fun queuedCalls ()Ljava/util/List;
	public final fun queuedCallsCount ()I
	public final fun runningCalls ()Ljava/util/List;
	public final fun runningCallsCount ()I
	public final fun setIdleCallback (Ljava/lang/Runnable;)V
	public final fun setMaxRequests (I)V

    val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost
    dispatcher.maxRequestsPerHost = 0
    val executorService: ExecutorService = dispatcher.executorService
    dispatcher.idleCallback = Runnable { TODO() }
    val queuedCalls: List<Call> = dispatcher.queuedCalls()
    val runningCalls: List<Call> = dispatcher.runningCalls()
    val queuedCallsCount: Int = dispatcher.queuedCallsCount()

	public final fun getIdleCallback ()Ljava/lang/Runnable;
	public final fun getMaxRequests ()I
	public final fun getMaxRequestsPerHost ()I
	public final fun queuedCalls ()Ljava/util/List;
	public final fun queuedCallsCount ()I
	public final fun runningCalls ()Ljava/util/List;
	public final fun runningCallsCount ()I
	public final fun setIdleCallback (Ljava/lang/Runnable;)V
	public final fun setMaxRequests (I)V

            .build();

        final long startNanos = System.nanoTime();
        final Call call = client.newCall(request);

        // Schedule a job to cancel the call in 1 second.
        executor.schedule(new Runnable() {
          @Override public void run() {
            System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f);
            call.cancel();

    sink.writeUtf8(bytes)
    sink.close()
    return bytesOut
  }

  internal inner class AsyncRequest(
    val path: String,
    val countDownLatch: CountDownLatch,
  ) : Runnable {
    override fun run() {
      try {
        val call =
          client.newCall(
            Request
              .Builder()
              .url(server.url(path))
              .build(),

    }

    @Override
    void maybeClearReferenceQueues() {
      clearReferenceQueue(queueForKeys);
    }
  }

  static final class CleanupMapTask implements Runnable {
    final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference;

    public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) {
      this.mapReference = new WeakReference<>(map);
    }

        return whenClosed = new CountDownLatch(1);
      }
    }
  }

  /**
   * Returns an object that can be used to wait until this objects' deferred closeables have all had
   * {@link Runnable}s that close them submitted to each one's closing {@link Executor}.
   */
  @VisibleForTesting
  CountDownLatch whenClosedCountDown() {
    try {
      return state.closeables.whenClosedCountDown();

    }

    @Override
    void maybeClearReferenceQueues() {
      clearReferenceQueue(queueForKeys);
    }
  }

  static final class CleanupMapTask implements Runnable {
    final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference;

    public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) {
      this.mapReference = new WeakReference<>(map);
    }