- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 15 for GetStatus (0.15 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/test/java/org/codelibs/fess/filter/CorsFilterTest.java
} private static class TestHttpServletResponse implements HttpServletResponse { private int status = 0; @Override public void setStatus(int sc) { this.status = sc; } public int getStatus() { return status; } @Override public java.util.Collection<String> getHeaderNames() {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 22.6K 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/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/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/api/json/SearchApiManager.java
final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient(); try { final PingResponse pingResponse = searchEngineClient.ping(); writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE, "\"data\":" + pingResponse.getMessage()); } catch (final Exception e) { if (logger.isDebugEnabled()) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 27 13:56:32 GMT 2026 - 55.4K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/filter/RateLimitFilter.java
* @param response the HTTP response * @throws IOException if an I/O error occurs */ protected void sendBlockedResponse(final HttpServletResponse response) throws IOException { response.setStatus(HttpServletResponse.SC_FORBIDDEN); response.setContentType("application/json;charset=UTF-8"); response.getWriter().write("{\"error\":\"ip_blocked\",\"message\":\"Access denied.\"}"); } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 4.4K bytes - Click Count (0)