- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for mutex_lock (0.16 sec)
-
tensorflow/cc/client/client_session.cc
std::vector<Tensor>* outputs) const { return Run(RunOptions(), inputs, fetch_outputs, run_outputs, outputs, nullptr); } Status ClientSession::Impl::MaybeExtendGraph() const { mutex_lock l(mu_); int num_nodes = graph_->num_node_ids(); if (num_nodes > last_num_graph_nodes_) { GraphDef graph_def; graph_->ToGraphDefSubRange(&graph_def, last_num_graph_nodes_); last_num_graph_nodes_ = num_nodes;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 28 09:04:10 UTC 2024 - 7.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/dump_mlir_util.cc
char ch = name[i]; if (ch == '/' || ch == '[' || ch == ']' || ch == '*' || ch == '?' || ch == '\\') { name[i] = '_'; } } int count; { mutex_lock lock(instance.counts_mutex); count = instance.counts[name]++; } std::string filename = name; if (count > 0) { filename = llvm::formatv("{0}_{1}", filename, count).str(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jan 05 03:03:46 UTC 2024 - 11.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/lift_as_function_call.cc
StringAttr InsertToSymbolTable(Operation& module, Operation& function, const StringRef func_name) { static tensorflow::mutex* mtx = new tensorflow::mutex(); tensorflow::mutex_lock lock(*mtx); SymbolTable symbol_table(&module); std::string unique_name = func_name.str(); int32_t uniquing_counter = 0; while (symbol_table.lookup(unique_name) != nullptr) { ++uniquing_counter;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 17:58:54 UTC 2024 - 21.8K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass.cc
return absl::OkStatus(); } // Tracks monotonic sequence numbers for graphs. class ClusterSequenceNumberGenerator { public: void Reset() { mutex_lock lock(mu_); sequence_numbers_.clear(); } int64 GetNext(uint64 key) { mutex_lock lock(mu_); return sequence_numbers_[key]++; } static ClusterSequenceNumberGenerator& Global() { static ClusterSequenceNumberGenerator* gen =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 12:19:41 UTC 2024 - 85.3K 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"); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 20 22:08:54 UTC 2023 - 63.6K bytes - Viewed (0) -
src/internal/poll/fd_mutex.go
// 20 bits - total number of references (read+write+misc). // 20 bits - number of outstanding read waiters. // 20 bits - number of outstanding write waiters. const ( mutexClosed = 1 << 0 mutexRLock = 1 << 1 mutexWLock = 1 << 2 mutexRef = 1 << 3 mutexRefMask = (1<<20 - 1) << 3 mutexRWait = 1 << 23 mutexRMask = (1<<20 - 1) << 23 mutexWWait = 1 << 43 mutexWMask = (1<<20 - 1) << 43 )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
return true; } size_t RamFileBlockCache::CacheSize() const { absl::MutexLock lock(&mu_); return cache_size_; } void RamFileBlockCache::Prune() { while (!stop_pruning_thread_.WaitForNotificationWithTimeout( absl::Microseconds(1000000))) { absl::MutexLock lock(&mu_); uint64_t now = timer_seconds_(); while (!lra_list_.empty()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 16 01:39:09 UTC 2020 - 11.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache.h
if (max_age_ == 0) { return; } absl::MutexLock lock(&mu_); InsertLocked(key, value); } // Delete the entry with key `key`. Return true if the entry was found for // `key`, false if the entry was not found. In both cases, there is no entry // with key `key` existed after the call. bool Delete(const std::string& key) { absl::MutexLock lock(&mu_); return DeleteLocked(key); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 09 19:31:22 UTC 2020 - 6.3K bytes - Viewed (0) -
src/runtime/lock_wasip1.go
// while allowing other goroutines to run. const ( mutex_unlocked = 0 mutex_locked = 1 active_spin = 4 active_spin_cnt = 30 ) func mutexContended(l *mutex) bool { return false } func lock(l *mutex) { lockWithRank(l, getLockRank(l)) } func lock2(l *mutex) { if l.key == mutex_locked { // wasm is single-threaded so we should never // observe this. throw("self deadlock")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 2K bytes - Viewed (0) -
src/runtime/lock_futex.go
// futexwakeup(addr *uint32, cnt uint32) // If any procs are sleeping on addr, wake up at most cnt. const ( mutex_unlocked = 0 mutex_locked = 1 mutex_sleeping = 2 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 ) // Possible lock states are mutex_unlocked, mutex_locked and mutex_sleeping. // mutex_sleeping means that there is presumably at least one sleeping thread.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0)