- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for polo (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
/** * Creates a new fixed thread pool executor with the specified number of threads. * * @param nThreads the number of threads in the pool * @return a new ThreadPoolExecutor configured for this callback */ protected ExecutorService newFixedThreadPool(final int nThreads) { if (logger.isDebugEnabled()) { logger.debug("Initialized executor thread pool: size={}", nThreads); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 29.7K bytes - Click Count (3) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
// Poll Loop // =========== /** * Periodic poll that sends a heartbeat, processes new events, and cleans up expired documents. */ protected void poll() { try { sendHeartbeat(); } catch (final Exception e) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/SearchLogHelperTest.java
searchLogHelper.createSearchLog(params, now, "test-query-id", "test query", 0, 10, queryResponseList, context); assertFalse(searchLogHelper.searchLogQueue.isEmpty()); return searchLogHelper.searchLogQueue.poll(); } @Test public void test_addSearchLog_accessType_json() { final SearchLog searchLog = callCreateSearchLogAndGetResult(Constants.SEARCH_LOG_ACCESS_TYPE_JSON);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 16.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
} /** * Data transfer object representing JVM buffer pool statistics. */ public static class JvmPoolObj { /** * Default constructor. */ public JvmPoolObj() { // Default constructor } /** Buffer pool name */ public String key; /** Number of buffers */ public long count;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 19.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java
final ForkJoinPool pool = new ForkJoinPool(10); for (int i = 0; i < 1000; i++) { pool.execute(() -> { assertEquals(result, crawlingInfoHelper.generateId(dataMap)); counter.incrementAndGet(); }); } pool.shutdown(); pool.awaitTermination(10, TimeUnit.SECONDS);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 12 01:46:45 GMT 2026 - 28.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
* of crawled documents into the search engine. * * <p>The DataIndexHelper supports:</p> * <ul> * <li>Concurrent crawling of multiple data configurations</li> * <li>Thread pool management for crawler execution</li> * <li>Session-based crawling with cleanup operations</li> * <li>Old document deletion after successful crawling</li> * <li>Crawling execution monitoring and timing</li> * </ul>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 19K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 29.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
* This processor supports searching with multiple searchers concurrently and merging their results based on * ranking scores to provide more comprehensive and accurate search results. * * The processor maintains a pool of searchers and an executor service for concurrent operations. * It implements rank fusion techniques to combine results from different search engines * and provides a unified search interface. */
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Dec 25 02:13:14 GMT 2025 - 28K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
indexUpdater.maxErrorCount = 0; // Make dataService throw runtime exception ((TestDataService) dataService).setThrowRuntimeException(true); indexUpdater.start(); // Poll for thread to process exceptions for (int i = 0; i < 20; i++) { if (!indexUpdater.isAlive() || indexUpdater.getState() == Thread.State.WAITINGCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java
try { JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pbCall, 1024, outputCallback); assertNotNull(jobProcess); // Poll for process to complete for (int i = 0; i < 50; i++) { if (!jobProcess.getProcess().isAlive()) { break; } Thread.sleep(100);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 16K bytes - Click Count (0)