Video/Screenshare loopback tool.

webrtc/modules/pacing/alr_detector.cc

 /*
  *  Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #include "webrtc/modules/pacing/alr_detector.h"
 
 #include <string>
 
+#include "webrtc/logging/rtc_event_log/rtc_event_log.h"
 #include "webrtc/rtc_base/checks.h"
 #include "webrtc/rtc_base/format_macros.h"
 #include "webrtc/rtc_base/logging.h"
 #include "webrtc/rtc_base/timeutils.h"
 #include "webrtc/system_wrappers/include/field_trial.h"
 
 namespace webrtc {
 
 const char AlrDetector::kScreenshareProbingBweExperimentName[] =
     "WebRTC-ProbingScreenshareBwe";
 const char AlrDetector::kStrictPacingAndProbingExperimentName[] =
     "WebRTC-StrictPacingAndProbing";
 
-AlrDetector::AlrDetector()
+AlrDetector::AlrDetector() : AlrDetector(nullptr) {}
+
+AlrDetector::AlrDetector(RtcEventLog* event_log)
     : bandwidth_usage_percent_(kDefaultAlrBandwidthUsagePercent),
       alr_start_budget_level_percent_(kDefaultAlrStartBudgetLevelPercent),
       alr_stop_budget_level_percent_(kDefaultAlrStopBudgetLevelPercent),
-      alr_budget_(0, true) {
+      alr_budget_(0, true),
+      event_log_(event_log) {
   RTC_CHECK(
       field_trial::FindFullName(kStrictPacingAndProbingExperimentName)
           .empty() ||
       field_trial::FindFullName(kScreenshareProbingBweExperimentName).empty());
   rtc::Optional<AlrExperimentSettings> experiment_settings =
       ParseAlrSettingsFromFieldTrial(kScreenshareProbingBweExperimentName);
   if (!experiment_settings) {
     experiment_settings =
         ParseAlrSettingsFromFieldTrial(kStrictPacingAndProbingExperimentName);
   }
   if (experiment_settings) {
     alr_stop_budget_level_percent_ =
         experiment_settings->alr_stop_budget_level_percent;
     alr_start_budget_level_percent_ =
         experiment_settings->alr_start_budget_level_percent;
     bandwidth_usage_percent_ = experiment_settings->alr_bandwidth_usage_percent;
   }
 }
 
 AlrDetector::~AlrDetector() {}
 
 void AlrDetector::OnBytesSent(size_t bytes_sent, int64_t delta_time_ms) {
   alr_budget_.UseBudget(bytes_sent);
   alr_budget_.IncreaseBudget(delta_time_ms);
-
   if (alr_budget_.budget_level_percent() > alr_start_budget_level_percent_ &&
       !alr_started_time_ms_) {
     alr_started_time_ms_.emplace(rtc::TimeMillis());
   } else if (alr_budget_.budget_level_percent() <
                  alr_stop_budget_level_percent_ &&
              alr_started_time_ms_) {
     alr_started_time_ms_.reset();
   }
+  int usage = 100 - alr_budget_.budget_level_percent();
+  uint32_t usage_kbps = usage * alr_budget_.target_rate_kbps() / 200;
+  usage_kbps *= 100.0 / bandwidth_usage_percent_;
+  if (event_log_)
+    event_log_->LogAlrState(alr_started_time_ms_.has_value(),
+                            usage_kbps * 1000);
 }
 
 void AlrDetector::SetEstimatedBitrate(int bitrate_bps) {
   RTC_DCHECK(bitrate_bps);
   alr_budget_.set_target_rate_kbps(bitrate_bps * bandwidth_usage_percent_ /
                                    (1000 * 100));
 }
 
 rtc::Optional<int64_t> AlrDetector::GetApplicationLimitedRegionStartTime()
     const {
@@ skipping 32 matching lines @@
                  << ", ALR end budget level percent: "
                  << settings.alr_stop_budget_level_percent;
   } else {
     LOG(LS_INFO) << "Failed to parse ALR experiment: " << experiment_name;
   }
 
   return ret;
 }
 
 }  // namespace webrtc