Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for stat (0.01 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/log/LogType.java

    /**
     * LogType defines the different types of log messages that can be generated during the crawling process.
     * Each enum constant represents a specific event or state in the crawler's execution.
     */
    public enum LogType {
        /** Indicates the start of a crawling process. */
        START_CRAWLING,
        /** Indicates the cleanup phase of crawling. */
        CLEANUP_CRAWLING,
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                        Thread.currentThread().interrupt();
                    } finally {
                        endLatch.countDown();
                    }
                }
            });
    
            thread1.start();
            thread2.start();
            startLatch.countDown();
            endLatch.await(5, TimeUnit.SECONDS);
    
            assertEquals(2, successCount.get());
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ignore) {}
                deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
            });
            th.start();
    
            final CountDownLatch latch = new CountDownLatch(1);
            deferred.promise().then(response -> latch.countDown());
            assertTrue(latch.await(10, TimeUnit.SECONDS));
        }
    
        @Test
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sat Mar 15 06:51:20 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  4. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

            }
        }
    
        public void test_execute_2instance() throws Exception {
            final CrawlerWebServer server1 = new CrawlerWebServer(7070);
            server1.start();
            final CrawlerWebServer server2 = new CrawlerWebServer(7071);
            server2.start();
    
            final String url1 = "http://localhost:7070/";
            final String url2 = "http://localhost:7071/";
            try {
                final int maxCount = 10;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerStatusTest.java

                                exceptions.add(e);
                            }
                        }
                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

                                exceptions.add(e);
                            }
                        }
                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Verify results
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            try {
                final long start = System.currentTimeMillis();
                final SuggestWriterResult result = suggestWriter.write(client, settings, index, array, true);
                return new SuggestIndexResponse(items.length, items.length, result.getFailures(), System.currentTimeMillis() - start);
            } catch (final Exception e) {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/IntervalController.java

     *   <li>{@code POST_PROCESSING} - Represents the post-processing state.</li>
     *   <li>{@code NO_URL_IN_QUEUE} - Indicates that there are no URLs in the queue.</li>
     *   <li>{@code WAIT_NEW_URL} - Indicates that the crawler is waiting for new URLs.</li>
     * </ul>
     */
    public interface IntervalController {
        /** Constant representing the pre-processing state. */
        int PRE_PROCESSING = 1;
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/XPathAPI.java

            }
        }
    
        /**
         *  Use an XPath string to select a nodelist.
         *  XPath namespace prefixes are resolved from the contextNode.
         *
         *  @param contextNode The node to start searching from.
         *  @param expression A valid XPath string.
         *  @return A XPathNodes, should never be null.
         *
         * @throws XPathExpressionException if an XPath expression error occurs.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/TransformerTest.java

                if (responseData != null) {
                    processedUrls.add(responseData.getUrl());
                    state++;
                }
    
                ResultData resultData = new ResultData();
                resultData.setTransformerName(name);
                resultData.setData(("State: " + state).getBytes());
                return resultData;
            }
    
            @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 28K bytes
    - Viewed (0)
Back to top