| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // This test generate synthetic data. For audio it's a sinusoid waveform with | 5 // This test generate synthetic data. For audio it's a sinusoid waveform with |
| 6 // frequency kSoundFrequency and different amplitudes. For video it's a pattern | 6 // frequency kSoundFrequency and different amplitudes. For video it's a pattern |
| 7 // that is shifting by one pixel per frame, each pixels neighbors right and down | 7 // that is shifting by one pixel per frame, each pixels neighbors right and down |
| 8 // is this pixels value +1, since the pixel value is 8 bit it will wrap | 8 // is this pixels value +1, since the pixel value is 8 bit it will wrap |
| 9 // frequently within the image. Visually this will create diagonally color bands | 9 // frequently within the image. Visually this will create diagonally color bands |
| 10 // that moves across the screen | 10 // that moves across the screen |
| (...skipping 451 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 462 | 462 |
| 463 test_receiver_audio_callback_->SetExpectedSamplingFrequency( | 463 test_receiver_audio_callback_->SetExpectedSamplingFrequency( |
| 464 audio_receiver_config_.rtp_timebase); | 464 audio_receiver_config_.rtp_timebase); |
| 465 | 465 |
| 466 video_sender_config_.sender_ssrc = 3; | 466 video_sender_config_.sender_ssrc = 3; |
| 467 video_sender_config_.receiver_ssrc = 4; | 467 video_sender_config_.receiver_ssrc = 4; |
| 468 video_sender_config_.max_playout_delay = | 468 video_sender_config_.max_playout_delay = |
| 469 base::TimeDelta::FromMilliseconds(kTargetPlayoutDelayMs); | 469 base::TimeDelta::FromMilliseconds(kTargetPlayoutDelayMs); |
| 470 video_sender_config_.rtp_payload_type = RtpPayloadType::VIDEO_VP8; | 470 video_sender_config_.rtp_payload_type = RtpPayloadType::VIDEO_VP8; |
| 471 video_sender_config_.use_external_encoder = false; | 471 video_sender_config_.use_external_encoder = false; |
| 472 video_sender_config_.rtp_timebase = kVideoFrequency; |
| 472 video_sender_config_.max_bitrate = 50000; | 473 video_sender_config_.max_bitrate = 50000; |
| 473 video_sender_config_.min_bitrate = 10000; | 474 video_sender_config_.min_bitrate = 10000; |
| 474 video_sender_config_.start_bitrate = 10000; | 475 video_sender_config_.start_bitrate = 10000; |
| 475 video_sender_config_.video_codec_params.max_qp = 30; | 476 video_sender_config_.video_codec_params.max_qp = 30; |
| 476 video_sender_config_.video_codec_params.min_qp = 4; | 477 video_sender_config_.video_codec_params.min_qp = 4; |
| 477 video_sender_config_.max_frame_rate = 30; | 478 video_sender_config_.max_frame_rate = 30; |
| 478 video_sender_config_.codec = video_codec; | 479 video_sender_config_.codec = video_codec; |
| 479 video_sender_config_.aes_iv_mask = | 480 video_sender_config_.aes_iv_mask = |
| 480 ConvertFromBase16String("1234567890abcdeffedcba0987654321"); | 481 ConvertFromBase16String("1234567890abcdeffedcba0987654321"); |
| 481 video_sender_config_.aes_key = | 482 video_sender_config_.aes_key = |
| (...skipping 405 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 887 | 888 |
| 888 namespace { | 889 namespace { |
| 889 | 890 |
| 890 class TransportClient : public CastTransport::Client { | 891 class TransportClient : public CastTransport::Client { |
| 891 public: | 892 public: |
| 892 TransportClient(LogEventDispatcher* log_event_dispatcher, | 893 TransportClient(LogEventDispatcher* log_event_dispatcher, |
| 893 End2EndTest* e2e_test) | 894 End2EndTest* e2e_test) |
| 894 : log_event_dispatcher_(log_event_dispatcher), e2e_test_(e2e_test) {} | 895 : log_event_dispatcher_(log_event_dispatcher), e2e_test_(e2e_test) {} |
| 895 | 896 |
| 896 void OnStatusChanged(media::cast::CastTransportStatus status) final { | 897 void OnStatusChanged(media::cast::CastTransportStatus status) final { |
| 897 bool result = (status == TRANSPORT_AUDIO_INITIALIZED || | 898 EXPECT_EQ(TRANSPORT_STREAM_INITIALIZED, status); |
| 898 status == TRANSPORT_VIDEO_INITIALIZED); | |
| 899 EXPECT_TRUE(result); | |
| 900 }; | 899 }; |
| 901 void OnLoggingEventsReceived( | 900 void OnLoggingEventsReceived( |
| 902 std::unique_ptr<std::vector<FrameEvent>> frame_events, | 901 std::unique_ptr<std::vector<FrameEvent>> frame_events, |
| 903 std::unique_ptr<std::vector<PacketEvent>> packet_events) final { | 902 std::unique_ptr<std::vector<PacketEvent>> packet_events) final { |
| 904 log_event_dispatcher_->DispatchBatchOfEvents(std::move(frame_events), | 903 log_event_dispatcher_->DispatchBatchOfEvents(std::move(frame_events), |
| 905 std::move(packet_events)); | 904 std::move(packet_events)); |
| 906 }; | 905 }; |
| 907 void ProcessRtpPacket(std::unique_ptr<Packet> packet) final { | 906 void ProcessRtpPacket(std::unique_ptr<Packet> packet) final { |
| 908 if (e2e_test_) | 907 if (e2e_test_) |
| 909 e2e_test_->ReceivePacket(std::move(packet)); | 908 e2e_test_->ReceivePacket(std::move(packet)); |
| 910 }; | 909 }; |
| 911 | 910 |
| 912 private: | 911 private: |
| 913 LogEventDispatcher* const log_event_dispatcher_; // Not owned by this class. | 912 LogEventDispatcher* const log_event_dispatcher_; // Not owned by this class. |
| 914 End2EndTest* const e2e_test_; // Not owned by this class. | 913 End2EndTest* const e2e_test_; // Not owned by this class. |
| 915 | 914 |
| 916 DISALLOW_COPY_AND_ASSIGN(TransportClient); | 915 DISALLOW_COPY_AND_ASSIGN(TransportClient); |
| 917 }; | 916 }; |
| 918 | 917 |
| 919 } // namespace | 918 } // namespace |
| 920 | 919 |
| 921 void End2EndTest::Create() { | 920 void End2EndTest::Create() { |
| 922 transport_sender_.reset(new CastTransportImpl( | 921 transport_sender_.reset(new CastTransportImpl( |
| 923 testing_clock_sender_, base::TimeDelta::FromMilliseconds(1), | 922 testing_clock_sender_, base::TimeDelta::FromMilliseconds(1), |
| 924 base::WrapUnique( | 923 base::MakeUnique<TransportClient>(cast_environment_sender_->logger(), |
| 925 new TransportClient(cast_environment_sender_->logger(), nullptr)), | 924 nullptr), |
| 926 base::WrapUnique(sender_to_receiver_), task_runner_sender_)); | 925 base::WrapUnique(sender_to_receiver_), task_runner_sender_)); |
| 927 | 926 |
| 928 transport_receiver_.reset(new CastTransportImpl( | 927 transport_receiver_.reset(new CastTransportImpl( |
| 929 testing_clock_sender_, base::TimeDelta::FromMilliseconds(1), | 928 testing_clock_sender_, base::TimeDelta::FromMilliseconds(1), |
| 930 base::WrapUnique( | 929 base::MakeUnique<TransportClient>(cast_environment_receiver_->logger(), |
| 931 new TransportClient(cast_environment_receiver_->logger(), this)), | 930 this), |
| 932 base::WrapUnique(receiver_to_sender_), task_runner_sender_)); | 931 base::WrapUnique(receiver_to_sender_), task_runner_sender_)); |
| 933 | 932 |
| 934 cast_receiver_ = | 933 cast_receiver_ = |
| 935 CastReceiver::Create(cast_environment_receiver_, audio_receiver_config_, | 934 CastReceiver::Create(cast_environment_receiver_, audio_receiver_config_, |
| 936 video_receiver_config_, transport_receiver_.get()); | 935 video_receiver_config_, transport_receiver_.get()); |
| 937 | 936 |
| 938 cast_sender_ = | 937 cast_sender_ = |
| 939 CastSender::Create(cast_environment_sender_, transport_sender_.get()); | 938 CastSender::Create(cast_environment_sender_, transport_sender_.get()); |
| 940 | 939 |
| 941 // Initializing audio and video senders. | 940 // Initializing audio and video senders. |
| (...skipping 329 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1271 EXPECT_EQ(0u, jump); | 1270 EXPECT_EQ(0u, jump); |
| 1272 jump = i; | 1271 jump = i; |
| 1273 } | 1272 } |
| 1274 } | 1273 } |
| 1275 EXPECT_GT(jump, 49u); | 1274 EXPECT_GT(jump, 49u); |
| 1276 EXPECT_LT(jump, 120u); | 1275 EXPECT_LT(jump, 120u); |
| 1277 } | 1276 } |
| 1278 | 1277 |
| 1279 } // namespace cast | 1278 } // namespace cast |
| 1280 } // namespace media | 1279 } // namespace media |
| OLD | NEW |