Reland of Make RTX pt/apt reconfigurable by calling WebRtcVideoChannel2::SetRecvParameters.

webrtc/logging/rtc_event_log/rtc_event_log_parser.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/logging/rtc_event_log/rtc_event_log_parser.h"
 
+#include <stdint.h>
 #include <string.h>
 
+#include <algorithm>
 #include <fstream>
 #include <istream>
 #include <utility>
 
 #include "webrtc/base/checks.h"
 #include "webrtc/base/logging.h"
 #include "webrtc/call/call.h"
 #include "webrtc/logging/rtc_event_log/rtc_event_log.h"
 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h"
 #include "webrtc/system_wrappers/include/file_wrapper.h"
@@ skipping 282 matching lines @@
   RTC_CHECK(receiver_config.has_remote_ssrc());
   config->rtp.remote_ssrc = receiver_config.remote_ssrc();
   RTC_CHECK(receiver_config.has_local_ssrc());
   config->rtp.local_ssrc = receiver_config.local_ssrc();
   // Get RTCP settings.
   RTC_CHECK(receiver_config.has_rtcp_mode());
   config->rtp.rtcp_mode = GetRuntimeRtcpMode(receiver_config.rtcp_mode());
   RTC_CHECK(receiver_config.has_remb());
   config->rtp.remb = receiver_config.remb();
   // Get RTX map.
-  config->rtp.rtx.clear();
+  std::vector<uint32_t> rtx_ssrcs(receiver_config.rtx_map_size());
+  config->rtp.rtx_payload_types.clear();
   for (int i = 0; i < receiver_config.rtx_map_size(); i++) {
     const rtclog::RtxMap& map = receiver_config.rtx_map(i);
     RTC_CHECK(map.has_payload_type());
     RTC_CHECK(map.has_config());
     RTC_CHECK(map.config().has_rtx_ssrc());
+    rtx_ssrcs[i] = map.config().rtx_ssrc();
     RTC_CHECK(map.config().has_rtx_payload_type());
-    webrtc::VideoReceiveStream::Config::Rtp::Rtx rtx_pair;
-    rtx_pair.ssrc = map.config().rtx_ssrc();
-    rtx_pair.payload_type = map.config().rtx_payload_type();
-    config->rtp.rtx.insert(std::make_pair(map.payload_type(), rtx_pair));
+    config->rtp.rtx_payload_types.insert(
+        std::make_pair(map.payload_type(), map.config().rtx_payload_type()));
+  }
+  if (!rtx_ssrcs.empty()) {
+    config->rtp.rtx_ssrc = rtx_ssrcs[0];
+
+    auto pred = [&config](uint32_t ssrc) {
+      return ssrc == config->rtp.rtx_ssrc;
+    };
+    if (!std::all_of(rtx_ssrcs.cbegin(), rtx_ssrcs.cend(), pred)) {
+      LOG(LS_WARNING) << "RtcEventLog protobuf contained different SSRCs for "
+                         "different received RTX payload types. Will only use "
+                         "rtx_ssrc = "
+                      << config->rtp.rtx_ssrc << ".";
+    }
   }
   // Get header extensions.
   GetHeaderExtensions(&config->rtp.extensions,
                       receiver_config.header_extensions());
   // Get decoders.
   config->decoders.clear();
   for (int i = 0; i < receiver_config.decoders_size(); i++) {
     RTC_CHECK(receiver_config.decoders(i).has_name());
     RTC_CHECK(receiver_config.decoders(i).has_payload_type());
     VideoReceiveStream::Decoder decoder;
@@ skipping 137 matching lines @@
   if (ana_event.has_frame_length_ms())
     config->frame_length_ms = rtc::Optional<int>(ana_event.frame_length_ms());
   if (ana_event.has_num_channels())
     config->num_channels = rtc::Optional<size_t>(ana_event.num_channels());
   if (ana_event.has_uplink_packet_loss_fraction())
     config->uplink_packet_loss_fraction =
         rtc::Optional<float>(ana_event.uplink_packet_loss_fraction());
 }
 
 }  // namespace webrtc