Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(121)

Side by Side Diff: webrtc/call/rtp_rtcp_demuxer_helper.h

Issue 2968693002: SSRC and RSID may only refer to one sink each in RtpDemuxer (Closed)
Patch Set: Add expectations to OnlyOneSinkPerSsrcGetsOnRtpPacketTriggered. Created 3 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « webrtc/call/rtp_demuxer_unittest.cc ('k') | webrtc/call/rtp_stream_receiver_controller.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2017 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2017 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
11 #ifndef WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_ 11 #ifndef WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_
12 #define WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_ 12 #define WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_
13 13
14 #include <algorithm> 14 #include <algorithm>
15 #include <map> 15 #include <map>
16 #include <utility> 16 #include <utility>
17 17
18 #include "webrtc/rtc_base/array_view.h" 18 #include "webrtc/rtc_base/array_view.h"
19 #include "webrtc/rtc_base/basictypes.h" 19 #include "webrtc/rtc_base/basictypes.h"
20 #include "webrtc/rtc_base/optional.h" 20 #include "webrtc/rtc_base/optional.h"
21 21
22 namespace webrtc { 22 namespace webrtc {
23 23
24 // TODO(eladalon): Remove this in the next CL.
24 template <typename Container> 25 template <typename Container>
25 bool MultimapAssociationExists(const Container& multimap, 26 bool MultimapAssociationExists(const Container& multimap,
26 const typename Container::key_type& key, 27 const typename Container::key_type& key,
27 const typename Container::mapped_type& val) { 28 const typename Container::mapped_type& val) {
28 auto it_range = multimap.equal_range(key); 29 auto it_range = multimap.equal_range(key);
29 using Reference = typename Container::const_reference; 30 using Reference = typename Container::const_reference;
30 return std::any_of(it_range.first, it_range.second, 31 return std::any_of(it_range.first, it_range.second,
31 [val](Reference elem) { return elem.second == val; }); 32 [val](Reference elem) { return elem.second == val; });
32 } 33 }
33 34
35 // TODO(eladalon): Remove this in the next CL.
34 template <typename Container, typename Value> 36 template <typename Container, typename Value>
35 size_t RemoveFromMultimapByValue(Container* multimap, const Value& value) { 37 size_t RemoveFromMultimapByValue(Container* multimap, const Value& value) {
36 size_t count = 0; 38 size_t count = 0;
37 for (auto it = multimap->begin(); it != multimap->end();) { 39 for (auto it = multimap->begin(); it != multimap->end();) {
38 if (it->second == value) { 40 if (it->second == value) {
39 it = multimap->erase(it); 41 it = multimap->erase(it);
40 ++count; 42 ++count;
41 } else { 43 } else {
42 ++it; 44 ++it;
43 } 45 }
44 } 46 }
45 return count; 47 return count;
46 } 48 }
47 49
50 template <typename Map, typename Value>
51 size_t RemoveFromMapByValue(Map* map, const Value& value) {
52 size_t count = 0;
53 for (auto it = map->begin(); it != map->end();) {
54 if (it->second == value) {
55 it = map->erase(it);
56 ++count;
57 } else {
58 ++it;
59 }
60 }
61 return count;
62 }
63
48 template <typename Container, typename Key> 64 template <typename Container, typename Key>
49 bool ContainerHasKey(const Container& c, const Key& k) { 65 bool ContainerHasKey(const Container& c, const Key& k) {
50 return std::find(c.cbegin(), c.cend(), k) != c.cend(); 66 return std::find(c.cbegin(), c.cend(), k) != c.cend();
51 } 67 }
52 68
69 // TODO(eladalon): Remove this in the next CL.
53 template <typename Container> 70 template <typename Container>
54 bool MultimapHasValue(const Container& c, 71 bool MultimapHasValue(const Container& c,
55 const typename Container::mapped_type& v) { 72 const typename Container::mapped_type& v) {
56 auto predicate = [v](const typename Container::value_type& it) { 73 auto predicate = [v](const typename Container::value_type& it) {
57 return it.second == v; 74 return it.second == v;
58 }; 75 };
59 return std::any_of(c.cbegin(), c.cend(), predicate); 76 return std::any_of(c.cbegin(), c.cend(), predicate);
60 } 77 }
61 78
79 template <typename Map>
80 bool MapHasValue(const Map& map, const typename Map::mapped_type& value) {
81 auto predicate = [value](const typename Map::value_type& it) {
82 return it.second == value;
83 };
84 return std::any_of(map.cbegin(), map.cend(), predicate);
85 }
86
62 rtc::Optional<uint32_t> ParseRtcpPacketSenderSsrc( 87 rtc::Optional<uint32_t> ParseRtcpPacketSenderSsrc(
63 rtc::ArrayView<const uint8_t> packet); 88 rtc::ArrayView<const uint8_t> packet);
64 89
65 } // namespace webrtc 90 } // namespace webrtc
66 91
67 #endif // WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_ 92 #endif // WEBRTC_CALL_RTP_RTCP_DEMUXER_HELPER_H_
OLDNEW
« no previous file with comments | « webrtc/call/rtp_demuxer_unittest.cc ('k') | webrtc/call/rtp_stream_receiver_controller.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698