- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for starai (0.13 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
/** * Executes the crawling process. * Starts a new thread for the crawler and optionally waits for its termination. * @return The session ID of the crawling process. */ public String execute() { parentThread = new Thread(this, "Crawler-" + crawlerContext.sessionId); parentThread.setDaemon(daemon); parentThread.start(); if (!background) { awaitTermination();Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
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) -
fess-crawler/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 - 19.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
urlFilter = container.getComponent("urlFilter"); } public void test_doGet() { final CrawlerWebServer server = new CrawlerWebServer(7070); server.start(); final String url = "http://localhost:7070/"; try { final ResponseData responseData = httpClient.doGet(url); assertEquals(200, responseData.getHttpStatusCode());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 11.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/JodExtractor.java
*/ @PostConstruct public void init() { if (officeManager == null) { throw new CrawlerSystemException("officeManager is null."); } try { officeManager.start(); } catch (final OfficeException e) { throw new CrawlerSystemException("Failed to start officeManager.", e); }Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 10.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 19.3K bytes - Viewed (0) -
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) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java
MonitorThread mt = null; try { currentProcess = pb.start(); // monitoring mt = new MonitorThread(currentProcess, executionTimeout); mt.start(); final InputStreamThread it = new InputStreamThread(currentProcess.getInputStream(), commandOutputEncoding, maxOutputLine); it.start(); currentProcess.waitFor(); it.join(5000);Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 16K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java
* @param objs the log objects */ protected void processCleanupCrawling(final Object... objs) { // CrawlerContext crawlerContext = (CrawlerContext) objs[0]; } /** * Processes start crawling log events. * * @param objs the log objects (should contain UrlQueue) */ protected void processStartCrawling(final Object... objs) {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/filter/UrlFilterTest.java
Thread thread2 = new Thread(() -> { for (int i = 0; i < 100; i++) { urlFilter.addExclude(".*\\.type" + i + "$"); } }); thread1.start(); thread2.start(); thread1.join(); thread2.join(); // Should complete without errors assertNotNull(urlFilter); } /** * Test boundary conditionsRegistered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 19K bytes - Viewed (0)