Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for JobProcess (0.04 sec)

  1. src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java

            Consumer<ProcessBuilder> pbCall = pb -> {
                pb.redirectErrorStream(true);
            };
    
            try {
                JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pbCall);
                assertNotNull(jobProcess);
                assertTrue(processHelper.isProcessRunning());
                assertTrue(processHelper.isProcessRunning(sessionId));
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 05:35:01 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            pbCall.accept(pb);
            destroyProcess(sessionId);
            JobProcess jobProcess;
            try {
                jobProcess = new JobProcess(pb.start(), bufferSize, outputCallback);
                destroyProcess(sessionId, runningProcessMap.putIfAbsent(sessionId, jobProcess));
                return jobProcess;
            } catch (final IOException e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/SuggestJob.java

                }
    
                final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> {
                    pb.directory(baseDir);
                    pb.redirectErrorStream(true);
                });
    
                final InputStreamThread it = jobProcess.getInputStreamThread();
                it.start();
    
                final Process currentProcess = jobProcess.getProcess();
                currentProcess.waitFor();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                }
    
                final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> {
                    pb.directory(baseDir);
                    pb.redirectErrorStream(true);
                });
    
                final InputStreamThread it = jobProcess.getInputStreamThread();
                it.start();
    
                final Process currentProcess = jobProcess.getProcess();
                currentProcess.waitFor();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/job/CrawlJob.java

                }
    
                final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> {
                    pb.directory(baseDir);
                    pb.redirectErrorStream(true);
                });
    
                final InputStreamThread it = jobProcess.getInputStreamThread();
                it.start();
    
                final Process currentProcess = jobProcess.getProcess();
                currentProcess.waitFor();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/job/GenerateThumbnailJobTest.java

    import org.codelibs.fess.mylasta.direction.FessConfig;
    
    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.codelibs.fess.util.ComponentUtil;
    import org.codelibs.fess.util.InputStreamThread;
    import org.codelibs.fess.util.JobProcess;
    
    import jakarta.servlet.ServletContext;
    
    public class GenerateThumbnailJobTest extends UnitFessTestCase {
    
        private GenerateThumbnailJob thumbnailJob;
        private TestProcessHelper testProcessHelper;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

            @Override
            public int destroyProcess(String sessionId) {
                // Mock implementation
                return 0;
            }
        }
    
        // Mock JobProcess implementation
        private class MockJobProcess extends JobProcess {
            private final int exitValue;
            private final String output;
    
            public MockJobProcess(int exitValue, String output) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/job/PythonJobTest.java

    import org.codelibs.fess.mylasta.direction.FessConfig;
    
    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.codelibs.fess.util.ComponentUtil;
    import org.codelibs.fess.util.InputStreamThread;
    import org.codelibs.fess.util.JobProcess;
    import org.codelibs.fess.util.SystemUtil;
    import org.lastaflute.job.JobManager;
    import org.lastaflute.job.key.LaJobUnique;
    import org.lastaflute.job.subsidiary.CronConsumer;
    
    import jakarta.servlet.ServletContext;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/job/CrawlJobTest.java

    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.dbflute.bhv.readable.EntityRowHandler;
    import org.codelibs.fess.util.ComponentUtil;
    import org.codelibs.fess.util.InputStreamThread;
    import org.codelibs.fess.util.JobProcess;
    import org.dbflute.bhv.readable.CBCall;
    import org.dbflute.cbean.result.PagingResultBean;
    
    import jakarta.servlet.ServletContext;
    
    public class CrawlJobTest extends UnitFessTestCase {
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25K bytes
    - Viewed (0)
Back to top