- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Workers (0.17 sec)
-
tensorflow/c/eager/c_api.h
TF_CAPI_EXPORT extern TFE_ContextDevicePlacementPolicy TFE_ContextGetDevicePlacementPolicy(TFE_Context* ctx); // A tensorflow.ServerDef specifies remote workers (in addition to the current // workers name). Operations created in this context can then be executed on // any of these remote workers by setting an appropriate device. // // If the following is set, all servers identified by the // ServerDef must be up when the context is created.
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 21:07:00 GMT 2023 - 22.8K bytes - Viewed (1) -
tensorflow/c/eager/c_api_experimental.h
// EagerService to maintain consistency between client and worker. The // context_id is initialized with a dummy value and is later set when the worker // is initialized (either locally or remotely). The context_id can change during // the process lifetime although this should cause the worker to be // reinitialized (e.g. cleared caches) as well.
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 39.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
server_def.set_task_index(1); std::unique_ptr<tensorflow::GrpcServer> worker_server1; ASSERT_TRUE(tensorflow::GrpcServer::Create( server_def, tensorflow::Env::Default(), &worker_server1) .ok()); ASSERT_TRUE(worker_server1->Start().ok()); server_def.set_task_index(2); std::unique_ptr<tensorflow::GrpcServer> worker_server2; ASSERT_TRUE(tensorflow::GrpcServer::Create(
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_test.cc
int port = tensorflow::testing::PickUnusedPortOrDie(); // 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/c_api_experimental_test.cc
namespace { TEST(CAPI_EXPERIMENTAL, GetServerDefTest) { const string expected_text_proto(R"(cluster { 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();
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) -
tensorflow/c/eager/BUILD
"//tensorflow/core/distributed_runtime:remote_device", "//tensorflow/core/distributed_runtime:server_lib", "//tensorflow/core/distributed_runtime:worker_env", "//tensorflow/core/distributed_runtime:worker_interface", "//tensorflow/core/distributed_runtime/eager:cluster_function_library_runtime", "//tensorflow/core/distributed_runtime/eager:eager_client",
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 11 23:52:39 GMT 2024 - 33.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api.cc
// TFE_ContextUpdateServerDefWithTimeout to be simple wrappers around the same // C++ function. // Retries are used for CreateContext calls, which is used in // ParameterServerStrategy initialization to be robust to worker preemption. TF_CAPI_EXPORT extern void TFE_ContextSetServerDefWithTimeoutAndRetries( TFE_Context* ctx, int keep_alive_secs, const void* proto, size_t proto_len, int64_t init_timeout_in_ms, int retries, TF_Status* status,
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.cc
return; } absl::Duration timeout; if (timeout_in_ms > 0) { timeout = absl::Milliseconds(timeout_in_ms); } else { // Block until the key-value is set or the worker shuts down. timeout = absl::InfiniteDuration(); } auto status_or_value = coord_agent->GetKeyValue(key, timeout); status->status = status_or_value.status(); if (!status_or_value.ok()) return;
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/parallel_device/parallel_device_lib.cc
}; tensorflow::mutex execution_mutex_; ExecutionState execution_state_ TF_GUARDED_BY(execution_mutex_) = ExecutionState::kIdle; // Tells the worker thread that there is new work. tensorflow::condition_variable start_execute_; // The worker thread notifies that work has finished. tensorflow::condition_variable finished_execute_; // Notifies a StartExecute that the previous Join has finished.
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_lib.h
TF_Status* status) const; void AsyncWait(TFE_Context* context, TF_Status* status) const; // Device strings for component devices that only include a // worker/task/replica if any of those differ across components. Useful for // printing debug messages. std::vector<std::string> SummarizeDeviceNames() const; private:
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 25 15:21:13 GMT 2023 - 12.9K bytes - Viewed (0)