- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for destroyProcess (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)