Searched refs:pending_flushes (Results 1 – 3 of 3) sorted by relevance
1585 if (tracing_session->pending_flushes.size() > 1000) { in Flush()1587 tracing_session->pending_flushes.size()); in Flush()1594 tracing_session->pending_flushes in Flush()1595 .emplace_hint(tracing_session->pending_flushes.end(), in Flush()1636 auto& pending_flushes = kv.second.pending_flushes; in NotifyFlushDoneForProducer() local1637 auto end_it = pending_flushes.upper_bound(flush_request_id); in NotifyFlushDoneForProducer()1638 for (auto it = pending_flushes.begin(); it != end_it;) { in NotifyFlushDoneForProducer()1651 it = pending_flushes.erase(it); in NotifyFlushDoneForProducer()1664 auto it = tracing_session->pending_flushes.find(flush_request_id); in OnFlushTimeout()1665 if (it == tracing_session->pending_flushes.end()) in OnFlushTimeout()[all …]
492 std::map<FlushRequestID, PendingFlush> pending_flushes; member
157 return tracing_session()->pending_flushes.size(); in GetNumPendingFlushes()