Searched refs:node_queue_mutex_ (Results 1 – 2 of 2) sorted by relevance
152 tf_shared_lock l(node_queue_mutex_); in status()196 TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);200 void NotifyWaiters(uint64 id) TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);214 TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);220 mutable mutex node_queue_mutex_; variable223 condition_variable nodes_pending_ TF_GUARDED_BY(node_queue_mutex_);227 TF_GUARDED_BY(node_queue_mutex_);231 unfinished_nodes_ TF_GUARDED_BY(node_queue_mutex_);235 Status status_ TF_GUARDED_BY(node_queue_mutex_);236 std::atomic<bool> ok_ TF_GUARDED_BY(node_queue_mutex_);[all …]
47 tensorflow::mutex_lock l(node_queue_mutex_); in ~EagerExecutor()62 tensorflow::mutex_lock l(node_queue_mutex_); in ShutDown()119 tensorflow::mutex_lock l(node_queue_mutex_); in SyncExecute()142 tensorflow::mutex_lock l(node_queue_mutex_); in AddOrExecute()174 tensorflow::mutex_lock l(node_queue_mutex_); in WaitForAllPendingNodes()199 tensorflow::mutex_lock l(node_queue_mutex_); in ClearError()227 mutex_lock l(node_queue_mutex_); in NodeDone()326 tensorflow::mutex_lock l(node_queue_mutex_); in Run()403 tensorflow::mutex_lock l(node_queue_mutex_); in MoveToUnfinished()