| 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)) {
|
|
|