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 |