diff options
Diffstat (limited to 'pc/test/fake_peer_connection_for_stats.h')
| -rw-r--r-- | pc/test/fake_peer_connection_for_stats.h | 27 |
1 files changed, 19 insertions, 8 deletions
diff --git a/pc/test/fake_peer_connection_for_stats.h b/pc/test/fake_peer_connection_for_stats.h index 3f3e0a9ee0..4cdbd82162 100644 --- a/pc/test/fake_peer_connection_for_stats.h +++ b/pc/test/fake_peer_connection_for_stats.h @@ -28,8 +28,10 @@ namespace webrtc { // Fake VoiceMediaChannel where the result of GetStats can be configured. class FakeVoiceMediaChannelForStats : public cricket::FakeVoiceMediaChannel { public: - FakeVoiceMediaChannelForStats() - : cricket::FakeVoiceMediaChannel(nullptr, cricket::AudioOptions()) {} + explicit FakeVoiceMediaChannelForStats(TaskQueueBase* network_thread) + : cricket::FakeVoiceMediaChannel(nullptr, + cricket::AudioOptions(), + network_thread) {} void SetStats(const cricket::VoiceMediaInfo& voice_info) { stats_ = voice_info; @@ -52,8 +54,10 @@ class FakeVoiceMediaChannelForStats : public cricket::FakeVoiceMediaChannel { // Fake VideoMediaChannel where the result of GetStats can be configured. class FakeVideoMediaChannelForStats : public cricket::FakeVideoMediaChannel { public: - FakeVideoMediaChannelForStats() - : cricket::FakeVideoMediaChannel(nullptr, cricket::VideoOptions()) {} + explicit FakeVideoMediaChannelForStats(TaskQueueBase* network_thread) + : cricket::FakeVideoMediaChannel(nullptr, + cricket::VideoOptions(), + network_thread) {} void SetStats(const cricket::VideoMediaInfo& video_info) { stats_ = video_info; @@ -178,7 +182,7 @@ class FakePeerConnectionForStats : public FakePeerConnectionBase { // TODO(steveanton): Switch tests to use RtpTransceivers directly. auto receiver_proxy = RtpReceiverProxyWithInternal<RtpReceiverInternal>::Create( - signaling_thread_, receiver); + signaling_thread_, worker_thread_, receiver); GetOrCreateFirstTransceiverOfType(receiver->media_type()) ->internal() ->AddReceiver(receiver_proxy); @@ -196,7 +200,7 @@ class FakePeerConnectionForStats : public FakePeerConnectionBase { const std::string& transport_name) { RTC_DCHECK(!voice_channel_); auto voice_media_channel = - std::make_unique<FakeVoiceMediaChannelForStats>(); + std::make_unique<FakeVoiceMediaChannelForStats>(network_thread_); auto* voice_media_channel_ptr = voice_media_channel.get(); voice_channel_ = std::make_unique<VoiceChannelForTesting>( worker_thread_, network_thread_, signaling_thread_, @@ -213,7 +217,7 @@ class FakePeerConnectionForStats : public FakePeerConnectionBase { const std::string& transport_name) { RTC_DCHECK(!video_channel_); auto video_media_channel = - std::make_unique<FakeVideoMediaChannelForStats>(); + std::make_unique<FakeVideoMediaChannelForStats>(network_thread_); auto video_media_channel_ptr = video_media_channel.get(); video_channel_ = std::make_unique<VideoChannelForTesting>( worker_thread_, network_thread_, signaling_thread_, @@ -388,7 +392,8 @@ class FakePeerConnectionForStats : public FakePeerConnectionBase { } } auto transceiver = RtpTransceiverProxyWithInternal<RtpTransceiver>::Create( - signaling_thread_, new RtpTransceiver(media_type)); + signaling_thread_, + new RtpTransceiver(media_type, channel_manager_.get())); transceivers_.push_back(transceiver); return transceiver; } @@ -397,6 +402,12 @@ class FakePeerConnectionForStats : public FakePeerConnectionBase { rtc::Thread* const worker_thread_; rtc::Thread* const signaling_thread_; + std::unique_ptr<cricket::ChannelManager> channel_manager_ = + cricket::ChannelManager::Create(nullptr /* MediaEngineInterface */, + true, + worker_thread_, + network_thread_); + rtc::scoped_refptr<StreamCollection> local_streams_; rtc::scoped_refptr<StreamCollection> remote_streams_; |