Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for GetStatus (0.07 sec)

  1. tensorflow/c/eager/c_api_experimental.cc

                                                      const char* description) {
      auto* result = new TFE_MonitoringCounter0({name, description});
      tsl::Set_TF_Status_from_Status(status, result->counter->GetStatus());
      if (!result->counter->GetStatus().ok()) {
        delete result;
        return nullptr;
      }
      return result;
    }
    
    void TFE_MonitoringDeleteCounter0(TFE_MonitoringCounter0* counter) {
      delete counter;
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/entity/PingResponse.java

        private String message = StringUtil.EMPTY;
    
        public PingResponse(final ClusterHealthResponse response) {
            status = response.getStatus() == ClusterHealthStatus.RED ? 1 : 0;
            clusterName = response.getClusterName();
            clusterStatus = response.getStatus().toString();
            final Set<String> fieldSet = ComponentUtil.getFessConfig().getApiPingEsFieldSet();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java

            final StringBuilder resultBuf = new StringBuilder();
    
            final PingResponse ping = searchEngineClient.ping();
            final int status = ping.getStatus();
            if (systemHelper.isChangedClusterState(status)) {
                if (fessConfig.hasNotification()) {
                    final String toStrs = fessConfig.getNotificationTo();
                    final String[] toAddresses;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/util/ConsoleTransferListener.java

                long complete = entry.getValue();
    
                buffer.append(getStatus(complete, total)).append("  ");
            }
    
            int pad = lastLength - buffer.length();
            lastLength = buffer.length();
            pad(buffer, pad);
            buffer.append('\r');
    
            print("transferProgressed", buffer.toString());
        }
    
        private String getStatus(long complete, long total) {
            if (total >= 1024) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

      }
    
      @JvmName("-deprecated_getStatus")
      @Deprecated(
        message = "moved to var",
        replaceWith = ReplaceWith(expression = "status"),
        level = DeprecationLevel.ERROR,
      )
      fun getStatus(): String = status
    
      fun setStatus(status: String) =
        apply {
          this.status = status
        }
    
      fun setResponseCode(code: Int): MockResponse {
        val reason =
          when (code) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  6. 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();
        }
    
        public long calculateDocumentSize(final Map<String, Object> dataMap) {
            return MemoryUtil.sizeOf(dataMap);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  7. 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();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  8. 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);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

                engineObj.numberOfPendingTasks = response.getNumberOfPendingTasks();
                engineObj.numberOfInFlightFetch = response.getNumberOfInFlightFetch();
                engineObj.status = response.getStatus().name().toLowerCase(Locale.ROOT);
            } catch (final Exception e) {
                engineObj.status = "red";
                engineObj.exception = e.getMessage();
            }
            return engineObj;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt

        val parse: MediaType? = MediaType.parse("")
      }
    
      @Test @Disabled
      fun mockResponse() {
        val mockResponse = MockResponse()
        var status: String = mockResponse.getStatus()
        var headers: Headers = mockResponse.getHeaders()
        var trailers: Headers = mockResponse.getTrailers()
        var socketPolicy: SocketPolicy = mockResponse.getSocketPolicy()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top