Searched refs:node_queue_mutex_ (Results 1 – 2 of 2) sorted by relevance
132 tf_shared_lock l(node_queue_mutex_); in status()168 const char* StateStringLocked() EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);172 void NotifyWaiters(uint64 id) EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);186 EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);192 mutable mutex node_queue_mutex_; variable195 condition_variable nodes_pending_ GUARDED_BY(node_queue_mutex_);199 GUARDED_BY(node_queue_mutex_);203 unfinished_nodes_ GUARDED_BY(node_queue_mutex_);207 Status status_ GUARDED_BY(node_queue_mutex_);208 std::atomic<bool> ok_ GUARDED_BY(node_queue_mutex_);[all …]
34 tensorflow::mutex_lock l(node_queue_mutex_); in ~EagerExecutor()45 tensorflow::mutex_lock l(node_queue_mutex_); in ShutDown()105 tensorflow::mutex_lock l(node_queue_mutex_); in SyncExecute()132 tensorflow::mutex_lock l(node_queue_mutex_); in AddOrExecute()164 tensorflow::mutex_lock l(node_queue_mutex_); in WaitForAllPendingNodes()190 tensorflow::mutex_lock l(node_queue_mutex_); in ClearError()217 mutex_lock l(node_queue_mutex_); in NodeDone()304 tensorflow::mutex_lock l(node_queue_mutex_); in Run()354 tensorflow::mutex_lock l(node_queue_mutex_); in MoveToUnfinished()