- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 20 for GetStatus (0.16 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java
public PingResponse ping() { PingResponse response = new PingResponse(createMockHealthResponse("test-cluster", ClusterHealthStatus.RED)) { @Override public int getStatus() { // RED status should return non-zero status return 2; } }; return response; } };
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 18.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
continue; } // check status for (int i = 0; i < startedCrawlerNum; i++) { if (crawlerList.get(i).getCrawlerContext().getStatus() == CrawlerStatus.DONE && Constants.RUNNING.equals(crawlerStatusList.get(i))) { crawlerList.get(i).awaitTermination();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 25K bytes - Click Count (0) -
tensorflow/c/eager/c_api_cluster_test.cc
} TEST(CAPI, TestRemoteExecuteUpdateServerDefResourceAccessAsync) { TestRemoteExecuteUpdateServerDefResourceAccess(true); } void TestRemoteExecuteUpdateServerDefWithFailures(bool async) { // Fail fast on GetStatus requests so we can get errors instead of timeout // when updating cluster with non-exsitent worker tensorflow::setenv("GRPC_FAIL_FAST", "TRUE", /*overwrite=*/1); tensorflow::ServerDef server_def = GetServerDef(2);Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Thu Oct 09 05:56:18 GMT 2025 - 19.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/filter/LoadControlFilterTest.java
private final PrintWriter writer = new PrintWriter(stringWriter); @Override public void setStatus(int sc) { this.status = sc; } @Override public int getStatus() { return status; } public int getSendErrorCode() { return sendErrorCode; }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 33.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/api/WebApiManagerTest.java
manager.process(request, response, chain); assertEquals(404, response.getStatus()); // Test with different status code manager = new StatusCodeWebApiManager(201); response = new TestHttpServletResponse(); manager.process(request, response, chain); assertEquals(201, response.getStatus()); } @TestCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 26.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
if (logger.isDebugEnabled()) { logger.debug("[{}] refresh status: {} ({}/{}/{})", index, response.getStatus(), response.getTotalShards(), response.getSuccessfulShards(), response.getFailedShards()); } return response.getStatus().getStatus(); } /** * Calculates the memory size of a document data map.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 26.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/filter/WebApiFilterTest.java
@Override public void addIntHeader(String name, int value) { } @Override public void setStatus(int sc) { } @Override public int getStatus() { return 0; } @Override public String getHeader(String name) { return null;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 26.5K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java
@Override public void addIntHeader(String name, int value) { } @Override public void setStatus(int sc) { } @Override public int getStatus() { return 200; } @Override public String getHeader(String name) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 26.3K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
return "http://test.example.com"; } @Override public String getParentUrl() { return null; } @Override public Integer getStatus() { return 200; } @Override public Integer getHttpStatusCode() { return 200; } @Override public String getMethod() {
Created: 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/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* * @return the cluster health status name */ public String getStatus() { return admin().cluster() .prepareHealth() .execute() .actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout()) .getStatus() .name(); } /** * Sets the OpenSearch runner for embedded mode.Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 138.6K bytes - Click Count (1)