Home | History | Annotate | Download | only in core

Lines Matching refs:pending_flush

1062   PendingFlush& pending_flush =
1083     pending_flush.producers.insert(producer_id);
1108       PendingFlush& pending_flush = it->second;
1109       pending_flush.producers.erase(producer_id);
1110       if (pending_flush.producers.empty()) {
1113         auto callback = std::move(pending_flush.callback);