| 284 | } |
| 285 | |
| 286 | void Consumer::HandleTaskFinish() { |
| 287 | ++impl_->nhandle_task_finished; |
| 288 | if (impl_->nhandle_task_finished == impl_->items.size() && impl_->nbatch_handle_task_finished == impl_->opt.nbatch_handler) co_cond_signal(impl_->cond); |
| 289 | } |
| 290 | |
| 291 | void Consumer::BatchHandleTaskFinish() { |
| 292 | ++impl_->nbatch_handle_task_finished; |
nothing calls this directly
no outgoing calls
no test coverage detected