- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for TimeoutTask (0.09 sec)
-
src/main/java/org/codelibs/fess/job/ExecJob.java
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.opensearch.config.exentity.ScheduledJob; import org.codelibs.fess.util.ComponentUtil; import org.lastaflute.di.exception.IORuntimeException;
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/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
protected void tearDown() throws Exception { 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++; }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/storage/StorageClientTest.java
// Skip init() and directly test timeout handling org.codelibs.fess.crawler.client.AccessTimeoutTarget accessTimeoutTarget = null; org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
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/main/java/org/codelibs/fess/exec/SuggestCreator.java
import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.DynamicProperties; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.FesenClient; import org.codelibs.fess.exception.ContainerNotAvailableException; import org.codelibs.fess.helper.SuggestHelper;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 11.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/s3/S3ClientTest.java
// Skip init() and directly test timeout handling org.codelibs.fess.crawler.client.AccessTimeoutTarget accessTimeoutTarget = null; org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 07:57:44 UTC 2025 - 20.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java
import org.codelibs.core.io.FileUtil; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.crawler.builder.RequestDataBuilder; import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 23.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java
import org.codelibs.core.io.FileUtil; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.crawler.builder.RequestDataBuilder; import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 23.4K bytes - Viewed (3) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/gcs/GcsClientTest.java
// Skip init() and directly test timeout handling org.codelibs.fess.crawler.client.AccessTimeoutTarget accessTimeoutTarget = null; org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread());
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 19.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/JobHelper.java
import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTarget; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.exception.ScheduledJobException; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.opensearch.config.exbhv.JobLogBhv;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
if (StringUtil.isNotBlank(httpAddress)) { System.setProperty(FesenClient.HTTP_ADDRESS, httpAddress); } TimeoutTask systemMonitorTask = null; TimeoutTask hotThreadMonitorTask = null; Thread commandThread = null; int exitCode; try { running.set(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)