diff --git a/call/bitrate_estimator_tests.cc b/call/bitrate_estimator_tests.cc index f17a037ed2..f44cdfd509 100644 --- a/call/bitrate_estimator_tests.cc +++ b/call/bitrate_estimator_tests.cc @@ -186,7 +186,6 @@ class BitrateEstimatorTest : public test::CallTest { test::VideoTestConstants::kDefaultFramerate, *test->task_queue_factory_); frame_generator_capturer_->Init(); - frame_generator_capturer_->Start(); send_stream_->SetSource(frame_generator_capturer_.get(), DegradationPreference::MAINTAIN_FRAMERATE); send_stream_->Start(); diff --git a/pc/peer_connection_field_trial_tests.cc b/pc/peer_connection_field_trial_tests.cc index 7799c9d6e3..c3b3a2db7f 100644 --- a/pc/peer_connection_field_trial_tests.cc +++ b/pc/peer_connection_field_trial_tests.cc @@ -237,7 +237,6 @@ TEST_F(PeerConnectionFieldTrialTest, ApplyFakeNetworkConfig) { auto video_track_source = rtc::make_ref_counted( config, clock_, /*is_screencast=*/false); - video_track_source->Start(); caller->AddTrack(pc_factory_->CreateVideoTrack(video_track_source, "v")); WrapperPtr callee = CreatePeerConnection(); diff --git a/pc/test/frame_generator_capturer_video_track_source.h b/pc/test/frame_generator_capturer_video_track_source.h index 79a5b3474a..50a3d26c2e 100644 --- a/pc/test/frame_generator_capturer_video_track_source.h +++ b/pc/test/frame_generator_capturer_video_track_source.h @@ -64,15 +64,9 @@ class FrameGeneratorCapturerVideoTrackSource : public VideoTrackSource { ~FrameGeneratorCapturerVideoTrackSource() = default; - void Start() { - SetState(kLive); - video_capturer_->Start(); - } + void Start() { SetState(kLive); } - void Stop() { - SetState(kMuted); - video_capturer_->Stop(); - } + void Stop() { SetState(kMuted); } bool is_screencast() const override { return is_screencast_; } diff --git a/test/BUILD.gn b/test/BUILD.gn index 5187205a0a..3a0a35926f 100644 --- a/test/BUILD.gn +++ b/test/BUILD.gn @@ -1260,7 +1260,6 @@ if (!build_with_chromium) { ":run_loop", ":scoped_key_value_config", ":test_support", - ":test_video_capturer", ":video_test_common", ":video_test_constants", "../api:array_view", diff --git a/test/call_test.cc b/test/call_test.cc index b8a1cd76b8..7a1bbd2969 100644 --- a/test/call_test.cc +++ b/test/call_test.cc @@ -634,14 +634,7 @@ void CallTest::Start() { audio_recv_stream->Start(); } -void CallTest::StartVideoSources() { - for (size_t i = 0; i < video_sources_.size(); ++i) { - video_sources_[i]->Start(); - } -} - void CallTest::StartVideoStreams() { - StartVideoSources(); for (size_t i = 0; i < video_send_streams_.size(); ++i) { std::vector active_rtp_streams( video_send_configs_[i].rtp.ssrcs.size(), true); diff --git a/test/call_test.h b/test/call_test.h index 08d0e49a68..41db9cefd1 100644 --- a/test/call_test.h +++ b/test/call_test.h @@ -36,7 +36,6 @@ #include "test/rtp_rtcp_observer.h" #include "test/run_loop.h" #include "test/scoped_key_value_config.h" -#include "test/test_video_capturer.h" #include "test/video_test_constants.h" namespace webrtc { @@ -163,7 +162,6 @@ class CallTest : public ::testing::Test, public RtpPacketSinkInterface { void ConnectVideoSourcesToStreams(); void Start(); - void StartVideoSources(); void StartVideoStreams(); void Stop(); void StopVideoStreams(); @@ -212,7 +210,8 @@ class CallTest : public ::testing::Test, public RtpPacketSinkInterface { std::vector flexfec_receive_streams_; test::FrameGeneratorCapturer* frame_generator_capturer_; - std::vector> video_sources_; + std::vector>> + video_sources_; DegradationPreference degradation_preference_ = DegradationPreference::MAINTAIN_FRAMERATE; diff --git a/test/frame_generator_capturer.cc b/test/frame_generator_capturer.cc index e5d4231b23..6ba0807a74 100644 --- a/test/frame_generator_capturer.cc +++ b/test/frame_generator_capturer.cc @@ -43,7 +43,7 @@ FrameGeneratorCapturer::FrameGeneratorCapturer( int target_fps, TaskQueueFactory& task_queue_factory) : clock_(clock), - sending_(false), + sending_(true), sink_wants_observer_(nullptr), frame_generator_(std::move(frame_generator)), source_fps_(target_fps), diff --git a/test/pc/e2e/peer_connection_quality_test_test.cc b/test/pc/e2e/peer_connection_quality_test_test.cc index 7f0129d525..066fe7d8ee 100644 --- a/test/pc/e2e/peer_connection_quality_test_test.cc +++ b/test/pc/e2e/peer_connection_quality_test_test.cc @@ -129,7 +129,7 @@ TEST_F(PeerConnectionE2EQualityTestTest, OutputVideoIsDumpedWhenRequested) { auto frame_reader = test::CreateY4mFrameReader( test::JoinFilename(test_directory_, "alice_video_bob_320x180_15.y4m")); - EXPECT_THAT(frame_reader->num_frames(), Eq(30)); // 2 seconds 15 fps + EXPECT_THAT(frame_reader->num_frames(), Eq(31)); // 2 seconds 15 fps + 1 ExpectOutputFilesCount(1); } diff --git a/test/peer_scenario/peer_scenario_client.cc b/test/peer_scenario/peer_scenario_client.cc index 697bf055a7..3419b9e069 100644 --- a/test/peer_scenario/peer_scenario_client.cc +++ b/test/peer_scenario/peer_scenario_client.cc @@ -338,7 +338,6 @@ PeerScenarioClient::VideoSendTrack PeerScenarioClient::CreateVideo( capturer->Init(); res.source = rtc::make_ref_counted( std::move(capturer), config.screencast); - res.source->Start(); auto track = pc_factory_->CreateVideoTrack(res.source, track_id); res.track = track.get(); res.sender = diff --git a/test/scenario/video_stream.cc b/test/scenario/video_stream.cc index e082aa37c6..ec139763c8 100644 --- a/test/scenario/video_stream.cc +++ b/test/scenario/video_stream.cc @@ -419,7 +419,6 @@ SendVideoStream::SendVideoStream(CallClient* sender, send_config.suspend_below_min_bitrate = config.encoder.suspend_below_min_bitrate; - video_capturer_->Start(); sender_->SendTask([&] { if (config.stream.fec_controller_factory) { send_stream_ = sender_->call_->CreateVideoSendStream( diff --git a/video/end_to_end_tests/multi_codec_receive_tests.cc b/video/end_to_end_tests/multi_codec_receive_tests.cc index 2d8bf0586d..377209b8a5 100644 --- a/video/end_to_end_tests/multi_codec_receive_tests.cc +++ b/video/end_to_end_tests/multi_codec_receive_tests.cc @@ -254,7 +254,6 @@ void MultiCodecReceiveTest::RunTestWithCodecs( GetVideoSendStream()->Start(); CreateFrameGeneratorCapturer(kFps, kWidth / 2, kHeight / 2); ConnectVideoSourcesToStreams(); - StartVideoSources(); }); EXPECT_TRUE(observer_.Wait()) << "Timed out waiting for frames."; } diff --git a/video/end_to_end_tests/rtp_rtcp_tests.cc b/video/end_to_end_tests/rtp_rtcp_tests.cc index fbd8585907..009a3878fb 100644 --- a/video/end_to_end_tests/rtp_rtcp_tests.cc +++ b/video/end_to_end_tests/rtp_rtcp_tests.cc @@ -339,7 +339,6 @@ void RtpRtcpEndToEndTest::TestRtpStatePreservation( ->SendRtcp(packet.data(), packet.size()); } CreateFrameGeneratorCapturer(30, 1280, 720); - StartVideoSources(); }); observer.ResetExpectedSsrcs(1);