Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for addTimeoutTarget (0.1 sec)

  1. src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java

            TimeoutManager.getInstance().clear();
        }
    
        /**
         * @throws Exception
         */
        public void testExpired() throws Exception {
            TimeoutTask task = TimeoutManager.getInstance().addTimeoutTarget(new TimeoutTarget() {
                public void expired() {
                    System.out.println("expired");
                    expiredCount++;
                }
            }, 1, true);
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. 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();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/ExecJob.java

                }
            }
        }
    
        protected TimeoutTask createTimeoutTask() {
            if (timeout <= 0) {
                return null;
            }
            return TimeoutManager.getInstance().addTimeoutTarget(() -> {
                logger.warn("Process is terminated due to {} second exceeded.", timeout);
                ComponentUtil.getProcessHelper().destroyProcess(sessionId);
                processTimeout = true;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            final ExtractData data = new ExtractData();
            final HttpPost httpPost = new HttpPost(url);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/Crawler.java

                systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(),
                        ComponentUtil.getFessConfig().getCrawlerSystemMonitorIntervalAsInteger(), true);
    
                if (options.hotThread != null) {
                    hotThreadMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new HotThreadMonitorTarget(), options.hotThread, true);
                }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                        destroyContainer();
                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(),
                        ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(), true);
    
                final int totalCount = process(options);
                if (totalCount != 0) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. 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);
        }
    
        public void setMonitorInterval(final int monitorInterval) {
            this.monitorInterval = monitorInterval;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/timer/TimeoutManager.java

         *
         * @param timeoutTarget target
         * @param timeout timeout
         * @param permanent permanent
         * @return {@link TimeoutTask}
         */
        public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent);
            timeoutTaskList.addLast(task);
            start();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                        destroyContainer();
                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(),
                        ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(), true);
    
                exitCode = process(options);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top