Searched refs:out_mu (Results 1 – 4 of 4) sorted by relevance
124 mutex out_mu; member126 bool out_mu_available GUARDED_BY(out_mu);128 CollectiveParams shared GUARDED_BY(out_mu);132 Status status GUARDED_BY(out_mu);137 int source_rank GUARDED_BY(out_mu);138 string communicator_key GUARDED_BY(out_mu);139 int known_count GUARDED_BY(out_mu);140 std::vector<bool> known GUARDED_BY(out_mu);141 std::vector<IRConsumer> known_waiters GUARDED_BY(out_mu);151 void WaitForOutMu(mutex_lock& lock) EXCLUSIVE_LOCKS_REQUIRED(out_mu);[all …]
432 ir->out_mu.unlock(); in InitInstanceSharedParams()437 EXCLUSIVE_LOCK_FUNCTION(ir->out_mu) { in InitInstanceSharedParams()441 ir->out_mu.lock(); in InitInstanceSharedParams()494 mutex_lock l(irec->out_mu); in CallbackWithStatus()555 ir->out_mu.lock(); in CallInitInstanceSharedParams()560 [this, ir, done](const Status& s) UNLOCK_FUNCTION(ir->out_mu) { in CallInitInstanceSharedParams()563 ir->out_mu.unlock(); in CallInitInstanceSharedParams()661 mutex_lock l(ir->out_mu); in CompleteInstanceFromInitializedIRec()698 mutex_lock l(irec->out_mu); in CompleteInstanceFromInitializedIRec()719 mutex_lock l(ir->out_mu); in WaitForGroup()
57 mutex_lock l(ir.out_mu); in RunCompleteDefaultRanking()
186 mutex_lock l(ir->out_mu); in CompleteInstanceAsync()308 mutex_lock l(ir->out_mu); in UpdateInstanceCache()