* the execution or processing of jobs in the system.
 */
public class JobProcessingException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new JobProcessingException with the specified cause.
     *
     * @param e the cause of the exception
     */
    public JobProcessingException(final Throwable e) {
        super(e);

) {
  if (isLoggable(Level.FINE)) {
    log(task, queue, messageBlock())
  }
}

internal inline fun <T> Logger.logElapsed(
  task: Task,
  queue: TaskQueue,
  block: () -> T,
): T {
  var startNs = -1L
  val loggingEnabled = isLoggable(Level.FINE)
  if (loggingEnabled) {
    startNs = queue.taskRunner.backend.nanoTime()
    log(task, queue, "starting")
  }

  var completedNormally = false
  try {

        ingestFactory = new TestIngestFactory();

        // Setup FessConfig
        fessConfig = new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

            @Override
            public String getIndexerDataMaxDocumentRequestSize() {
                return "1048576"; // 1MB
            }

            @Override

import org.codelibs.fess.util.ComponentUtil;

/**
 * @author FreeGen
 */
public class JobLog extends BsJobLog {

    private static final long serialVersionUID = 1L;

    private ScheduledJob scheduledJob;

    public JobLog() {
    }

    public JobLog(final ScheduledJob scheduledJob) {
        this.scheduledJob = scheduledJob;
        setJobName(scheduledJob.getName());

        generator.setCommandTimeout(-1L);
        assertTrue(true);

        // Test very large timeout
        generator.setCommandTimeout(Long.MAX_VALUE);
        assertTrue(true);

        // Test destroy timeout
        generator.setCommandDestroyTimeout(0L);
        assertTrue(true);

        generator.setCommandDestroyTimeout(-1L);
        assertTrue(true);

import org.dbflute.optional.OptionalEntity;

/**
 * @author FreeGen
 */
public class SearchLog extends BsSearchLog implements SearchLogEvent {

    private static final long serialVersionUID = 1L;

    private final List<Pair<String, String>> searchFieldLogList = new ArrayList<>();

    private final List<Pair<String, String>> headerList = new ArrayList<>();

    private OptionalEntity<UserInfo> userInfo;

 * - File handle leaks
 * - Connection pool exhaustion
 * - Memory allocation failures
 * - Quota exceeded
 */
public class SmbResourceException extends SmbException {

    private static final long serialVersionUID = 1L;

    /**
     * Resource type that caused the error
     */
    public enum ResourceType {
        FILE_HANDLE, CONNECTION, MEMORY, DISK_SPACE, QUOTA, LOCK, BUFFER, THREAD_POOL
    }

        // Arrange: filter that accepts only strictly positive length
        SmbFileFilter filter = f -> f.length() > 0;

        // negative size -> reject
        when(smbFile.length()).thenReturn(-1L);
        assertFalse(filter.accept(smbFile), "Negative size should be rejected");
        verify(smbFile, times(1)).length();

        // zero size -> reject
        reset(smbFile);

        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

            @Override
            public String getRoleSearchUserPrefix() {
                return fessConfig.getRoleSearchUserPrefix();
            }

            @Override

/**
 * @param <ENTITY> The type of entity.
 * @author ESFlute (using FreeGen)
 */
public class EsPagingResultBean<ENTITY> extends PagingResultBean<ENTITY> {

    private static final long serialVersionUID = 1L;

    protected long took;
    private int totalShards;
    private int successfulShards;
    private int failedShards;
    private TotalHits totalHits;
    private Aggregations aggregations;