Filter overlapping RTP header extensions.

talk/media/webrtc/webrtcmediaengine.cc

 /*
  * libjingle
  * Copyright 2014 Google Inc.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are met:
  *
  *  1. Redistributions of source code must retain the above copyright notice,
  *     this list of conditions and the following disclaimer.
  *  2. Redistributions in binary form must reproduce the above copyright notice,
@@ skipping 50 matching lines @@
 
 // Used by PeerConnectionFactory to create a media engine passed into
 // ChannelManager.
 MediaEngineInterface* WebRtcMediaEngineFactory::Create(
     webrtc::AudioDeviceModule* adm,
     WebRtcVideoEncoderFactory* encoder_factory,
     WebRtcVideoDecoderFactory* decoder_factory) {
   return CreateWebRtcMediaEngine(adm, encoder_factory, decoder_factory);
 }
 
+const char* kBweExtensionPriorities[] = {
+    kRtpTransportSequenceNumberHeaderExtension,
+    kRtpAbsoluteSenderTimeHeaderExtension, kRtpTimestampOffsetHeaderExtension};
+
+const size_t kBweExtensionPrioritiesLength =
+    ARRAY_SIZE(kBweExtensionPriorities);
+
+int GetPriority(const RtpHeaderExtension& extension,
+                const char* extension_prios[],
+                size_t extension_prios_length) {
+  for (size_t i = 0; i < extension_prios_length; ++i) {
+    if (extension.uri == extension_prios[i])
+      return static_cast<int>(i);
+  }
+  return -1;
+}
+
+std::vector<RtpHeaderExtension> FilterRedundantRtpExtensions(
+    const std::vector<RtpHeaderExtension>& extensions,
+    const char* extension_prios[],
+    size_t extension_prios_length) {
+  if (extensions.empty())
+    return std::vector<RtpHeaderExtension>();
+  std::vector<RtpHeaderExtension> filtered;
+  std::map<int, const RtpHeaderExtension*> sorted;
+  for (auto& extension : extensions) {
+    int priority =
+        GetPriority(extension, extension_prios, extension_prios_length);
+    if (priority == -1) {
+      filtered.push_back(extension);
+      continue;
+    } else {
+      sorted[priority] = &extension;
+    }
+  }
+  if (!sorted.empty())
+    filtered.push_back(*sorted.begin()->second);
+  return filtered;
+}
+
 }  // namespace cricket