Searched refs:PendingFlush (Results 1 – 2 of 2) sorted by relevance
368 struct PendingFlush { struct371 explicit PendingFlush(decltype(callback) cb) : callback(std::move(cb)) {} in PendingFlush() function492 std::map<FlushRequestID, PendingFlush> pending_flushes;
1593 PendingFlush& pending_flush = in Flush()1596 flush_request_id, PendingFlush(std::move(callback))) in Flush()1639 PendingFlush& pending_flush = it->second; in NotifyFlushDoneForProducer()