- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for async (0.13 sec)
-
tensorflow/c/eager/immediate_execution_operation.h
virtual Status InputLength(const char* input_name, int* length) = 0; virtual Status OutputLength(const char* output_name, int* length) = 0; // Set stack trace to be used for potential async error reporting. virtual void SetStackTrace(ManagedStackTrace stack_trace) = 0; virtual const tensorflow::AbstractOpAttrs* GetOpAttrs() const = 0; virtual void AddAttrs(const AbstractOpAttrs* op_attrs) = 0;
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Sep 26 22:40:32 GMT 2022 - 3.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_internal.h
// TODO(b/154564140): Move this to its own header. This requires splitting // c_api_experimental.h struct TFE_ContextOptions { TF_SessionOptions session_options; // true if async execution is enabled. bool async = false; TFE_ContextDevicePlacementPolicy device_placement_policy{ TFE_DEVICE_PLACEMENT_SILENT}; // If true, use TFRT backend bool use_tfrt = false;
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Jan 18 19:26:34 GMT 2023 - 1.9K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
// placed on each underlying device. class ParallelDevice { public: // Eager async execution is only supported when remote eager is not in use // (b/157523095). explicit ParallelDevice(const std::vector<std::string>& devices, bool is_async = false, int in_flight_nodes_limit = 0); ~ParallelDevice();
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) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
const int in_flight_nodes_limit) : status_(TF_NewStatus()), // If the context's default exector is set to async, re-using that in // each thread would cause collectives to deadlock. For consistency we // create a new sync executor for every thread. // // TODO(allenl): We should have an async API that works with the
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) -
.github/workflows/trusted_partners.js
username has the login username of the Pull Request Event @return {string} Return the domain name of the user's email. Empty string if not found */ const get_email_domain = async ({github, username}) => { const user = await github.rest.users.getByUsername({ username }); if (user.status >= 400) { console.log(user); throw `Error Getting user data for ${username}`; }
JavaScript - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Tue Feb 07 13:52:04 GMT 2023 - 4.5K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/BUILD
visibility = ["//visibility:public"], deps = [ "//tensorflow/compiler/jit:pjrt_tensor_buffer_util", "//tensorflow/core:framework", "//tensorflow/core/tfrt/common:async_value_tensor", "//tensorflow/core/tfrt/common:global_state", "//tensorflow/core/tfrt/common:pjrt_state", "//tensorflow/core/tfrt/common:pjrt_util", "@com_google_absl//absl/status",
Plain Text - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Tue Jan 09 00:52:04 GMT 2024 - 3.8K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/tensor_pjrt_buffer_util.cc
#include "xla/pjrt/pjrt_client.h" #include "tensorflow/core/framework/resource_mgr.h" #include "tensorflow/core/framework/tensor.h" #include "tensorflow/core/framework/types.h" #include "tensorflow/core/tfrt/common/async_value_tensor.h" #include "tensorflow/core/tfrt/common/global_state.h" #include "tensorflow/core/tfrt/common/pjrt_state.h" #include "tensorflow/core/tfrt/common/pjrt_util.h" #include "tsl/platform/errors.h"
C++ - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Mon Oct 30 19:20:20 GMT 2023 - 3.7K bytes - Viewed (0) -
tensorflow/c/eager/c_api.cc
} // Note: this function looks up a thread local policy. So it should be called in // the appropriate client thread. In particular, in async mode, it may not be // safe to call this function from the async EagerExecutor threads. extern TFE_ContextDevicePlacementPolicy TFE_ContextGetDevicePlacementPolicy( TFE_Context* ctx) { return static_cast<TFE_ContextDevicePlacementPolicy>(
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
tensorflow::unwrap(cancellation_manager)); status->status = absl::OkStatus(); } TFE_Executor* TFE_NewExecutor(bool is_async, bool enable_streaming_enqueue, int in_flight_nodes_limit) { return new TFE_Executor(is_async, enable_streaming_enqueue, in_flight_nodes_limit); } void TFE_DeleteExecutor(TFE_Executor* executor) { delete executor; }
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/experimental/filesystem/modular_filesystem.cc
ops_->flush(file_.get(), plugin_status.get()); return StatusFromTF_Status(plugin_status.get()); } Status ModularWritableFile::Sync() { if (ops_->sync == nullptr) return Flush(); UniquePtrTo_TF_Status plugin_status(TF_NewStatus(), TF_DeleteStatus); ops_->sync(file_.get(), plugin_status.get()); return StatusFromTF_Status(plugin_status.get()); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Sep 06 19:12:29 GMT 2023 - 23.1K bytes - Viewed (0)