- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for correctly (0.23 sec)
-
tensorflow/c/c_api.cc
while (*pos < static_cast<size_t>(graph->graph.num_node_ids())) { Node* node = graph->graph.FindNodeId(*pos); // FindNodeId() returns nullptr for nodes that have been deleted. // We aren't currently allowing nodes to be deleted, but it is safer // to still check. if (node != nullptr) return ToOperation(node); *pos += 1; } // No more nodes. return nullptr; }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 102.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
TFE_ExecutorWaitForAllPendingNodes(executor, status); ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); // TODO(b/136478427): Figure out how to correctly shut the server down. worker_server.release(); // Update the server def with a new set of names (worker instead of // localhost). tensorflow::ServerDef updated_server_def = GetServerDef("worker", 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) -
tensorflow/c/eager/c_api_remote_test.cc
ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteExecutor(executor); TFE_DeleteContext(ctx); TF_DeleteStatus(status); // TODO(b/136478427): Figure out how to correctly shut the server down. worker_server.release(); } TEST(CAPI, RemoteExecute) { TestRemoteExecute(false); } TEST(CAPI, RemoteExecuteAsync) { TestRemoteExecute(true); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 12 00:14:22 GMT 2020 - 5.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
TFE_DeleteExecutor(executor); TFE_ContextRemoveFunction(ctx, "AddVariablesFunction", status); TFE_DeleteContext(ctx); TF_DeleteStatus(status); // TODO(b/136478427): Figure out how to correctly shut the server down. worker_server1.release(); worker_server2.release(); } TEST(CAPI, TestLocalFunctionWithPackedInput) { TestFunctionWithPackedInput(/*remote=*/false); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 09:49:45 GMT 2024 - 23.5K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_test.cc
} { // Try to extract the wrong number of components from a parallel tensor std::array<TFE_TensorHandle*, 1> correct_components{value_one.get()}; TensorHandlePtr combined_value = CreatePerDeviceValues( context.get(), correct_components, device_name, status.get()); ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 08 23:47:35 GMT 2021 - 29.3K bytes - Viewed (1) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
TFE_OpSetCancellationManager(op_.get(), wrap(cancellation_manager_), status); if (TF_GetCode(status) != TF_OK) return; // unwrap op_ and set step_id only if valid step id value was set. // Currently only required for non-TFRT use cases, e.g., EagerOp. if (step_id_.has_value()) { tensorflow::unwrap(op_.get())->SetStepId(step_id_.value()); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1) -
tensorflow/c/eager/parallel_device/parallel_device_testlib.cc
#include "tensorflow/c/c_api_experimental.h" #include "tensorflow/c/eager/c_api.h" #include "tensorflow/c/eager/c_api_experimental.h" #include "tensorflow/core/platform/test.h" // NOTE(allenl): These tests currently go through TFE_Execute and so are // integration testing rather than purely testing the parallel device. They // correspond fairly well to the implementation, but testing the C++ directly is // another option.
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Jun 15 15:44:44 GMT 2021 - 12.5K bytes - Viewed (0) -
tensorflow/c/c_api_function.cc
if (iter == input_nodes.end()) { // This node is not referenced in inputs. Add it to the body. body_nodes->push_back(node); } else { // This node is referenced in inputs. Currently, we place an // artificial restriction and require that when num_opers=-1, such // nodes must have a single output. if (node->num_outputs() != 1) { return InvalidArgument(
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 13.6K bytes - Viewed (2) -
tensorflow/c/eager/parallel_device/parallel_device.cc
.c_str()); return nullptr; } // For TFE_CustomDevice::copy_tensor_from_device in the parallel device // registration. // // Currently this is an error, and un-packing ParallelTensors must be performed // explicitly by running a TPUReplicatedOutput operation on the parallel device. //
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 29 22:05:31 GMT 2023 - 18.3K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache_test.cc
cache1.LookupOrCompute("a", &value, compute_func, &status); TF_EXPECT_OK(status.status); EXPECT_EQ(value, 1); EXPECT_EQ(num_compute_calls, 2); // Define a new cache with max_age > 0 and verify correct behavior. tf_gcs_filesystem::ExpiringLRUCache<int> cache2(2, 4); num_compute_calls = 0; value = -1; // Read our first value cache2.LookupOrCompute("a", &value, compute_func, &status);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 19:31:22 GMT 2020 - 7.1K bytes - Viewed (0)