- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for getStats (0.23 sec)
-
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; }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 11 23:52:39 GMT 2024 - 35.9K bytes - Viewed (3) -
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);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 15.6K bytes - Viewed (1) -
src/main/java/jcifs/smb/SmbEnumerationUtil.java
SmbComTransactionResponse resp = new NetShareEnumResponse(th.getConfig()); th.send(req, resp); if ( resp.getStatus() != WinError.ERROR_SUCCESS ) throw new SmbException(resp.getStatus(), true); return resp.getResults(); }
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sat Jul 20 08:41:19 GMT 2019 - 12.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
boolean isDone() { return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */ boolean isCancelled() { return (getState() & (CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #INTERRUPTED}. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
boolean isDone() { return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */ boolean isCancelled() { return (getState() & (CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #INTERRUPTED}. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000); assertEquals(Thread.State.TERMINATED, otherThread.getState()); Throwable throwable = throwableFromOtherThread.get(); assertNull( "Throwable from other thread: " + (throwable == null ? null : Throwables.getStackTraceAsString(throwable)),
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
cmd/metrics-resource.go
hosts: map[string]struct{}{ globalLocalNodeName: {}, }, }) for host, hm := range m.ByHost { if len(host) > 0 { if hm.Net != nil && len(hm.Net.NetStats.Name) > 0 { stats := hm.Net.NetStats labels := map[string]string{"interface": stats.Name} updateResourceMetrics(interfaceSubsystem, interfaceRxBytes, float64(stats.RxBytes), labels, true)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (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();
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.6K bytes - Viewed (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);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Apr 14 10:03:59 GMT 2023 - 19.3K bytes - Viewed (0) -
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; }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12.1K bytes - Viewed (0)