private final int bufferSize;

  /** Number of bytes processed per process() invocation. */
  private final int chunkSize;

  /**
   * Constructor for use by subclasses. This hasher instance will process chunks of the specified
   * size.
   *
   * @param chunkSize the number of bytes available per {@link #process(ByteBuffer)} invocation;
   *     must be at least 4
   */

    protected String allRecordCountRelation;

    /** Total number of pages based on record count and page size. */
    protected int allPageCount;

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

    /** Flag indicating whether a previous page exists. */
    protected boolean existPrevPage;

    /** Starting record number for the current page. */
    protected long currentStartRecordNumber;

        // Set up mock provider to return TCP memory regions
        when(mockProvider.registerMemory(any(ByteBuffer.class), any())).thenAnswer(invocation -> {
            ByteBuffer buffer = invocation.getArgument(0);
            EnumSet<RdmaAccess> access = invocation.getArgument(1);
            return new TcpMemoryRegion(buffer, access);
        });

        bufferManager = new RdmaBufferManager(mockProvider);
    }

     * SID type indicating a domain.
     */
    public static final int SID_TYPE_DOMAIN = lsarpc.SID_NAME_DOMAIN;
    /**
     * SID type indicating a local group or alias.
     */
    public static final int SID_TYPE_ALIAS = lsarpc.SID_NAME_ALIAS;
    /**
     * SID type indicating a well-known group.
     */
    public static final int SID_TYPE_WKN_GRP = lsarpc.SID_NAME_WKN_GRP;
    /**
     * SID type indicating a deleted account.

     */
    private int allRecordCount;

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

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

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

    /**
     * List of page numbers for pagination.
     */

  protected AbstractService() {}

  /**
   * This method is called by {@link #startAsync} to initiate service startup. The invocation of
   * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
   * or after it has returned. If startup fails, the invocation should cause a call to {@link
   * #notifyFailed(Throwable)} instead.
   *

    /**
     * Session flag indicating this is a guest session
     */
    public static final int SMB2_SESSION_FLAGS_IS_GUEST = 0x1;

    /**
     * Session flag indicating this is a null/anonymous session
     */
    public static final int SMB2_SESSION_FLAGS_IS_NULL = 0x2;

    /**
     * Session flag indicating data encryption is required for this session
     */

     *
     * @return true if a previous page exists, false otherwise
     */
    public boolean isExistPrePage() {
        return existPrePage;
    }

    /**
     * Sets the flag indicating whether a previous page exists.
     *
     * @param existPrePage true if a previous page exists, false otherwise
     */
    public void setExistPrePage(final boolean existPrePage) {

        // Mock transport.connect() to succeed
        doNothing().when(transport).connect();

        // Setup response for tree connect
        doAnswer(invocation -> {
            ServerMessageBlock request = invocation.getArgument(0);
            ServerMessageBlock response = invocation.getArgument(1);
            if (request instanceof SmbComTreeConnectAndX && response instanceof SmbComTreeConnectAndXResponse) {

        if (lmCompatibility == 3 || lmCompatibility == 4 || lmCompatibility == 5) {
            // For LM compatibility 3-5, only 16 bytes are used
            doAnswer(invocation -> {
                byte[] dest = invocation.getArgument(2);
                int offset = invocation.getArgument(3);
                System.arraycopy(new byte[16], 0, dest, offset, 16);
                return null;