- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for task (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 23 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 22:09:57 GMT 2023 - 6.7K bytes - Viewed (0) -
tensorflow/c/eager/immediate_execution_distributed_manager.h
// on all tasks in the cluster. This call internally coordinates with other // tasks to initialize the eager context and TF server for multi-client // execution. virtual Status EnableCollectiveOps(const ServerDef& server_def) = 0; // Check if the remote task is alive. virtual Status CheckRemoteAlive(const std::string& remote_task_name, bool* is_alive) = 0;
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 2.9K bytes - Viewed (0) -
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 23 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
// Add a client. job_def->mutable_tasks()->insert( {0, tensorflow::strings::StrCat( "localhost:", tensorflow::testing::PickUnusedPortOrDie())}); 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) {
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 20:50:20 GMT 2023 - 94.6K bytes - Viewed (1) -
tensorflow/c/eager/abstract_operation.h
// chosen for the operation by the device placement logic in the // executor. After that, the value returned by DeviceName will be a full // device name such as "/job:localhost/replica:0/task:0/device:GPU:1". virtual const string& DeviceName() const = 0; // Sets the operation device name. // // The given `name` must be parseable by DeviceNameUtils::ParseFullName, and
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Jul 14 16:20:41 GMT 2021 - 6.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
"/job:worker/replica:0/task:1/device:CPU:0"; const char new_local_device_name[] = "/job:worker/replica:0/task:0/device:CPU:0"; auto* h0_task1_new = TFE_TensorHandleCopyToDevice( h0_task0_new, ctx, new_remote_device_name, status); EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteTensorHandle(h0_task0_new); TFE_DeleteTensorHandle(h0_task1_new);
C++ - Registered: Tue Apr 23 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_util.cc
const char task1_name[] = "/job:localhost/replica:0/task:1/device:CPU:0"; const char task2_name[] = "/job:localhost/replica:0/task:2/device:CPU:0"; std::vector<TFE_TensorHandle*> handles_task2; for (auto* h_task0 : handles_task0) { handles_task2.push_back( TFE_TensorHandleCopyToDevice(h_task0, ctx, task2_name, status)); ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status); } auto* h1_task2 =
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Dec 11 22:56:03 GMT 2020 - 9.1K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_test.cc
TFE_TensorHandle* h0_task0 = TestMatrixTensorHandle(ctx); TFE_TensorHandle* h1_task0 = TestMatrixTensorHandle(ctx); const char remote_device_name[] = "/job:localhost/replica:0/task:1/device:CPU:0"; auto* h0_task1 = TFE_TensorHandleCopyToDevice(h0_task0, ctx, remote_device_name, status); ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); auto* h1_task1 =
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Aug 12 00:14:22 GMT 2020 - 5.4K 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 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 08 23:47:35 GMT 2021 - 15.3K 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 23 12:39:09 GMT 2024 - Last Modified: Thu Apr 11 23:52:39 GMT 2024 - 35.9K bytes - Viewed (3)