- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for addTimeoutTarget (0.06 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance() .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try { return getResponseData(uri, includeContent); } finally {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 20.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/gcs/GcsClientTest.java
accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance() .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try { return getResponseData(uri, includeContent); } finally {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 19.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/s3/S3ClientTest.java
accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance() .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try { return getResponseData(uri, includeContent); } finally {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 07:57:44 UTC 2025 - 20.5K bytes - Viewed (0) -
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: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 4.3K bytes - Viewed (0) -
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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 12.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
} }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance() .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(), true); final int totalCount = process(options);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 9.4K bytes - Viewed (0) -
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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 12:19:14 UTC 2025 - 15.1K bytes - Viewed (0) -
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);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 14.2K bytes - Viewed (0) -
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: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 31.4K bytes - Viewed (0) -
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 */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.9K bytes - Viewed (0)