- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for sync (0.14 sec)
-
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
if (fflush(posix_file->handle) != 0) TF_SetStatusFromIOError(status, errno, posix_file->filename); } static void Sync(const TF_WritableFile* file, TF_Status* status) { // For historical reasons, this does the same as `Flush` at the moment. // TODO(b/144055243): This should use `fsync`/`sync`. Flush(file, status); } static void Close(const TF_WritableFile* file, TF_Status* status) {
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sun Mar 24 20:08:23 GMT 2024 - 15.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
TFE_Execute(op, out_value, &num_retvals, status); ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteOp(op); TF_DeleteStatus(status); } void TestRemoteExecuteChangeServerDef(bool async) { tensorflow::ServerDef server_def = GetServerDef(2); // This server def has the task index set to 0. string serialized = server_def.SerializeAsString(); server_def.set_task_index(1);
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.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) -
tensorflow/c/eager/c_api_distributed_test.cc
TFE_TensorHandle* h0 = TestVariable(ctx, 1.0, task1_name); TFE_TensorHandle* h1 = TestVariable(ctx, 2.0, task2_name); TFE_TensorHandle* h2 = TestVariable(ctx, 3.0, task0_name); // Add a sync point to make sure that variables have been initialized // before the function execution starts. TFE_ContextAsyncWait(ctx, status); EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
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/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
gcs_file->object.c_str()); if (TF_GetCode(status) != TF_OK) return; gcs_file->sync_need = false; } else { TF_SetStatus(status, TF_OK, ""); } } void Sync(const TF_WritableFile* file, TF_Status* status) { auto gcs_file = static_cast<GCSFile*>(file->plugin_file); TF_VLog(3, "Sync: gs://%s/%s", gcs_file->bucket.c_str(), gcs_file->object.c_str()); Flush(file, status); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 23 06:55:53 GMT 2023 - 46.9K bytes - Viewed (0) -
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) -
tensorflow/c/experimental/next_pluggable_device/tensor_pjrt_buffer_util_test.cc
#include "xla/pjrt/pjrt_c_api_client.h" #include "xla/pjrt/tfrt_cpu_pjrt_client.h" #include "xla/shape.h" #include "xla/shape_util.h" #include "tensorflow/core/framework/types.h" #include "tensorflow/core/tfrt/common/async_value_tensor.h" #include "tensorflow/core/tfrt/common/pjrt_util.h" #include "tsl/lib/core/status_test_util.h" #include "tsl/platform/casts.h" #include "tsl/platform/status_matchers.h" #include "tsl/protobuf/error_codes.pb.h"
C++ - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Mon Oct 30 19:20:20 GMT 2023 - 7.2K 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/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_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)