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

Side by Side Diff: webrtc/video_engine/vie_channel.cc

Issue 1335353005: Remove channel ids from various interfaces. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: LoopBackTransport SSRC demuxing. Created 5 years, 3 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/video_engine/vie_channel.h ('k') | webrtc/video_engine/vie_channel_group.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) 2012 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2012 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 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
70 uint32_t* sent_nack_rate_bps, 70 uint32_t* sent_nack_rate_bps,
71 uint32_t* sent_fec_rate_bps) override { 71 uint32_t* sent_fec_rate_bps) override {
72 return owner_->ProtectionRequest(delta_fec_params, key_fec_params, 72 return owner_->ProtectionRequest(delta_fec_params, key_fec_params,
73 sent_video_rate_bps, sent_nack_rate_bps, 73 sent_video_rate_bps, sent_nack_rate_bps,
74 sent_fec_rate_bps); 74 sent_fec_rate_bps);
75 } 75 }
76 private: 76 private:
77 ViEChannel* owner_; 77 ViEChannel* owner_;
78 }; 78 };
79 79
80 ViEChannel::ViEChannel(int32_t channel_id, 80 ViEChannel::ViEChannel(uint32_t number_of_cores,
81 int32_t engine_id,
82 uint32_t number_of_cores,
83 Transport* transport, 81 Transport* transport,
84 ProcessThread* module_process_thread, 82 ProcessThread* module_process_thread,
85 RtcpIntraFrameObserver* intra_frame_observer, 83 RtcpIntraFrameObserver* intra_frame_observer,
86 RtcpBandwidthObserver* bandwidth_observer, 84 RtcpBandwidthObserver* bandwidth_observer,
87 TransportFeedbackObserver* transport_feedback_observer, 85 TransportFeedbackObserver* transport_feedback_observer,
88 RemoteBitrateEstimator* remote_bitrate_estimator, 86 RemoteBitrateEstimator* remote_bitrate_estimator,
89 RtcpRttStats* rtt_stats, 87 RtcpRttStats* rtt_stats,
90 PacedSender* paced_sender, 88 PacedSender* paced_sender,
91 PacketRouter* packet_router, 89 PacketRouter* packet_router,
92 size_t max_rtp_streams, 90 size_t max_rtp_streams,
93 bool sender) 91 bool sender)
94 : channel_id_(channel_id), 92 : number_of_cores_(number_of_cores),
95 engine_id_(engine_id),
96 number_of_cores_(number_of_cores),
97 sender_(sender), 93 sender_(sender),
98 module_process_thread_(module_process_thread), 94 module_process_thread_(module_process_thread),
99 crit_(CriticalSectionWrapper::CreateCriticalSection()), 95 crit_(CriticalSectionWrapper::CreateCriticalSection()),
100 send_payload_router_(new PayloadRouter()), 96 send_payload_router_(new PayloadRouter()),
101 vcm_protection_callback_(new ViEChannelProtectionCallback(this)), 97 vcm_protection_callback_(new ViEChannelProtectionCallback(this)),
102 vcm_(VideoCodingModule::Create(Clock::GetRealTimeClock(), 98 vcm_(VideoCodingModule::Create(Clock::GetRealTimeClock(),
103 nullptr, 99 nullptr,
104 nullptr)), 100 nullptr)),
105 vie_receiver_(channel_id, vcm_, remote_bitrate_estimator, this), 101 vie_receiver_(vcm_, remote_bitrate_estimator, this),
106 vie_sync_(vcm_), 102 vie_sync_(vcm_),
107 stats_observer_(new ChannelStatsObserver(this)), 103 stats_observer_(new ChannelStatsObserver(this)),
108 receive_stats_callback_(nullptr), 104 receive_stats_callback_(nullptr),
109 incoming_video_stream_(nullptr), 105 incoming_video_stream_(nullptr),
110 intra_frame_observer_(intra_frame_observer), 106 intra_frame_observer_(intra_frame_observer),
111 rtt_stats_(rtt_stats), 107 rtt_stats_(rtt_stats),
112 paced_sender_(paced_sender), 108 paced_sender_(paced_sender),
113 packet_router_(packet_router), 109 packet_router_(packet_router),
114 bandwidth_observer_(bandwidth_observer), 110 bandwidth_observer_(bandwidth_observer),
115 transport_feedback_observer_(transport_feedback_observer), 111 transport_feedback_observer_(transport_feedback_observer),
116 nack_history_size_sender_(kSendSidePacketHistorySize), 112 nack_history_size_sender_(kSendSidePacketHistorySize),
117 max_nack_reordering_threshold_(kMaxPacketAgeToNack), 113 max_nack_reordering_threshold_(kMaxPacketAgeToNack),
118 pre_render_callback_(NULL), 114 pre_render_callback_(NULL),
119 report_block_stats_sender_(new ReportBlockStats()), 115 report_block_stats_sender_(new ReportBlockStats()),
120 time_of_first_rtt_ms_(-1), 116 time_of_first_rtt_ms_(-1),
121 rtt_sum_ms_(0), 117 rtt_sum_ms_(0),
122 num_rtts_(0), 118 num_rtts_(0),
123 rtp_rtcp_modules_( 119 rtp_rtcp_modules_(
124 CreateRtpRtcpModules(ViEModuleId(engine_id_, channel_id_), 120 CreateRtpRtcpModules(!sender,
125 !sender,
126 vie_receiver_.GetReceiveStatistics(), 121 vie_receiver_.GetReceiveStatistics(),
127 transport, 122 transport,
128 sender ? intra_frame_observer_ : nullptr, 123 sender ? intra_frame_observer_ : nullptr,
129 sender ? bandwidth_observer_.get() : nullptr, 124 sender ? bandwidth_observer_.get() : nullptr,
130 transport_feedback_observer_, 125 transport_feedback_observer_,
131 rtt_stats_, 126 rtt_stats_,
132 &rtcp_packet_type_counter_observer_, 127 &rtcp_packet_type_counter_observer_,
133 remote_bitrate_estimator, 128 remote_bitrate_estimator,
134 paced_sender_, 129 paced_sender_,
135 packet_router_, 130 packet_router_,
(...skipping 880 matching lines...) Expand 10 before | Expand all | Expand 10 after
1016 return stats_observer_.get(); 1011 return stats_observer_.get();
1017 } 1012 }
1018 1013
1019 // Do not acquire the lock of |vcm_| in this function. Decode callback won't 1014 // Do not acquire the lock of |vcm_| in this function. Decode callback won't
1020 // necessarily be called from the decoding thread. The decoding thread may have 1015 // necessarily be called from the decoding thread. The decoding thread may have
1021 // held the lock when calling VideoDecoder::Decode, Reset, or Release. Acquiring 1016 // held the lock when calling VideoDecoder::Decode, Reset, or Release. Acquiring
1022 // the same lock in the path of decode callback can deadlock. 1017 // the same lock in the path of decode callback can deadlock.
1023 int32_t ViEChannel::FrameToRender(VideoFrame& video_frame) { // NOLINT 1018 int32_t ViEChannel::FrameToRender(VideoFrame& video_frame) { // NOLINT
1024 CriticalSectionScoped cs(crit_.get()); 1019 CriticalSectionScoped cs(crit_.get());
1025 1020
1026
1027 if (pre_render_callback_ != NULL) 1021 if (pre_render_callback_ != NULL)
1028 pre_render_callback_->FrameCallback(&video_frame); 1022 pre_render_callback_->FrameCallback(&video_frame);
1029 1023
1030 incoming_video_stream_->RenderFrame(channel_id_, video_frame); 1024 // TODO(pbos): Remove stream id argument.
1025 incoming_video_stream_->RenderFrame(0, video_frame);
mflodman 2015/09/17 05:36:54 Why did you leave this one? Given the CL descripti
1031 return 0; 1026 return 0;
1032 } 1027 }
1033 1028
1034 int32_t ViEChannel::ReceivedDecodedReferenceFrame( 1029 int32_t ViEChannel::ReceivedDecodedReferenceFrame(
1035 const uint64_t picture_id) { 1030 const uint64_t picture_id) {
1036 return rtp_rtcp_modules_[0]->SendRTCPReferencePictureSelection(picture_id); 1031 return rtp_rtcp_modules_[0]->SendRTCPReferencePictureSelection(picture_id);
1037 } 1032 }
1038 1033
1039 void ViEChannel::OnIncomingPayloadType(int payload_type) { 1034 void ViEChannel::OnIncomingPayloadType(int payload_type) {
1040 CriticalSectionScoped cs(crit_.get()); 1035 CriticalSectionScoped cs(crit_.get());
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after
1127 rtp_rtcp->BitrateSent(&not_used, &module_video_rate, &module_fec_rate, 1122 rtp_rtcp->BitrateSent(&not_used, &module_video_rate, &module_fec_rate,
1128 &module_nack_rate); 1123 &module_nack_rate);
1129 *video_rate_bps += module_video_rate; 1124 *video_rate_bps += module_video_rate;
1130 *nack_rate_bps += module_nack_rate; 1125 *nack_rate_bps += module_nack_rate;
1131 *fec_rate_bps += module_fec_rate; 1126 *fec_rate_bps += module_fec_rate;
1132 } 1127 }
1133 return 0; 1128 return 0;
1134 } 1129 }
1135 1130
1136 std::vector<RtpRtcp*> ViEChannel::CreateRtpRtcpModules( 1131 std::vector<RtpRtcp*> ViEChannel::CreateRtpRtcpModules(
1137 int32_t id,
1138 bool receiver_only, 1132 bool receiver_only,
1139 ReceiveStatistics* receive_statistics, 1133 ReceiveStatistics* receive_statistics,
1140 Transport* outgoing_transport, 1134 Transport* outgoing_transport,
1141 RtcpIntraFrameObserver* intra_frame_callback, 1135 RtcpIntraFrameObserver* intra_frame_callback,
1142 RtcpBandwidthObserver* bandwidth_callback, 1136 RtcpBandwidthObserver* bandwidth_callback,
1143 TransportFeedbackObserver* transport_feedback_callback, 1137 TransportFeedbackObserver* transport_feedback_callback,
1144 RtcpRttStats* rtt_stats, 1138 RtcpRttStats* rtt_stats,
1145 RtcpPacketTypeCounterObserver* rtcp_packet_type_counter_observer, 1139 RtcpPacketTypeCounterObserver* rtcp_packet_type_counter_observer,
1146 RemoteBitrateEstimator* remote_bitrate_estimator, 1140 RemoteBitrateEstimator* remote_bitrate_estimator,
1147 PacedSender* paced_sender, 1141 PacedSender* paced_sender,
1148 PacketRouter* packet_router, 1142 PacketRouter* packet_router,
1149 BitrateStatisticsObserver* send_bitrate_observer, 1143 BitrateStatisticsObserver* send_bitrate_observer,
1150 FrameCountObserver* send_frame_count_observer, 1144 FrameCountObserver* send_frame_count_observer,
1151 SendSideDelayObserver* send_side_delay_observer, 1145 SendSideDelayObserver* send_side_delay_observer,
1152 size_t num_modules) { 1146 size_t num_modules) {
1153 DCHECK_GT(num_modules, 0u); 1147 DCHECK_GT(num_modules, 0u);
1154 RtpRtcp::Configuration configuration; 1148 RtpRtcp::Configuration configuration;
1155 ReceiveStatistics* null_receive_statistics = configuration.receive_statistics; 1149 ReceiveStatistics* null_receive_statistics = configuration.receive_statistics;
1156 configuration.id = id;
1157 configuration.audio = false; 1150 configuration.audio = false;
1158 configuration.receiver_only = receiver_only; 1151 configuration.receiver_only = receiver_only;
1159 configuration.receive_statistics = receive_statistics; 1152 configuration.receive_statistics = receive_statistics;
1160 configuration.outgoing_transport = outgoing_transport; 1153 configuration.outgoing_transport = outgoing_transport;
1161 configuration.intra_frame_callback = intra_frame_callback; 1154 configuration.intra_frame_callback = intra_frame_callback;
1162 configuration.rtt_stats = rtt_stats; 1155 configuration.rtt_stats = rtt_stats;
1163 configuration.rtcp_packet_type_counter_observer = 1156 configuration.rtcp_packet_type_counter_observer =
1164 rtcp_packet_type_counter_observer; 1157 rtcp_packet_type_counter_observer;
1165 configuration.paced_sender = paced_sender; 1158 configuration.paced_sender = paced_sender;
1166 configuration.packet_router = packet_router; 1159 configuration.packet_router = packet_router;
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after
1224 } 1217 }
1225 1218
1226 void ViEChannel::RegisterPreDecodeImageCallback( 1219 void ViEChannel::RegisterPreDecodeImageCallback(
1227 EncodedImageCallback* pre_decode_callback) { 1220 EncodedImageCallback* pre_decode_callback) {
1228 vcm_->RegisterPreDecodeImageCallback(pre_decode_callback); 1221 vcm_->RegisterPreDecodeImageCallback(pre_decode_callback);
1229 } 1222 }
1230 1223
1231 // TODO(pbos): Remove OnInitializeDecoder which is called from the RTP module, 1224 // TODO(pbos): Remove OnInitializeDecoder which is called from the RTP module,
1232 // any decoder resetting should be handled internally within the VCM. 1225 // any decoder resetting should be handled internally within the VCM.
1233 int32_t ViEChannel::OnInitializeDecoder( 1226 int32_t ViEChannel::OnInitializeDecoder(
1234 const int32_t id,
1235 const int8_t payload_type, 1227 const int8_t payload_type,
1236 const char payload_name[RTP_PAYLOAD_NAME_SIZE], 1228 const char payload_name[RTP_PAYLOAD_NAME_SIZE],
1237 const int frequency, 1229 const int frequency,
1238 const uint8_t channels, 1230 const uint8_t channels,
1239 const uint32_t rate) { 1231 const uint32_t rate) {
1240 LOG(LS_INFO) << "OnInitializeDecoder " << static_cast<int>(payload_type) 1232 LOG(LS_INFO) << "OnInitializeDecoder " << static_cast<int>(payload_type)
1241 << " " << payload_name; 1233 << " " << payload_name;
1242 vcm_->ResetDecoder(); 1234 vcm_->ResetDecoder();
1243 1235
1244 return 0; 1236 return 0;
1245 } 1237 }
1246 1238
1247 void ViEChannel::OnIncomingSSRCChanged(const int32_t id, const uint32_t ssrc) { 1239 void ViEChannel::OnIncomingSSRCChanged(const uint32_t ssrc) {
1248 DCHECK_EQ(channel_id_, ChannelId(id));
1249 rtp_rtcp_modules_[0]->SetRemoteSSRC(ssrc); 1240 rtp_rtcp_modules_[0]->SetRemoteSSRC(ssrc);
1250 } 1241 }
1251 1242
1252 void ViEChannel::OnIncomingCSRCChanged(const int32_t id, 1243 void ViEChannel::OnIncomingCSRCChanged(const uint32_t CSRC, const bool added) {}
1253 const uint32_t CSRC,
1254 const bool added) {
1255 DCHECK_EQ(channel_id_, ChannelId(id));
1256 CriticalSectionScoped cs(crit_.get());
1257 }
1258 1244
1259 void ViEChannel::RegisterSendFrameCountObserver( 1245 void ViEChannel::RegisterSendFrameCountObserver(
1260 FrameCountObserver* observer) { 1246 FrameCountObserver* observer) {
1261 send_frame_count_observer_.Set(observer); 1247 send_frame_count_observer_.Set(observer);
1262 } 1248 }
1263 1249
1264 void ViEChannel::RegisterReceiveStatisticsProxy( 1250 void ViEChannel::RegisterReceiveStatisticsProxy(
1265 ReceiveStatisticsProxy* receive_statistics_proxy) { 1251 ReceiveStatisticsProxy* receive_statistics_proxy) {
1266 CriticalSectionScoped cs(crit_.get()); 1252 CriticalSectionScoped cs(crit_.get());
1267 receive_stats_callback_ = receive_statistics_proxy; 1253 receive_stats_callback_ = receive_statistics_proxy;
1268 } 1254 }
1269 1255
1270 void ViEChannel::SetIncomingVideoStream( 1256 void ViEChannel::SetIncomingVideoStream(
1271 IncomingVideoStream* incoming_video_stream) { 1257 IncomingVideoStream* incoming_video_stream) {
1272 CriticalSectionScoped cs(crit_.get()); 1258 CriticalSectionScoped cs(crit_.get());
1273 incoming_video_stream_ = incoming_video_stream; 1259 incoming_video_stream_ = incoming_video_stream;
1274 } 1260 }
1275 } // namespace webrtc 1261 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/video_engine/vie_channel.h ('k') | webrtc/video_engine/vie_channel_group.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698