Searched refs:pending_flushes (Results 1 – 3 of 3) sorted by relevance
1054 if (tracing_session->pending_flushes.size() > 1000) { in Flush()1056 tracing_session->pending_flushes.size()); in Flush()1063 tracing_session->pending_flushes in Flush()1064 .emplace_hint(tracing_session->pending_flushes.end(), in Flush()1105 auto& pending_flushes = kv.second.pending_flushes; in NotifyFlushDoneForProducer() local1106 auto end_it = pending_flushes.upper_bound(flush_request_id); in NotifyFlushDoneForProducer()1107 for (auto it = pending_flushes.begin(); it != end_it;) { in NotifyFlushDoneForProducer()1120 it = pending_flushes.erase(it); in NotifyFlushDoneForProducer()1133 auto it = tracing_session->pending_flushes.find(flush_request_id); in OnFlushTimeout()1134 if (it == tracing_session->pending_flushes.end()) in OnFlushTimeout()[all …]
435 std::map<FlushRequestID, PendingFlush> pending_flushes; member
144 return tracing_session()->pending_flushes.size(); in GetNumPendingFlushes()