Searched refs:node_queue_mutex_ (Results 1 – 2 of 2) sorted by relevance
150 tf_shared_lock l(node_queue_mutex_); in status()194 TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);198 void NotifyWaiters(uint64 id) TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);212 TF_EXCLUSIVE_LOCKS_REQUIRED(node_queue_mutex_);218 mutable mutex node_queue_mutex_; variable221 condition_variable nodes_pending_ TF_GUARDED_BY(node_queue_mutex_);225 TF_GUARDED_BY(node_queue_mutex_);229 unfinished_nodes_ TF_GUARDED_BY(node_queue_mutex_);233 Status status_ TF_GUARDED_BY(node_queue_mutex_);234 std::atomic<bool> ok_ TF_GUARDED_BY(node_queue_mutex_);[all …]
46 tensorflow::mutex_lock l(node_queue_mutex_); in ~EagerExecutor()61 tensorflow::mutex_lock l(node_queue_mutex_); in ShutDown()118 tensorflow::mutex_lock l(node_queue_mutex_); in SyncExecute()145 tensorflow::mutex_lock l(node_queue_mutex_); in AddOrExecute()177 tensorflow::mutex_lock l(node_queue_mutex_); in WaitForAllPendingNodes()203 tensorflow::mutex_lock l(node_queue_mutex_); in ClearError()231 mutex_lock l(node_queue_mutex_); in NodeDone()330 tensorflow::mutex_lock l(node_queue_mutex_); in Run()407 tensorflow::mutex_lock l(node_queue_mutex_); in MoveToUnfinished()