Searched refs:pending_flush (Results 1 – 1 of 1) sorted by relevance
1062 PendingFlush& pending_flush = in Flush() local1083 pending_flush.producers.insert(producer_id); in Flush()1108 PendingFlush& pending_flush = it->second; in NotifyFlushDoneForProducer() local1109 pending_flush.producers.erase(producer_id); in NotifyFlushDoneForProducer()1110 if (pending_flush.producers.empty()) { in NotifyFlushDoneForProducer()1113 auto callback = std::move(pending_flush.callback); in NotifyFlushDoneForProducer()