import java.util.concurrent.TimeoutException;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import org.jspecify.annotations.Nullable;

/**
 * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is
 * interrupted during such a call, the call continues to block until the result is available or the
 * timeout elapses, and only then re-interrupts the thread.

        IOException exception = assertThrows(IOException.class, () -> {
            SessionServicePacket.readPacketType(bais, buffer, 0);
        });

        assertEquals("unexpected EOF reading netbios session header", exception.getMessage());
    }

    @Test
    @DisplayName("readPacketType should throw IOException on incomplete header")
    void testReadPacketTypeIncompleteHeader() {

import org.codelibs.fess.exception.FessSystemException;

/**
 * Exception thrown when dictionary operations encounter errors.
 * This exception is typically used for issues during dictionary file
 * reading, writing, parsing, or other dictionary-related operations.
 */
public class DictionaryException extends FessSystemException {

    /** Serial version UID for serialization. */

        assertEquals(expectedTime, response.getLastWriteTime());
        assertEquals(expectedTime, response.getLastAccessTime());
    }

    @Test
    void testReadParameterWordsWireFormatWithData() {
        // Test reading parameter words from wire format
        response = new SmbComQueryInformationResponse(mockConfig, 0L);

        // Prepare test data
        byte[] buffer = new byte[256];
        int bufferIndex = 0;

        SessionRequestPacket packet = new SessionRequestPacket(mockConfig);
        packet.length = 100; // Expect more data than available

        // Create a larger buffer for reading to avoid IndexOutOfBoundsException
        byte[] readBuffer = new byte[100];
        assertThrows(IOException.class, () -> {
            packet.readTrailerWireFormat(bais, readBuffer, 0);
        });
    }

import org.codelibs.fess.dict.DictionaryFile;
import org.codelibs.fess.dict.DictionaryItem;

import jakarta.annotation.PostConstruct;

/**
 * A dictionary creator for stopwords files.
 * This class is responsible for creating {@link StopwordsFile} instances
 * from files that match the pattern "stopwords.*\\.txt".
 */
public class StopwordsCreator extends DictionaryCreator {

    /**
     * The timestamp when this related content was created.
     */
    @ValidateTypeFailure
    public Long createdTime;

    /**
     * Initializes the form with default values for creating new related content.
     */
    public void initialize() {
        crudMode = CrudMode.CREATE;
        createdBy = ComponentUtil.getSystemHelper().getUsername();

package org.codelibs.fess.thumbnail;

import java.io.File;
import java.util.Map;

import org.codelibs.core.misc.Tuple3;

/**
 * Interface for thumbnail generation implementations.
 * Provides methods for creating thumbnails from various document types.
 */
public interface ThumbnailGenerator {

    /**
     * Gets the name of this thumbnail generator.
     * @return The generator name.
     */
    String getName();

    public void test_ofNullable_performanceAndMemory() {
        // Test creating many OptionalEntity instances
        for (int i = 0; i < 1000; i++) {
            OptionalEntity<Integer> opt = OptionalUtil.ofNullable(i);
            assertTrue(opt.isPresent());
            assertEquals(Integer.valueOf(i), opt.get());
        }

        // Test creating many empty OptionalEntity instances
        for (int i = 0; i < 1000; i++) {

import java.io.EOFException;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

/**
 * An implementation of {@link DataInput} that uses little-endian byte ordering for reading {@code
 * short}, {@code int}, {@code float}, {@code double}, and {@code long} values.
 *
 * <p><b>Note:</b> This class intentionally violates the specification of its supertype {@code