- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for mutex_lock (0.19 sec)
-
tensorflow/cc/training/coordinator.cc
{ mutex_lock l(mu_); if (should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "The coordinator has been stopped."); } } mutex_lock l(runners_lock_); runners_.push_back(std::move(runner)); return absl::OkStatus(); } bool Coordinator::AllRunnersStopped() { mutex_lock l(runners_lock_); for (const auto& runner : runners_) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
Status QueueRunner::Join() { thread_pool_.reset(); mutex_lock l(mu_); return status_; } void QueueRunner::UpdateStatus(const Status& status) { { mutex_lock l(mu_); if (!status_.ok() || status.ok() || IsQueueClosed(status)) { return; } status_ = status; } if (coord_) { coord_->ReportStatus(status); } mutex_lock l(cb_mu_); for (auto& cb : callbacks_) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compilation_profiler.cc
} void DeviceCompilationProfiler::IncrementOngoingAsyncCompilations() { mutex_lock lock(mu_); num_ongoing_compilations_++; } void DeviceCompilationProfiler::DecrementOngoingAsyncCompilations() { mutex_lock lock(mu_); num_ongoing_compilations_--; } int64_t DeviceCompilationProfiler::GetNumOngoingAsyncCompilations() const { mutex_lock lock(mu_); return num_ongoing_compilations_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 8.5K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compilation_cache.h
// protect the contents of the cache entry. Entry* entry; { mutex_lock lock(compile_cache_mu_); // Find cache entry. auto it = cache_.find(key); if (it == cache_.cend()) { return std::nullopt; } entry = it->second.get(); } mutex_lock lock(entry->mu); Value value = {/*compile_state=*/entry->compile_state,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 8.9K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device.cc
} void XlaDevice::SetAllowsSyncOnCompletion(bool sync_on_completion) { mutex_lock lock(mu_); sync_on_completion_ = sync_on_completion; } bool XlaDevice::AllowsSyncOnCompletion() const { mutex_lock lock(mu_); return sync_on_completion_; } void XlaDevice::SetHandleDeviceErrorCallback(std::function<Status()> callback) { mutex_lock lock(mu_); device_error_callback_ = callback; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 21:05:42 UTC 2024 - 24.3K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_tensor.cc
} void XlaTensor::ResetDefinitionEvent(std::shared_ptr<se::Event> event, se::Stream* stream) { mutex_lock lock(mu_); definition_event_ = std::move(event); streams_defined_on_ = {stream}; } Status XlaTensor::RefreshStatusOfStreams() { mutex_lock lock(mu_); Status status; for (se::Stream* stream : streams_defined_on_) { status.Update(stream->RefreshStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 4.5K bytes - Viewed (0) -
tensorflow/c/c_api.cc
GraphDef def; { mutex_lock l(graph->mu); graph->graph.ToGraphDef(&def); } status->status = MessageToBuffer(def, output_graph_def); } void TF_GraphGetOpDef(TF_Graph* graph, const char* op_name, TF_Buffer* output_op_def, TF_Status* status) { const OpDef* op_def; { mutex_lock l(graph->mu);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 03:35:10 UTC 2024 - 102.3K bytes - Viewed (0) -
tensorflow/c/python_api.cc
// Do not delete. Do not use. void ExportRecordMutation( // NOLINT: Intentionally unused function. TF_Graph* graph, const TF_Operation& op, const char* mutation_type) { mutex_lock l(graph->mu); RecordMutation(graph, op, mutation_type); } void AddControlInput(TF_Graph* graph, TF_Operation* op, TF_Operation* input) { TF_AddOperationControlInput(graph, op, input); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jul 12 18:48:56 UTC 2023 - 3.5K 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(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 03:35:10 UTC 2024 - 13.6K bytes - Viewed (0) -
tensorflow/c/kernels_experimental.cc
std::unique_ptr<std::vector<tensorflow::mutex_lock>> locks, std::unique_ptr<std::vector<tensorflow::tf_shared_lock>> shared_locks) : vars(std::move(vars)), locks(std::move(locks)), shared_locks(std::move(shared_locks)) {} std::vector<tensorflow::Var*> vars; std::unique_ptr<std::vector<tensorflow::mutex_lock>> locks;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 23 06:12:29 UTC 2024 - 30.9K bytes - Viewed (0)