Searched refs:closures_ (Results 1 – 2 of 2) sorted by relevance
132 closures_.emplace_back(closure, error, reason); in Add()143 if (closures_.empty()) { in RunClosures()147 for (size_t i = 1; i < closures_.size(); ++i) { in RunClosures()148 auto& closure = closures_[i]; in RunClosures()156 call_combiner, closures_[0].closure, in RunClosures()157 grpc_error_string(closures_[0].error), closures_[0].reason); in RunClosures()160 GRPC_CLOSURE_SCHED(closures_[0].closure, closures_[0].error); in RunClosures()161 closures_.clear(); in RunClosures()167 for (size_t i = 0; i < closures_.size(); ++i) { in RunClosuresWithoutYielding()168 auto& closure = closures_[i]; in RunClosuresWithoutYielding()[all …]
158 bool insert_successful = closures_.emplace(key, std::move(result)).second; in Produce()166 auto it = closures_.find(key); in Consume()167 DCHECK(it != closures_.end()); in Consume()169 closures_.erase(it); in Consume()181 absl::flat_hash_map<KeyT, XlaExecutableClosure> closures_ GUARDED_BY(mutex_);