Search Options

Display Count
Sort
Preferred Language
Advanced Search

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

  1. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

         * @return exit code of the destroyed process, or -1 if the process was not found
         */
        public synchronized int destroyProcess(final String sessionId) {
            final JobProcess jobProcess = runningProcessMap.remove(sessionId);
            return destroyProcess(sessionId, jobProcess);
        }
    
        /**
         * Checks if any processes are currently running.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 06:54:47 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  2. 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) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  3. 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) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  4. 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) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/job/ExecJob.java

            }
            return TimeoutManager.getInstance().addTimeoutTarget(() -> {
                logger.warn("Process terminated: timeout={}s exceeded", timeout);
                ComponentUtil.getProcessHelper().destroyProcess(sessionId);
                processTimeout = true;
            }, timeout, false);
        }
    
        /**
         * Creates and stores system properties to the specified file.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  6. 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();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 19.6K bytes
    - Click Count (0)
  7. 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);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 25K bytes
    - Click Count (0)
  8. 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());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16K bytes
    - Click Count (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;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 22.2K bytes
    - Click Count (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
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 24.8K bytes
    - Click Count (0)
Back to Top