Index: webrtc/logging/rtc_event_log/rtc_event_log.cc |
diff --git a/webrtc/logging/rtc_event_log/rtc_event_log.cc b/webrtc/logging/rtc_event_log/rtc_event_log.cc |
index e661e679828dc401ede7bfbce978fd09ae040a7b..bb6096856e24cb566234f7ea41e807d225398115 100644 |
--- a/webrtc/logging/rtc_event_log/rtc_event_log.cc |
+++ b/webrtc/logging/rtc_event_log/rtc_event_log.cc |
@@ -93,6 +93,9 @@ class RtcEventLogImpl final : public RtcEventLog { |
void LogProbeResultSuccess(int id, int bitrate_bps) override; |
void LogProbeResultFailure(int id, |
ProbeFailureReason failure_reason) override; |
+ void LogAckedBitrate(uint32_t bitrate_bps) override; |
+ void LogAlrState(bool in_alr, uint32_t bitrate_bps) override; |
+ void LogPacketQueueTime(uint32_t ssrc, int64_t time_ms) override; |
private: |
// Private constructor to ensure that creation is done by RtcEventLog::Create. |
@@ -565,6 +568,38 @@ void RtcEventLogImpl::LogProbeResult(int id, |
StoreEvent(std::move(event)); |
} |
+void RtcEventLogImpl::LogAckedBitrate(uint32_t bitrate_bps) { |
+ std::unique_ptr<rtclog::Event> event(new rtclog::Event()); |
+ event->set_timestamp_us(rtc::TimeMicros()); |
+ event->set_type(rtclog::Event::BWE_ACKED_BITRATE_EVENT); |
+ |
+ auto acked_bitrate = event->mutable_acked_bitrate(); |
+ acked_bitrate->set_bitrate_bps(bitrate_bps); |
+ StoreEvent(std::move(event)); |
+} |
+ |
+void RtcEventLogImpl::LogAlrState(bool in_alr, uint32_t usage_bps) { |
+ std::unique_ptr<rtclog::Event> event(new rtclog::Event()); |
+ event->set_timestamp_us(rtc::TimeMicros()); |
+ event->set_type(rtclog::Event::ALR_STATE_EVENT); |
+ |
+ auto alr_state = event->mutable_alr_state(); |
+ alr_state->set_in_alr(in_alr); |
+ alr_state->set_usage_bps(usage_bps); |
+ StoreEvent(std::move(event)); |
+} |
+ |
+void RtcEventLogImpl::LogPacketQueueTime(uint32_t ssrc, int64_t time_ms) { |
+ std::unique_ptr<rtclog::Event> event(new rtclog::Event()); |
+ event->set_timestamp_us(rtc::TimeMicros()); |
+ event->set_type(rtclog::Event::PACKET_QUEUE_TIME); |
+ |
+ auto queue_time = event->mutable_packet_queue_time(); |
+ queue_time->set_queue_time_ms(time_ms); |
+ queue_time->set_ssrc(ssrc); |
+ StoreEvent(std::move(event)); |
+} |
+ |
void RtcEventLogImpl::StoreEvent(std::unique_ptr<rtclog::Event> event) { |
RTC_DCHECK(event.get() != nullptr); |
if (!event_queue_.Insert(&event)) { |