| 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 |