/**
     * Function code to validate SMB2 negotiate information
     */
    public static final int FSCTL_VALIDATE_NEGOTIATE_INFO = 0x000140204;

    /**
     * Flag indicating this IOCTL is a file system control operation
     */
    public static final int SMB2_O_IOCTL_IS_FSCTL = 0x1;

    private byte[] fileId;
    private final int controlCode;
    private final byte[] outputBuffer;

    protected static final LoggerAdapterFactory factory = getLoggerAdapterFactory();

    /** Map of loggers keyed by class */
    protected static final Map<Class<?>, Logger> loggers = newHashMap();

    /** Flag indicating initialization is complete. */
    private static boolean initialized;

    /** Logger adapter. */
    private final LoggerAdapter log;

    /**
     * Returns a {@link Logger}.
     *
     * @param clazz

        public TextNormalizeContext maxSymbolTermSize(final int maxSymbolTermSize) {
            this.maxSymbolTermSize = maxSymbolTermSize;
            return this;
        }

        /**
         * Sets the flag indicating whether duplicate terms should be removed.
         *
         * @param duplicateTermRemoved true if duplicate terms should be removed, false otherwise
         * @return the current instance of {@link TextNormalizeContext}

         * the andx command will not be written and therefore the
         * response will not read a batched command and therefore
         * the 'received' member of the response object will not
         * be set to true indicating the send and sendTransaction
         * methods that the next part should be sent. This is a
         * very indirect and simple batching control mechanism.
         */

     *
     * @param dictId identifier of the dictionary to upload mapping for
     * @param form upload form containing the file and metadata
     * @return JSON response indicating the API result status
     */
    // PUT /api/admin/dict/mapping/upload/{dictId}
    @Execute
    public JsonResponse<ApiResult> put$upload(final String dictId, final UploadForm form) {
        form.dictId = dictId;

    protected Set<String> highlightedQuerySet = null;

    /** Map storing field names and their associated query terms for logging. */
    protected Map<String, List<String>> fieldLogMap = null;

    /** Flag indicating whether role-based query filtering should be disabled. */
    protected boolean disableRoleQuery = false;

    /** The default field to search in when no specific field is specified. */
    protected String defaultField = null;

    private static final long serialVersionUID = -2832037191318016836L;

    /** The ANSI password hash */
    private byte[] ansiHash;
    /** The Unicode password hash */
    private byte[] unicodeHash;
    /** Flag indicating if hashes are externally provided */
    private boolean hashesExternal = false;
    /** The CIFS context for this authentication */
    private CIFSContext context;

    /**
     *
     */

    }

    /**
     * Deletes a document by ID from the search index.
     *
     * @param id the document ID to delete
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/searchlist/doc/{doc_id}
    @Execute
    public JsonResponse<ApiResult> delete$doc(final String id) {
        try {

    private static final Logger logger = LogManager.getLogger(ESSourceReader.class);

    /** Queue of documents. */
    protected final Queue<Map<String, Object>> queue = new ConcurrentLinkedQueue<>();
    /** Flag indicating if reading is finished. */
    protected final AtomicBoolean isFinished = new AtomicBoolean(false);

    /** OpenSearch client. */
    protected final Client client;
    /** Suggest settings. */

     * This class handles the writing and committing of changes to the dictionary file.
     */
    protected class ProtwordsUpdater implements Closeable {

        /** Flag indicating if the update should be committed */
        protected boolean isCommit = false;

        /** Temporary file for storing updates */
        protected File newFile;