Searched refs:PendingFlush (Results 1 – 2 of 2) sorted by relevance
330 struct PendingFlush { struct333 explicit PendingFlush(decltype(callback) cb) : callback(std::move(cb)) {} in PendingFlush() argument435 std::map<FlushRequestID, PendingFlush> pending_flushes;
1062 PendingFlush& pending_flush = in Flush()1065 flush_request_id, PendingFlush(std::move(callback))) in Flush()1108 PendingFlush& pending_flush = it->second; in NotifyFlushDoneForProducer()