- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for lock (0.22 sec)
-
ci/official/wheel_test/WORKSPACE
) load("@python//:defs.bzl", "interpreter") load("@rules_python//python:pip.bzl", "pip_parse") pip_parse( name = "pypi", python_interpreter_target = interpreter, requirements = "//:requirements_lock_" + TF_PYTHON_VERSION.replace(".", "_") + ".txt", ) load("@pypi//:requirements.bzl", "install_deps")
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Apr 05 22:27:48 GMT 2024 - 1.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
uint64_t block_size, size_t max_bytes, uint64_t max_staleness, uint64_t stat_cache_max_age, size_t stat_cache_max_entries) : gcs_client(gcs_client), compose(compose), block_cache_lock(), block_size(block_size) { file_block_cache = std::make_unique<RamFileBlockCache>( block_size, max_bytes, max_staleness,
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/eager/parallel_device/parallel_device_lib.cc
std::unique_ptr<Thread> thread_; }; DeviceThread::~DeviceThread() { { tensorflow::mutex_lock l(execution_mutex_); execution_state_ = ExecutionState::kShuttingDown; } start_execute_.notify_one(); } void DeviceThread::AsyncWait(TF_Status* status) { tensorflow::mutex_lock l(execution_mutex_); TFE_ExecutorWaitForAllPendingNodes(executor_.get(), status);
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/experimental/filesystem/plugins/gcs/gcs_filesystem.h
typedef struct GCSFile { google::cloud::storage::Client gcs_client; // owned bool compose; absl::Mutex block_cache_lock; std::shared_ptr<RamFileBlockCache> file_block_cache ABSL_GUARDED_BY(block_cache_lock); uint64_t block_size; // Reads smaller than block_size will trigger a read // of block_size. std::unique_ptr<ExpiringLRUCache<GcsFileStat>> stat_cache;
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:37:41 GMT 2020 - 5.2K bytes - Viewed (0) -
tensorflow/c/c_api_function.cc
} int TF_GraphNumFunctions(TF_Graph* g) { tensorflow::mutex_lock l(g->mu); return g->graph.flib_def().num_functions(); } int TF_GraphGetFunctions(TF_Graph* g, TF_Function** funcs, int max_func, TF_Status* status) { tensorflow::FunctionDefLibrary lib; { tensorflow::mutex_lock l(g->mu); lib = g->graph.flib_def().ToProto(); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 13.6K bytes - Viewed (2) -
tensorflow/c/eager/c_api_unified_experimental_graph.cc
TF_RETURN_IF_ERROR(tensorflow::TensorShapeUtils::MakeShape(dims, shape)); return absl::OkStatus(); } tensorflow::FullTypeDef FullType() const override { const FullTypeDef* ft; mutex_lock l(graph_->mu); graph_->graph.NodeType(output_.oper->node.name(), &ft); if (ft == nullptr) { return FullTypeDef(); } else { return *ft; } } TF_Output output_;
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Mar 12 20:00:09 GMT 2024 - 15.4K bytes - Viewed (1) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
} TF_SetStatus(status, TF_OK, ""); return bytes_transferred; }; for (size_t block_size = 2; block_size <= 4; block_size++) { // Make a cache of N-byte block size (1 block) and verify that reads of // varying offsets and lengths return correct data. tf_gcs_filesystem::RamFileBlockCache cache(block_size, block_size, 0, fetcher);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
tensorflow/c/c_api_function_test.cc
ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); TF_DeleteFunction(grad_func); const StackTracesMap* func_stack_traces; const StackTracesMap* grad_stack_traces; { mutex_lock l(host_graph_->mu); auto flib_def = host_graph_->graph.flib_def(); func_stack_traces = flib_def.GetStackTraces(func_name_); grad_stack_traces = flib_def.GetStackTraces("MyGrad"); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 20 22:08:54 GMT 2023 - 63.6K bytes - Viewed (6) -
tensorflow/c/eager/c_api.h
// you want the latter, use TFE_TensorHandleBackingDeviceName. This function // will block till the operation that produces `h` has completed. TF_CAPI_EXPORT extern const char* TFE_TensorHandleDeviceName( TFE_TensorHandle* h, TF_Status* status); // Returns the name of the device in whose memory `h` resides. // // This function will block till the operation that produces `h` has completed.
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
// Causes the calling thread to block till all ops dispatched in this executor // have been executed. Note that "execution" here refers to kernel execution / // scheduling of copies, etc. Similar to sync execution, it doesn't guarantee // that lower level device queues (like GPU streams) have been flushed. // // This call may not block for execution of ops enqueued concurrently with this // call.
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)