- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Mask (0.16 sec)
-
tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc
EXPECT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get()); const char* first_device = "/job:worker/replica:0/task:1/device:CPU:0"; const char* second_device = "/job:worker/replica:0/task:2/device:CPU:0"; const char* device_name = "/job:localhost/replica:0/task:0/device:CUSTOM:0"; std::array<const char*, 2> underlying_devices{first_device, second_device};
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 22:09:57 GMT 2023 - 6.7K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
namespace { using ::tensorflow::string; void ReplaceTaskInServerDef(tensorflow::ServerDef* server_def, int task_index) { tensorflow::JobDef* job_def = server_def->mutable_cluster()->mutable_job(0); int port = tensorflow::testing::PickUnusedPortOrDie(); job_def->mutable_tasks()->at(task_index) = tensorflow::strings::StrCat("localhost:", port); } void CheckTFE_TensorHandleHasFloats(TFE_TensorHandle* handle,
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/parallel_device/parallel_device_lib_test.cc
ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get()); std::vector<std::string> devices{ "/job:localhost/replica:0/task:0/device:CPU:0", "/job:localhost/replica:0/task:0/device:CPU:1"}; ParallelDevice parallel_device(std::move(devices)); std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> handle_op(
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 08 23:47:35 GMT 2021 - 15.3K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.cc
TFE_Context* ctx, const char* task, int64_t timeout_in_ms, TF_Status* status) { tensorflow::EagerContext* context = tensorflow::ContextFromInterface(tensorflow::unwrap(ctx)); auto collective_executor_handle = context->GetCollectiveExecutorHandle(); tensorflow::Notification done; collective_executor_handle->get()->remote_access()->CheckPeerHealth( task, timeout_in_ms, [&done, status](const Status& s) {
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 29.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
// During execution: // * task:0 processes main function `VariableAddFunctionWithGraphError` // and places the 'read0_maybe_with_graph_error' op on task:2 // * task:0 partitions the main function with a subgraph containing // 'read0_maybe_with_graph_error' sent to task:2 // * task:2 graph pass reports an error when it sees
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
ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get()); const char* device_name = "/job:localhost/replica:0/task:0/device:CUSTOM:0"; const char* first_device_name = "/job:localhost/replica:0/task:0/device:CPU:0"; const char* second_device_name = "/job:localhost/replica:0/task:0/device:CPU:1"; std::array<const char*, 2> underlying_devices{first_device_name,
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_testlib.cc
// Register the custom device std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status( TF_NewStatus(), TF_DeleteStatus); const char* device_name = "/job:localhost/replica:0/task:0/device:CUSTOM:0"; std::array<const char*, 2> underlying_devices{first_device, second_device}; RegisterParallelDevice(context, device_name, underlying_devices, status.get());
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/eager/c_api_experimental.cc
return; } std::vector<tensorflow::CoordinatedTask> task_vec(tasks.length); auto* task_iter = static_cast<const tensorflow::CoordinatedTask*>(tasks.data); for (size_t i = 0; i < tasks.length; ++i) { task_vec[i].set_job_name(task_iter->job_name()); task_vec[i].set_task_id(task_iter->task_id()); ++task_iter; } auto results = coord_agent->GetTaskState(task_vec); if (!results.ok()) {
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) -
tensorflow/c/eager/c_api_test_util.cc
tensorflow::ServerDef ReplaceTaskInServerDef( const tensorflow::ServerDef& server_def, int task_index) { tensorflow::ServerDef server_def_copy = server_def; tensorflow::ClusterDef* cluster_def = server_def_copy.mutable_cluster(); tensorflow::JobDef* job_def = cluster_def->mutable_job(0); const int port = tensorflow::testing::PickUnusedPortOrDie(); job_def->mutable_tasks()->at(task_index) = tensorflow::strings::StrCat("localhost:", port);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 23.5K bytes - Viewed (2) -
tensorflow/c/c_api_experimental_test.cc
job { name: "worker" tasks { key: 0 value: "tpuserver:0" } tasks { key: 1 value: "localhost:1" } } } job_name: "worker" task_index: 1 protocol: "grpc" )"); TF_Status* status = TF_NewStatus(); TF_Buffer* result = TFE_GetServerDef(expected_text_proto.c_str(), status); EXPECT_EQ(TF_GetCode(status), TF_OK); ServerDef actual;
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Jan 17 22:27:52 GMT 2023 - 13.1K bytes - Viewed (1)