# Whether to replace term with prefix query.
query.replace.term.with.prefix.query=true
# Minimum hit count for OR search queries.
query.orsearch.min.hit.count=-1
# Unicode terminal characters for query highlighting.
query.highlight.terminal.chars=u0021u002Cu002Eu003Fu0589u061Fu06D4u0700u0701u0702u0964u104Au104Bu1362u1367u1368u166Eu1803u1809u203Cu203Du2047u2048u2049u3002uFE52uFE57uFF01uFF0EuFF1FuFF61
# Fragment size for query highlighting.

    /** HTML-escaped highlight prefix */
    protected String escapedHighlightPre = null;

    /** HTML-escaped highlight suffix */
    protected String escapedHighlightPost = null;

    /** Set of terminal characters for highlighting */
    protected Set<Integer> highlightTerminalCharSet = new HashSet<>();

    /** Action hook for custom processing */
    protected ActionHook actionHook = new ActionHook();

    public static final String LABELS_CITY = "{labels.city}";

    /** The key of the message: Teletex Terminal Identifier */
    public static final String LABELS_user_teletexTerminalIdentifier = "{labels.user_teletexTerminalIdentifier}";

    /** The key of the message: Teletex Terminal Identifier */
    public static final String LABELS_TELETEX_TERMINAL_IDENTIFIER = "{labels.teletexTerminalIdentifier}";

    /**
     * Get the value for the key 'query.highlight.terminal.chars'. <br>
     * The value is, e.g. u0021u002Cu002Eu003Fu0589u061Fu06D4u0700u0701u0702u0964u104Au104Bu1362u1367u1368u166Eu1803u1809u203Cu203Du2047u2048u2049u3002uFE52uFE57uFF01uFF0EuFF1FuFF61 <br>
     * comment: Unicode terminal characters for query highlighting.

import jcifs.Configuration;
import jcifs.internal.smb2.ServerMessageBlock2Request;
import jcifs.internal.smb2.Smb2Constants;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Logoff request message. This command is used to terminate an SMB2 session.
 *
 * @author mbechler
 *
 */
public class Smb2LogoffRequest extends ServerMessageBlock2Request<Smb2LogoffResponse> {

    /**

import jcifs.Configuration;
import jcifs.internal.smb1.AndXServerMessageBlock;
import jcifs.internal.smb1.ServerMessageBlock;

/**
 * SMB1 Logoff AndX request message.
 *
 * This command is used to terminate a user session that was
 * previously established with a Session Setup AndX command.
 */
public class SmbComLogoffAndX extends AndXServerMessageBlock {

    /**

        }
        return crawlerContext.sessionId;
    }

    /**
     * Waits for the crawling process to terminate indefinitely.
     */
    public void awaitTermination() {
        awaitTermination(0);
    }

    /**
     * Waits for the crawling process to terminate for a specified duration.
     * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely.
     */

            if (logger.isDebugEnabled()) {
                logger.debug("TimeoutManager stopped.");
            }
        }
    }

    /**
     * Interrupts the thread and waits for it to terminate.
     *
     * @param timeoutMillis
     *            The time to wait (in milliseconds)
     * @return <code>true</code> if the thread has terminated
     * @throws InterruptedException

         * @return true if the thread is actively executing
         */
        public boolean isRunning() {
            return running;
        }

        /**
         * Waits for the crawling thread to terminate.
         * This method blocks until the thread completes its execution.
         * Interrupted exceptions are caught and logged at debug level.
         */
        public void awaitTermination() {
            try {

     * <li>Sends processed documents to the search engine</li>
     * <li>Cleans up processed data and manages crawler sessions</li>
     * </ul>
     *
     * <p>The method includes error handling, retry logic, and will terminate
     * if too many empty results are encountered or if a system shutdown is requested.
     */
    @Override
    public void run() {
        if (dataService == null) {