Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for addTimeoutTarget (0.08 seconds)

  1. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance()
                        .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(),
                                true);
    
                if (ComponentUtil.getFessConfig().isLogNotificationEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance()
                        .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(),
                                true);
    
                if (ComponentUtil.getFessConfig().isLogNotificationEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 10.4K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java

                    cb.query().setJobStatus_Equal(Constants.RUNNING);
                    cb.query().setTarget_Equal(myName);
                });
            }
    
            TimeoutManager.getInstance().addTimeoutTarget(() -> {
                if (logger.isDebugEnabled()) {
                    logger.debug("Updating scheduled jobs: time={}", schedulerTime);
                }
                final long now = systemHelper.getCurrentTimeAsLong();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java

            logNotificationTarget = new LogNotificationTarget();
            final int interval = ComponentUtil.getFessConfig().getLogNotificationFlushIntervalAsInteger();
            timeoutTask = TimeoutManager.getInstance().addTimeoutTarget(logNotificationTarget, interval, true);
        }
    
        /**
         * Stops the log notification timer and performs a final flush.
         */
        @PreDestroy
        public void destroy() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 5.3K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/job/ExecJob.java

         */
        protected TimeoutTask createTimeoutTask() {
            if (timeout <= 0) {
                return null;
            }
            return TimeoutManager.getInstance().addTimeoutTarget(() -> {
                logger.warn("Process terminated: timeout={}s exceeded", timeout);
                ComponentUtil.getProcessHelper().destroyProcess(sessionId);
                processTimeout = true;
            }, timeout, false);
    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/exec/Crawler.java

                            .addTimeoutTarget(logNotificationTarget, ComponentUtil.getFessConfig().getLogNotificationFlushIntervalAsInteger(),
                                    true);
                }
    
                if (options.hotThread != null) {
                    hotThreadMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new HotThreadMonitorTarget(), options.hotThread, true);
                }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 32.4K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/helper/JobHelper.java

         */
        public TimeoutTask startMonitorTask(final JobLog jobLog) {
            final TimeoutTarget target = new MonitorTarget(jobLog);
            return TimeoutManager.getInstance().addTimeoutTarget(target, monitorInterval, true);
        }
    
        /**
         * Sets the monitor interval for job monitoring.
         *
         * @param monitorInterval the monitor interval in seconds
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/chat/ChatSessionManager.java

         * Initializes the session manager and starts the cleanup scheduler.
         */
        @PostConstruct
        public void init() {
            // 5 minutes = 300 seconds
            cleanupTask = TimeoutManager.getInstance().addTimeoutTarget(this::cleanupExpiredSessions, 300, true);
            if (logger.isDebugEnabled()) {
                logger.debug("Initialized ChatSessionManager");
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 07 13:27:59 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java

            sendHeartbeat();
    
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final int interval = fessConfig.getCoordinatorPollIntervalAsInteger();
            pollTask = TimeoutManager.getInstance().addTimeoutTarget(this::poll, interval, true);
    
            if (logger.isInfoEnabled()) {
                logger.info("CoordinatorHelper started: instanceId={}", instanceId);
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 33.3K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/SystemHelper.java

                            final int interval = fessConfig.getLoadControlMonitorIntervalAsInteger();
                            loadControlMonitorTask =
                                    TimeoutManager.getInstance().addTimeoutTarget(new LoadControlMonitorTarget(this), interval, true);
                        }
                    }
                }
            }
        }
    
        /**
         * Gets a map of filtered environment variables.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 43.2K bytes
    - Click Count (0)
Back to Top