* Maximum transmit buffer size for DCERPC messages
     */
    protected int max_xmit = 4280;
    /**
     * Maximum receive buffer size for DCERPC messages
     */
    protected int max_recv = max_xmit;
    /**
     * The current state of the DCERPC connection
     */
    protected int state = 0;
    /**
     * The security provider for authentication and message protection
     */

            fail("Expected ExtractException");
        } catch (final ExtractException e) {
            assertTrue("Error message should mention ZIP archive", e.getMessage().contains("ZIP archive"));
            assertTrue("Error message should indicate failure",
                    e.getMessage().contains("Failed to extract") || e.getMessage().contains("No entries could be processed"));
        }
    }

    /**

import jcifs.smb.SmbException;
import jcifs.util.Hexdump;
import jcifs.util.Strings;

/**
 * Base class for all SMB1/CIFS protocol message blocks.
 * This abstract class provides the fundamental structure and common functionality for SMB1 request
 * and response messages, including header fields, message encoding/decoding, and wire format handling.
 */

                logger.debug("WildcardQuery: query={}, boost={}", query, boost);
            }
            return convertWildcardQuery(context, wildcardQuery, boost);
        }
        throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                "Unknown q: " + query.getClass() + " => " + query);
    }

    /**

                throw new InvalidQueryException(messages -> messages.addErrorsInvalidQuerySortValue(UserMessages.GLOBAL_PROPERTY_KEY, text),
                        "Invalid sort field: " + termQuery);
            }
            final String sortField = values[0];
            if (!getQueryFieldConfig().isSortField(sortField)) {
                throw new InvalidQueryException(

    private void mockResponse(int code, String message, Map<String, List<String>> headers, InputStream errorStream) throws IOException {
        mockResponse(this.mockConnection, code, message, headers, errorStream);
    }

    /**
     * Helper method to mock the response of a specific HttpURLConnection instance.
     */

                throw new SsoMessageException(
                        messages -> messages.addErrorsFailedToProcessSsoRequest(UserMessages.GLOBAL_PROPERTY_KEY, e.getMessage()),
                        "Failed to process metadata.", e);
            }
        })
                .orElseThrow(() -> new SsoMessageException(
                        messages -> messages.addErrorsFailedToProcessSsoRequest(UserMessages.GLOBAL_PROPERTY_KEY, "Invalid state."),

            if (queryCommand != null) {
                return queryCommand.execute(context, query, boost);
            }
            throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                    "Unknown q: " + query.getClass() + " => " + query);
        };
    }

    /**
     * Interface for query processing filters.

    }

    /**
     * Gets the next message in the compound chain.
     *
     * @return the next message or null if this is the last message
     */
    protected ServerMessageBlock2 getNext() {
        return this.next;
    }

    /**
     * Sets the next message in the compound chain.
     *
     * @param n the next message
     */
    protected void setNext(final ServerMessageBlock2 n) {

        return this.readDataAvailable;
    }

    /**
     * Gets the number of messages available in the pipe
     * @return the numberOfMessages
     */
    public int getNumberOfMessages() {
        return this.numberOfMessages;
    }

    /**
     * Gets the length of the first message in the pipe
     * @return the messageLength
     */
    public int getMessageLength() {