- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for statRps (0.07 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerStatusTest.java
// Test with ternary operator String message = (status == CrawlerStatus.RUNNING) ? "Running" : "Not Running"; assertEquals("Running", message); // Test with logical operators assertTrue(status == CrawlerStatus.RUNNING || status == CrawlerStatus.DONE); assertFalse(status == CrawlerStatus.INITIALIZING && status == CrawlerStatus.DONE); } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 15.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/ResponseData.java
/** * Gets the processing status of this response. * * @return the processing status */ public int getStatus() { return status; } /** * Sets the processing status of this response. * * @param status the processing status to set */ public void setStatus(final int status) { this.status = status; } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 11.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleTest.java
if (!responseData.getMimeType().matches(mimeTypeCondition)) { return false; } } // Check status code condition String statusCodeCondition = conditions.get("statusCode"); if (statusCodeCondition != null) { int expectedCode = Integer.parseInt(statusCodeCondition);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 22.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java
protected CrawlerContainer crawlerContainer; /** Transformer used to transform response data */ protected Transformer transformer; /** HTTP status codes considered successful */ protected int[] successfulHttpCodes; /** HTTP status codes considered not modified */ protected int[] notModifiedHttpCodes; /** * Constructs a new DefaultResponseProcessor. */Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 12.5K bytes - Viewed (0) -
README.md
String sessionId = crawler.execute(); ``` ### Background Crawling ```java // Configure for background execution crawler.setBackground(true); String sessionId = crawler.execute(); // Check crawling status while (crawler.crawlerContext.getStatus() == CrawlerStatus.RUNNING) { Thread.sleep(1000); System.out.println("Crawling in progress..."); } // Wait for completion crawler.awaitTermination();
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
builder.setFetchSource(new String[] { "parentUrl", "method", "mimeType", "sessionId", "url", "executionTime", "createTime", "contentLength", "lastModified", "ruleId", "httpStatusCode", "status" }, null); return builder.execute(); }); final OpenSearchResultList<OpenSearchAccessResult> targetList = new OpenSearchResultList<>(); final SearchHits hits = response.getHits();
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 10.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java
endLatch.await(10, TimeUnit.SECONDS); executor.shutdown(); assertEquals(threadCount * operationsPerThread, crawlerContext.getAccessCount()); } /** * Test status getter and setter */ public void test_status() { assertEquals(CrawlerStatus.INITIALIZING, crawlerContext.getStatus()); crawlerContext.setStatus(CrawlerStatus.RUNNING);
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/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
// for (Future<ResponseData> future : futureList) { // ResponseData responseData = future.get(); // if (responseData != null) { // System.out.println("status: " // + responseData.getHttpStatusCode() // + " content: " // + new String(InputStreamUtil.getBytes(responseData // .getResponseBody()), "UTF-8")); // } else { // System.out.println("OK");
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/client/http/form/FormScheme.java
} catch (final IOException e) { content = e.getMessage(); } logger.warn("Failed to access to {}. The http status is {}.\n{}", tokenUrl, httpStatusCode, content); } }); } final String loginHttpMethod = getParameter(LOGIN_METHOD);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14.3K bytes - Viewed (1) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java
// UrlQueue<?> urlQueue = (UrlQueue<?>) objs[1]; final ResponseData responseData = (ResponseData) objs[2]; if (logger.isDebugEnabled()) { logger.debug("Processing the response. Http Status: {}, Exec Time: {}", responseData.getHttpStatusCode(), responseData.getExecutionTime()); } } /** * Processes redirect location log events. *
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0)