diff --git a/test/fuzzers/utils/BUILD.gn b/test/fuzzers/utils/BUILD.gn index dfb617857c..895e76e939 100644 --- a/test/fuzzers/utils/BUILD.gn +++ b/test/fuzzers/utils/BUILD.gn @@ -15,10 +15,8 @@ rtc_library("rtp_replayer") { "rtp_replayer.h", ] deps = [ - "../../../api/rtc_event_log", - "../../../api/task_queue:default_task_queue_factory", + "../../../api/environment:environment_factory", "../../../api/test/video:function_video_factory", - "../../../api/transport:field_trial_based_config", "../../../api/units:timestamp", "../../../api/video_codecs:video_codecs_api", "../../../call", diff --git a/test/fuzzers/utils/rtp_replayer.cc b/test/fuzzers/utils/rtp_replayer.cc index f6d7119338..1b1b96803f 100644 --- a/test/fuzzers/utils/rtp_replayer.cc +++ b/test/fuzzers/utils/rtp_replayer.cc @@ -16,8 +16,7 @@ #include #include "absl/memory/memory.h" -#include "api/task_queue/default_task_queue_factory.h" -#include "api/transport/field_trial_based_config.h" +#include "api/environment/environment_factory.h" #include "api/units/timestamp.h" #include "modules/rtp_rtcp/source/rtp_packet.h" #include "modules/rtp_rtcp/source/rtp_packet_received.h" @@ -73,13 +72,7 @@ void RtpReplayer::Replay( } // Setup the video streams based on the configuration. - webrtc::RtcEventLogNull event_log; - std::unique_ptr task_queue_factory = - CreateDefaultTaskQueueFactory(); - CallConfig call_config(&event_log); - call_config.task_queue_factory = task_queue_factory.get(); - FieldTrialBasedConfig field_trials; - call_config.trials = &field_trials; + CallConfig call_config(CreateEnvironment()); std::unique_ptr call(Call::Create(call_config)); SetupVideoStreams(&receive_stream_configs, stream_state.get(), call.get()); diff --git a/test/fuzzers/utils/rtp_replayer.h b/test/fuzzers/utils/rtp_replayer.h index ae94a640a5..73220eecfa 100644 --- a/test/fuzzers/utils/rtp_replayer.h +++ b/test/fuzzers/utils/rtp_replayer.h @@ -18,7 +18,6 @@ #include #include -#include "api/rtc_event_log/rtc_event_log.h" #include "api/test/video/function_video_decoder_factory.h" #include "api/video_codecs/video_decoder.h" #include "call/call.h" diff --git a/video/BUILD.gn b/video/BUILD.gn index 1722ad4f6e..204c6b66f4 100644 --- a/video/BUILD.gn +++ b/video/BUILD.gn @@ -836,6 +836,8 @@ if (rtc_include_tests) { "../api:transport_api", "../api/adaptation:resource_adaptation_api", "../api/crypto:options", + "../api/environment", + "../api/environment:environment_factory", "../api/metronome/test:fake_metronome", "../api/rtc_event_log", "../api/task_queue", @@ -843,7 +845,6 @@ if (rtc_include_tests) { "../api/test/metrics:global_metrics_logger_and_exporter", "../api/test/metrics:metric", "../api/test/video:function_video_factory", - "../api/transport:field_trial_based_config", "../api/units:data_rate", "../api/units:frequency", "../api/units:time_delta", diff --git a/video/end_to_end_tests/multi_stream_tester.cc b/video/end_to_end_tests/multi_stream_tester.cc index 1eb388cc76..759b75ccf9 100644 --- a/video/end_to_end_tests/multi_stream_tester.cc +++ b/video/end_to_end_tests/multi_stream_tester.cc @@ -14,8 +14,8 @@ #include #include -#include "api/rtc_event_log/rtc_event_log.h" -#include "api/task_queue/default_task_queue_factory.h" +#include "api/environment/environment.h" +#include "api/environment/environment_factory.h" #include "api/task_queue/task_queue_base.h" #include "api/test/create_frame_generator.h" #include "api/test/simulated_network.h" @@ -42,17 +42,13 @@ MultiStreamTester::MultiStreamTester() { MultiStreamTester::~MultiStreamTester() = default; void MultiStreamTester::RunTest() { - webrtc::RtcEventLogNull event_log; - auto task_queue_factory = CreateDefaultTaskQueueFactory(); + Environment env = CreateEnvironment(); // Use high prioirity since this task_queue used for fake network delivering // at correct time. Those test tasks should be prefered over code under test // to make test more stable. - auto task_queue = task_queue_factory->CreateTaskQueue( + auto task_queue = env.task_queue_factory().CreateTaskQueue( "TaskQueue", TaskQueueFactory::Priority::HIGH); - CallConfig config(&event_log); - test::ScopedKeyValueConfig field_trials; - config.trials = &field_trials; - config.task_queue_factory = task_queue_factory.get(); + CallConfig config(env); std::unique_ptr sender_call; std::unique_ptr receiver_call; std::unique_ptr sender_transport; @@ -115,10 +111,10 @@ void MultiStreamTester::RunTest() { receive_streams[i]->Start(); auto* frame_generator = new test::FrameGeneratorCapturer( - Clock::GetRealTimeClock(), + &env.clock(), test::CreateSquareFrameGenerator(width, height, absl::nullopt, absl::nullopt), - 30, *task_queue_factory); + 30, env.task_queue_factory()); frame_generators[i] = frame_generator; send_streams[i]->SetSource(frame_generator, DegradationPreference::MAINTAIN_FRAMERATE);