byte[] buf = new byte[4280]; // Use maxRecv size

            // Mock initial receive with valid PDU header
            when(mockSmbPipeHandleInternal.recv(buf, 0, buf.length)).thenAnswer(invocation -> {
                byte[] buffer = invocation.getArgument(0);
                buffer[0] = 5; // Valid PDU version
                buffer[1] = 0; // Valid PDU type
                Encdec.enc_uint16le((short) 50, buffer, 8); // Fragment length

    /**
     * Named pipe status indicating the pipe is disconnected.
     */
    public static final int STATUS_DISCONNECTED = 1;

    /**
     * Named pipe status indicating the pipe is listening for connections.
     */
    public static final int STATUS_LISTENING = 2;

    /**
     * Named pipe status indicating the connection is established and operational.
     */

 */
public class NegTokenTarg extends SpnegoToken {

    /**
     * Result code indicating unspecified result
     */
    public static final int UNSPECIFIED_RESULT = -1;
    /**
     * Result code indicating authentication completed successfully
     */
    public static final int ACCEPT_COMPLETED = 0;
    /**
     * Result code indicating authentication is incomplete and additional tokens required
     */

    protected final long allRecordCount;

    /** The relation type indicating how the record count should be interpreted (e.g., "eq", "gte"). */
    protected final String allRecordCountRelation;

    /** The time taken to execute the search query in milliseconds. */
    protected final long queryTime;

    /** Flag indicating whether the search results are partial due to timeout or other constraints. */

  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
   */

        return asJson(new ApiResult.ApiConfigResponse().setting(body).status(ApiResult.Status.OK).result());
    }

    /**
     * Deletes all suggest words from the system.
     *
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/suggest/all
    @Execute
    public JsonResponse<ApiResult> delete$all() {
        if (!suggestHelper.deleteAllWords()) {

      continue

    url = result_store_line_match.group(1)
    url_lines = result_store_links.setdefault(url, {})
    # Each bazel RBE invocation should produce two
    # 'Streaming build results to: ...' lines, one at the start, and one at the
    # end of the invocation.
    # If there's a failure message, it will be found in-between these two.

    if not current_url:
      url_lines['start'] = i

    /** Total number of records available */
    private int allRecordCount;

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

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

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

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

        // Setup for successful close
        ArgumentCaptor<MsrpcSamrCloseHandle> closeCaptor = ArgumentCaptor.forClass(MsrpcSamrCloseHandle.class);
        doAnswer(invocation -> {
            MsrpcSamrCloseHandle rpc = invocation.getArgument(0);
            rpc.retval = 0; // Simulate success
            return null;
        }).when(mockHandle).sendrecv(closeCaptor.capture());

    private int allRecordCount;

    /** Total number of pages available for pagination. */
    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 to display in pagination navigation. */