- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for finisher (0.04 sec)
-
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Dec 04 08:02:36 UTC 2025 - 16K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
} } } /** * Sets the finished flag to indicate whether the process has completed. * @param finished True if the process has finished, false otherwise. */ public void setFinished(final boolean finished) { this.finished = finished; } /** * Checks if the process has been terminated due to timeout.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 14.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
/** Initialization parameters for the data store */ private final DataStoreParams initParamMap; /** Flag indicating whether the crawling thread has finished execution */ protected boolean finished = false; /** Flag indicating whether the crawling thread is currently running */ protected boolean running = false;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 19K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
} forceStop(); } } /** * Adds a finished session ID to the cleanup list. * This method is thread-safe and adds the session ID to be cleaned up later. * * @param sessionId the crawler session ID that has finished processing */ public void addFinishedSessionId(final String sessionId) { synchronized (finishedSessionIdList) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 32.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java
if (scheduledJob.isLoggingEnabled() && logger.isInfoEnabled()) { logger.info("Finished job: id={}", id); } } else { if (scheduledJob.isLoggingEnabled() && logger.isInfoEnabled()) { logger.info("Finished job: id={}, returnValue:\n{}", id, ret); } jobLog.setScriptResult(ret.toString()); }
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 5.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
super.processFinishedCrawling(objs); if (objs.length > 1 && objs[1] instanceof final UrlQueue<?> urlQueue) { ComponentUtil.getCrawlerStatsHelper().record(urlQueue, StatsAction.FINISHED); } } @Override protected void processCrawlingAccessException(final Object... objs) { String failureUrlId = "?";
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 8.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
} finally { if (systemMonitorTask != null) { systemMonitorTask.cancel(); } destroyContainer(); } logger.info("Finished SuggestCreator."); System.exit(exitCode); } private static void destroyContainer() { TimeoutManager.getInstance().stop(); synchronized (SingletonLaContainerFactory.class) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
} joinCrawlerThread(webFsCrawlerThread); joinCrawlerThread(dataCrawlerThread); if (logger.isInfoEnabled()) { logger.info("Finished Crawler."); } return Constants.EXIT_OK; } catch (final Throwable t) { logger.warn("Crawl task failed with an exception.", t); return Constants.EXIT_FAIL;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 31.4K bytes - Viewed (0)