- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for locks (0.18 sec)
-
tensorflow/c/c_api.cc
bool ExtendSessionGraphHelper(TF_Session* session, TF_Status* status) { if (session->graph != nullptr) { // Take the graph lock before the session lock to avoid deadlock. This is // safe since session->graph does not change. session->graph->mu.lock(); mutex_lock session_lock(session->mu); const Graph& graph = session->graph->graph; const string& mutation_warning = session->graph->sessions[session];
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 102.3K 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/c_api_experimental.cc
static std::unordered_map<std::string, void*>* loaded_libs = new std::unordered_map<std::string, void*>(); tensorflow::Env* env = tensorflow::Env::Default(); { tensorflow::mutex_lock lock(mu); auto it = loaded_libs->find(library_filename); if (it != loaded_libs->end()) { lib_handle->lib_handle = it->second; } else { status->status =
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 29.4K 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/eager/gradients.cc
// Builds a tensor filled with ones with the same shape and dtype as `t`. Status BuildOnesLike(const TapeTensor& t, AbstractTensorHandle** result) const override; // Looks up the ID of a Gradient. int64_t TensorId(AbstractTensorHandle* tensor) const override; // Converts a Gradient to a TapeTensor. TapeTensor TapeTensorFromGradient(AbstractTensorHandle* g) const override;
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 09:49:45 GMT 2024 - 19.3K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
// The environment variable that overrides the max size of the LRU cache of // blocks read from GCS. Specified in MB. constexpr char kMaxCacheSize[] = "GCS_READ_CACHE_MAX_SIZE_MB"; constexpr size_t kDefaultMaxCacheSize = 0; // The environment variable that overrides the maximum staleness of cached file // contents. Once any block of a file reaches this staleness, all cached blocks // will be evicted on the next read.
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/plugins/gcs/ram_file_block_cache_test.cc
EXPECT_EQ(out, B); EXPECT_EQ(calls, 4); // Remove the blocks from "a". cache.RemoveFile("a"); // Both blocks from "b" should still be there. TF_EXPECT_OK(ReadCache(&cache, "b", 0, n, &out)); EXPECT_EQ(out, b); TF_EXPECT_OK(ReadCache(&cache, "b", 8, n, &out)); EXPECT_EQ(out, B); EXPECT_EQ(calls, 4); // The blocks from "a" should not be there. TF_EXPECT_OK(ReadCache(&cache, "a", 0, n, &out));
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)