int decoded = resp.decode(buf, headerStart);
        assertTrue(decoded > 0, "Decode should return positive length");

        assertEquals(NtStatus.NT_STATUS_MORE_PROCESSING_REQUIRED, resp.getStatus());
        assertArrayEquals(blob, resp.getBlob(), "Security blob should match");
        assertEquals(sessionFlags, resp.getSessionFlags(), "Session flags should decode");

        SMBUtil.writeInt2(2, buffer, bufferIndex + 64);

        // Decode the response
        int result = response.decode(buffer, bufferIndex);

        assertEquals(66, result);
        assertEquals(0, response.getStatus()); // Should be STATUS_SUCCESS
    }

    @Test
    @DisplayName("Test readBytesWireFormat preserves buffer content")
    void testReadBytesWireFormatPreservesBuffer() throws SMBProtocolDecodingException {

            this.next.setDigest(digest);
        }
    }

    /**
     * Gets the status code for this message.
     *
     * @return the status
     */
    public final int getStatus() {
        return this.status;
    }

    /**
     * Gets the session identifier for this message.
     *
     * @return the sessionId
     */
    public long getSessionId() {

                }

                // Attempt to reset the connection
                connection.reset();

                // Verify connection is working
                if (connection.getState() == RdmaConnection.RdmaConnectionState.ESTABLISHED) {
                    log.info("RDMA connection recovery successful after {} attempts", retryCount);
                    return true;
                }

        return receiveCredits.get();
    }

    /**
     * Get connection state
     *
     * @return current connection state
     */
    public RdmaConnectionState getState() {
        return state;
    }

    /**
     * Get remote address
     *
     * @return remote socket address
     */
    public InetSocketAddress getRemoteAddress() {

     */
    public void stop() {
        if (logger.isInfoEnabled()) {
            logger.info("Stopping crawler: sessionId={}, status={}", crawlerContext.sessionId, crawlerContext.getStatus());
        }
        crawlerContext.setStatus(CrawlerStatus.DONE);
        try {
            if (crawlerThreadGroup != null) {
                crawlerThreadGroup.interrupt();

                        throw new SmbAuthException("Login failed", e);
                    }
                    if (!sessResponse.isReceived() || sessResponse.isError() || sessResponse.getStatus() != NtStatus.NT_STATUS_SUCCESS
                            && sessResponse.getStatus() != NtStatus.NT_STATUS_MORE_PROCESSING_REQUIRED) {
                        throw e;
                    }
                    ex = e;

        this.creditsRequested = creditsRequested;
    }

    /**
     * Get the negotiation status
     *
     * @return status code
     */
    public int getStatus() {
        return status;
    }

    /**
     * Set the negotiation status
     *
     * @param status status code
     */
    public void setStatus(int status) {
        this.status = status;

                    continue;
                }

                // check status
                for (int i = 0; i < startedCrawlerNum; i++) {
                    if (crawlerList.get(i).getCrawlerContext().getStatus() == CrawlerStatus.DONE
                            && Constants.RUNNING.equals(crawlerStatusList.get(i))) {
                        crawlerList.get(i).awaitTermination();

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#isErrorResponseStatus()
     */
    @Override
    protected boolean isErrorResponseStatus() {
        final int status = getStatus();
        return status != NtStatus.NT_STATUS_INVALID_PARAMETER && ((status != NtStatus.NT_STATUS_INVALID_PARAMETER)