Searched refs:pending_flush (Results 1 – 1 of 1) sorted by relevance
1593 PendingFlush& pending_flush = in Flush() local1614 pending_flush.producers.insert(producer_id); in Flush()1639 PendingFlush& pending_flush = it->second; in NotifyFlushDoneForProducer() local1640 pending_flush.producers.erase(producer_id); in NotifyFlushDoneForProducer()1641 if (pending_flush.producers.empty()) { in NotifyFlushDoneForProducer()1644 auto callback = std::move(pending_flush.callback); in NotifyFlushDoneForProducer()