- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Mask (0.26 sec)
-
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/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/eager/c_api.cc
return nullptr; } std::vector<std::unique_ptr<tensorflow::Device>> devices; status->status = tensorflow::DeviceFactory::AddDevices( opts->session_options.options, "/job:localhost/replica:0/task:0", &devices); if (!status->status.ok()) return nullptr; std::unique_ptr<tensorflow::DeviceMgr> device_mgr( new tensorflow::DynamicDeviceMgr(std::move(devices)));
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Mar 12 20:00:09 GMT 2024 - 43.9K bytes - Viewed (2) -
tensorflow/c/eager/c_api_experimental_test.cc
// 3. Replace worker1 with a new worker in server_def_0 and server_def_1. ReplaceTaskInServerDef(&server_def_0, /*task_index=*/1, "localhost", port); ReplaceTaskInServerDef(&server_def_1, /*task_index=*/1, "localhost", port); // 4. Start a new task to replace worker1. server_def_0.set_task_index(1); worker_server1.release(); ASSERT_TRUE(tensorflow::GrpcServer::Create(
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 03:14:26 GMT 2023 - 31.5K bytes - Viewed (1) -
tensorflow/c/eager/c_api_test.cc
tensorflow::JobDef* job_def2 = cluster_def->add_job(); job_def2->set_name("worker"); // Copy over `host:port` at `task_index` for (auto task : cluster_server_def.cluster().job(0).tasks()) { if (task.first == task_index) { job_def2->mutable_tasks()->insert({task.first, task.second}); } } return single_host_server_def; }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 20:50:20 GMT 2023 - 94.6K bytes - Viewed (1)