Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for destroyProcess (0.07 sec)

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

                // Since echo commands complete quickly, we may not catch them running
                // Just verify no exceptions occurred
    
                // Clean up
                processHelper.destroyProcess(sessionId1);
                processHelper.destroyProcess(sessionId2);
    
                // Test passes if no exceptions thrown
                assertTrue(true);
            } catch (Exception e) {
                fail("Unexpected exception: " + e.getMessage());
    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

            final ProcessBuilder pb = new ProcessBuilder(cmdList);
            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/PythonJob.java

            }
            resultBuf.append("Session Id: ").append(sessionId).append("\n");
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
            final TimeoutTask timeoutTask = createTimeoutTask();
            try {
                executePython();
            } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/job/SuggestJob.java

            }
            resultBuf.append("Session Id: ").append(sessionId).append("\n");
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
            final TimeoutTask timeoutTask = createTimeoutTask();
            try {
                executeSuggestCreator();
            } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

            }
            resultBuf.append("Session Id: ").append(sessionId).append("\n");
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
            final TimeoutTask timeoutTask = createTimeoutTask();
            try {
                executeThumbnailGenerator();
            } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/ExecJob.java

            }
            return TimeoutManager.getInstance().addTimeoutTarget(() -> {
                logger.warn("Process is terminated due to {} second exceeded.", timeout);
                ComponentUtil.getProcessHelper().destroyProcess(sessionId);
                processTimeout = true;
            }, timeout, false);
        }
    
        /**
         * Creates and stores system properties to the specified file.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/job/CrawlJob.java

                }
                resultBuf.append('\n');
            }
    
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
            final TimeoutTask timeoutTask = createTimeoutTask();
            try {
                executeCrawler();
                ComponentUtil.getKeyMatchHelper().update();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/job/CrawlJobTest.java

                    // Mock update
                }
            }, "keyMatchHelper");
    
            ComponentUtil.register(new ProcessHelper() {
                @Override
                public int destroyProcess(String sessionId) {
                    // Mock destroy
                    return 0;
                }
            }, "processHelper");
    
            crawlJob.jobExecutor(mockJobExecutor);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/job/PythonJobTest.java

                capturedEnvironment = new HashMap<>(pb.environment());
    
                return new TestJobProcess(exitValue, processOutput);
            }
    
            @Override
            public int destroyProcess(String sessionId) {
                destroyProcessCalled = true;
                return 0;
            }
        }
    
        private static class TestJobProcess extends JobProcess {
            private final int exitValue;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/job/ExecJobTest.java

                    return tempDir.getAbsolutePath();
                }
            }, "systemHelper");
    
            ComponentUtil.register(new ProcessHelper() {
                @Override
                public int destroyProcess(String sessionId) {
                    // Mock implementation
                    return 0;
                }
            }, "processHelper");
    
            ComponentUtil.register(new JobHelper() {
                @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
Back to top