Searched refs:closures_ (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | call_combiner.h | 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 …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | call_combiner.h | 154 closures_.emplace_back(closure, error, reason); in Add()
165 if (closures_.empty()) { in RunClosures()
169 for (size_t i = 1; i < closures_.size(); ++i) { in RunClosures()
170 auto& closure = closures_[i]; in RunClosures()
178 call_combiner, closures_[0].closure, in RunClosures()
179 grpc_error_string(closures_[0].error), closures_[0].reason); in RunClosures()
182 ExecCtx::Run(DEBUG_LOCATION, closures_[0].closure, closures_[0].error); in RunClosures()
183 closures_.clear(); in RunClosures()
189 for (size_t i = 0; i < closures_.size(); ++i) { in RunClosuresWithoutYielding()
190 auto& closure = closures_[i]; in RunClosuresWithoutYielding()
[all …]
|
| /external/tensorflow/tensorflow/compiler/jit/kernels/ |
| D | xla_ops.cc | 121 bool insert_successful = closures_.emplace(key, std::move(result)).second; in Produce()
129 auto it = closures_.find(key); in Consume()
130 DCHECK(it != closures_.end()); in Consume()
132 closures_.erase(it); in Consume()
144 absl::flat_hash_map<KeyT, XlaExecutableClosure> closures_
|