OLD | NEW |
---|---|
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 |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
64 void ResolveAssociations(const RtpPacketReceived& packet); | 64 void ResolveAssociations(const RtpPacketReceived& packet); |
65 | 65 |
66 // Find the associations of RSID to SSRCs. | 66 // Find the associations of RSID to SSRCs. |
67 void ResolveRsidToSsrcAssociations(const RtpPacketReceived& packet); | 67 void ResolveRsidToSsrcAssociations(const RtpPacketReceived& packet); |
68 | 68 |
69 // Notify observers of the resolution of an RSID to an SSRC. | 69 // Notify observers of the resolution of an RSID to an SSRC. |
70 void NotifyObserversOfRsidResolution(const std::string& rsid, uint32_t ssrc); | 70 void NotifyObserversOfRsidResolution(const std::string& rsid, uint32_t ssrc); |
71 | 71 |
72 // This records the association SSRCs to sinks. Other associations, such | 72 // This records the association SSRCs to sinks. Other associations, such |
73 // as by RSID, also end up here once the RSID, etc., is resolved to an SSRC. | 73 // as by RSID, also end up here once the RSID, etc., is resolved to an SSRC. |
74 std::multimap<uint32_t, RtpPacketSinkInterface*> sinks_; | 74 std::multimap<uint32_t, RtpPacketSinkInterface*> ssrc_sinks_; |
danilchap
2017/06/28 14:05:39
while just 'sinks' is not properly differentiated
| |
75 | 75 |
76 // A sink may be associated with an RSID - RTP Stream ID. This tag has a | 76 // A sink may be associated with an RSID - RTP Stream ID. This tag has a |
77 // one-to-one association with an SSRC, but that SSRC is not yet known. | 77 // one-to-one association with an SSRC, but that SSRC is not yet known. |
78 // When it becomes known, the association of the sink to the RSID is deleted | 78 // When it becomes known, the association of the sink to the RSID is deleted |
79 // from this container, and moved into |sinks_|. | 79 // from this container, and moved into |ssrc_sinks_|. |
80 std::multimap<std::string, RtpPacketSinkInterface*> rsid_sinks_; | 80 std::multimap<std::string, RtpPacketSinkInterface*> rsid_sinks_; |
81 | 81 |
82 // Iterating over |rsid_sinks_| for each incoming and performing multiple | 82 // Iterating over |rsid_sinks_| for each incoming and performing multiple |
83 // string comparisons is of non-trivial cost. To avoid this cost, we only | 83 // string comparisons is of non-trivial cost. To avoid this cost, we only |
84 // check RSIDs for the first packet on each incoming SSRC stream. | 84 // check RSIDs for the first packet on each incoming SSRC stream. |
85 // (If RSID associations are added later, we check again.) | 85 // (If RSID associations are added later, we check again.) |
86 std::set<uint32_t> processed_ssrcs_; | 86 std::set<uint32_t> processed_ssrcs_; |
87 | 87 |
88 // Avoid an attack that would create excessive logging. | 88 // Avoid an attack that would create excessive logging. |
89 bool logged_max_processed_ssrcs_exceeded_ = false; | 89 bool logged_max_processed_ssrcs_exceeded_ = false; |
90 | 90 |
91 // Observers which will be notified when an RSID association to an SSRC is | 91 // Observers which will be notified when an RSID association to an SSRC is |
92 // resolved by this object. | 92 // resolved by this object. |
93 std::vector<RsidResolutionObserver*> rsid_resolution_observers_; | 93 std::vector<RsidResolutionObserver*> rsid_resolution_observers_; |
94 }; | 94 }; |
95 | 95 |
96 } // namespace webrtc | 96 } // namespace webrtc |
97 | 97 |
98 #endif // WEBRTC_CALL_RTP_DEMUXER_H_ | 98 #endif // WEBRTC_CALL_RTP_DEMUXER_H_ |
OLD | NEW |