OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 // Simulate end to end streaming. | 5 // Simulate end to end streaming. |
6 // | 6 // |
7 // Input: | 7 // Input: |
8 // --source= | 8 // --source= |
9 // WebM used as the source of video and audio frames. | 9 // WebM used as the source of video and audio frames. |
10 // --output= | 10 // --output= |
(...skipping 372 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
383 video_receiver_config.rtp_max_delay_ms = | 383 video_receiver_config.rtp_max_delay_ms = |
384 video_sender_config.max_playout_delay.InMilliseconds(); | 384 video_sender_config.max_playout_delay.InMilliseconds(); |
385 | 385 |
386 // Loopback transport. Owned by CastTransport. | 386 // Loopback transport. Owned by CastTransport. |
387 LoopBackTransport* receiver_to_sender = new LoopBackTransport(receiver_env); | 387 LoopBackTransport* receiver_to_sender = new LoopBackTransport(receiver_env); |
388 LoopBackTransport* sender_to_receiver = new LoopBackTransport(sender_env); | 388 LoopBackTransport* sender_to_receiver = new LoopBackTransport(sender_env); |
389 | 389 |
390 PacketProxy packet_proxy; | 390 PacketProxy packet_proxy; |
391 | 391 |
392 // Cast receiver. | 392 // Cast receiver. |
393 std::unique_ptr<CastTransport> transport_receiver( | 393 std::unique_ptr<CastTransport> transport_receiver(new CastTransportImpl( |
394 new CastTransportImpl(&testing_clock, base::TimeDelta::FromSeconds(1), | 394 &testing_clock, base::TimeDelta::FromSeconds(1), |
395 base::WrapUnique(new TransportClient( | 395 base::MakeUnique<TransportClient>(receiver_env->logger(), &packet_proxy), |
396 receiver_env->logger(), &packet_proxy)), | 396 base::WrapUnique(receiver_to_sender), task_runner)); |
397 base::WrapUnique(receiver_to_sender), task_runner)); | |
398 std::unique_ptr<CastReceiver> cast_receiver( | 397 std::unique_ptr<CastReceiver> cast_receiver( |
399 CastReceiver::Create(receiver_env, audio_receiver_config, | 398 CastReceiver::Create(receiver_env, audio_receiver_config, |
400 video_receiver_config, transport_receiver.get())); | 399 video_receiver_config, transport_receiver.get())); |
401 | 400 |
402 packet_proxy.receiver = cast_receiver.get(); | 401 packet_proxy.receiver = cast_receiver.get(); |
403 | 402 |
404 // Cast sender and transport sender. | 403 // Cast sender and transport sender. |
405 std::unique_ptr<CastTransport> transport_sender(new CastTransportImpl( | 404 std::unique_ptr<CastTransport> transport_sender(new CastTransportImpl( |
406 &testing_clock, base::TimeDelta::FromSeconds(1), | 405 &testing_clock, base::TimeDelta::FromSeconds(1), |
407 base::WrapUnique(new TransportClient(sender_env->logger(), nullptr)), | 406 base::MakeUnique<TransportClient>(sender_env->logger(), nullptr), |
408 base::WrapUnique(sender_to_receiver), task_runner)); | 407 base::WrapUnique(sender_to_receiver), task_runner)); |
409 std::unique_ptr<CastSender> cast_sender( | 408 std::unique_ptr<CastSender> cast_sender( |
410 CastSender::Create(sender_env, transport_sender.get())); | 409 CastSender::Create(sender_env, transport_sender.get())); |
411 | 410 |
412 // Initialize network simulation model. | 411 // Initialize network simulation model. |
413 const bool use_network_simulation = | 412 const bool use_network_simulation = |
414 model.type() == media::cast::proto::INTERRUPTED_POISSON_PROCESS; | 413 model.type() == media::cast::proto::INTERRUPTED_POISSON_PROCESS; |
415 std::unique_ptr<test::InterruptedPoissonProcess> ipp; | 414 std::unique_ptr<test::InterruptedPoissonProcess> ipp; |
416 if (use_network_simulation) { | 415 if (use_network_simulation) { |
417 LOG(INFO) << "Running Poisson based network simulation."; | 416 LOG(INFO) << "Running Poisson based network simulation."; |
(...skipping 316 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
734 values.SetString("sim-id", sim_id); | 733 values.SetString("sim-id", sim_id); |
735 | 734 |
736 std::string extra_data; | 735 std::string extra_data; |
737 base::JSONWriter::Write(values, &extra_data); | 736 base::JSONWriter::Write(values, &extra_data); |
738 | 737 |
739 // Run. | 738 // Run. |
740 media::cast::RunSimulation(source_path, log_output_path, metrics_output_path, | 739 media::cast::RunSimulation(source_path, log_output_path, metrics_output_path, |
741 yuv_output_path, extra_data, model); | 740 yuv_output_path, extra_data, model); |
742 return 0; | 741 return 0; |
743 } | 742 } |
OLD | NEW |