private var port = 0
  private val executor = Executors.newSingleThreadExecutor(threadFactory("MockHttp2Peer"))
  private var serverSocket: ServerSocket? = null
  private var socket: Socket? = null

  fun setClient(client: Boolean) {
    if (this.client == client) return
    this.client = client
    writer = Http2Writer(bytesOut, client)
  }

  fun acceptFrame() {
    frameCount++
  }

     * Total number of pages.
     */
    private int allPageCount;

    /**
     * Flag indicating whether a previous page exists.
     */
    private boolean existPrePage;

    /**
     * Flag indicating whether a next page exists.
     */
    private boolean existNextPage;

    /**
     * List of page numbers for pagination navigation.
     */
    private List<Integer> pageNumberList;

    /**

    }

    @Override
    public boolean isPublic() {
        return MethodUtil.isPublic(method);
    }

    @Override
    public boolean isStatic() {
        return MethodUtil.isStatic(method);
    }

    @Override
    public boolean isFinal() {
        return MethodUtil.isFinal(method);
    }

    @Override
    public boolean isAbstract() {

    override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route
  }

  data class ConnectEnd(
    override val timestampNs: Long,
    override val connection: Connection,
    val route: Route,
    val call: Call,
  ) : ConnectionEvent() {
    override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route

            if (connectFails) {
                throw new IOException("Connect failed");
            }
        }

        @Override
        protected boolean doDisconnect(boolean hard, boolean inUse) throws IOException {
            return disconnectResult;
        }

        // Test control methods
        public void setState(int state) {
            this.state = state;
        }

     * Property {@code jcifs.smb.client.dfs.strictView} (boolean, default false)
     *
     * @return whether a authentication failure during DFS resolving will throw an exception
     */
    boolean isDfsStrictView();

    /**
     *
     * Property {@code jcifs.smb.client.dfs.disabled} (boolean, default false)
     *
     * @return whether DFS lookup is disabled
     */
    boolean isDfsDisabled();

    /**

 * Unicode string type wrapper
 *
 */
public class UnicodeString extends rpc.unicode_string {

    boolean zterm;

    /**
     * Constructs a UnicodeString with zero termination option.
     *
     * @param zterm
     *            whether the string should be zero terminated
     */
    public UnicodeString(final boolean zterm) {
        this.zterm = zterm;
    }

    /**

    private ConcreteNdrObject ndrObject;

    // A concrete implementation of NdrObject for testing purposes.
    private static class ConcreteNdrObject extends NdrObject {
        private boolean throwOnEncode = false;
        private boolean throwOnDecode = false;

        @Override
        public void encode(NdrBuffer dst) throws NdrException {
            if (throwOnEncode) {
                throw new NdrException("Failed to encode");

    /** Total number of pages calculated from record count and page size. */
    private int allPageCount;

    /** Flag indicating whether a previous page exists. */
    private boolean existPrePage;

    /** Flag indicating whether a next page exists. */
    private boolean existNextPage;

    /** List of page numbers for pagination navigation. */
    private List<Integer> pageNumberList;

    /** Number of records to display per page. */

    .default(DEFAULT_TIMEOUT)

  val followRedirects: Boolean by option("-L", "--location").help("Follow redirects").flag()

  val allowInsecure: Boolean by option("-k", "--insecure").help("Allow connections to SSL sites without certs").flag()

  val showHeaders: Boolean by option("-i", "--include").help("Include protocol headers in the output").flag()

  val showHttp2Frames: Boolean by option("--frames").help("Log HTTP/2 frames to STDERR").flag()