- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for addTimeoutTarget (0.23 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) -
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: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 2.1K 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) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
* @param timeout the timeout duration * @param permanent whether the task is permanent * @return the {@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: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 7.8K 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)