| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 #include <algorithm> // max | 10 #include <algorithm> // max |
| (...skipping 493 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 504 test_generic_packetization_(test_generic_packetization), | 504 test_generic_packetization_(test_generic_packetization), |
| 505 use_fec_(use_fec), | 505 use_fec_(use_fec), |
| 506 packet_count_(0), | 506 packet_count_(0), |
| 507 accumulated_size_(0), | 507 accumulated_size_(0), |
| 508 accumulated_payload_(0), | 508 accumulated_payload_(0), |
| 509 fec_packet_received_(false), | 509 fec_packet_received_(false), |
| 510 current_size_rtp_(start_size), | 510 current_size_rtp_(start_size), |
| 511 current_size_frame_(static_cast<int32_t>(start_size)) { | 511 current_size_frame_(static_cast<int32_t>(start_size)) { |
| 512 // Fragmentation required, this test doesn't make sense without it. | 512 // Fragmentation required, this test doesn't make sense without it. |
| 513 encoder_.SetFrameSize(start_size); | 513 encoder_.SetFrameSize(start_size); |
| 514 DCHECK_GT(stop_size, max_packet_size); | 514 RTC_DCHECK_GT(stop_size, max_packet_size); |
| 515 transport_adapter_.Enable(); | 515 transport_adapter_.Enable(); |
| 516 } | 516 } |
| 517 | 517 |
| 518 private: | 518 private: |
| 519 Action OnSendRtp(const uint8_t* packet, size_t size) override { | 519 Action OnSendRtp(const uint8_t* packet, size_t size) override { |
| 520 size_t length = size; | 520 size_t length = size; |
| 521 RTPHeader header; | 521 RTPHeader header; |
| 522 EXPECT_TRUE(parser_->Parse(packet, length, &header)); | 522 EXPECT_TRUE(parser_->Parse(packet, length, &header)); |
| 523 | 523 |
| 524 EXPECT_LE(length, max_packet_size_); | 524 EXPECT_LE(length, max_packet_size_); |
| (...skipping 437 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 962 size_t length, | 962 size_t length, |
| 963 const PacketTime& packet_time) override { | 963 const PacketTime& packet_time) override { |
| 964 EXPECT_TRUE(media_type == MediaType::ANY || | 964 EXPECT_TRUE(media_type == MediaType::ANY || |
| 965 media_type == MediaType::VIDEO); | 965 media_type == MediaType::VIDEO); |
| 966 if (RtpHeaderParser::IsRtcp(packet, length)) | 966 if (RtpHeaderParser::IsRtcp(packet, length)) |
| 967 return DELIVERY_OK; | 967 return DELIVERY_OK; |
| 968 | 968 |
| 969 RTPHeader header; | 969 RTPHeader header; |
| 970 if (!parser_->Parse(packet, length, &header)) | 970 if (!parser_->Parse(packet, length, &header)) |
| 971 return DELIVERY_PACKET_ERROR; | 971 return DELIVERY_PACKET_ERROR; |
| 972 DCHECK(stream_ != nullptr); | 972 RTC_DCHECK(stream_ != nullptr); |
| 973 VideoSendStream::Stats stats = stream_->GetStats(); | 973 VideoSendStream::Stats stats = stream_->GetStats(); |
| 974 if (!stats.substreams.empty()) { | 974 if (!stats.substreams.empty()) { |
| 975 EXPECT_EQ(1u, stats.substreams.size()); | 975 EXPECT_EQ(1u, stats.substreams.size()); |
| 976 int total_bitrate_bps = | 976 int total_bitrate_bps = |
| 977 stats.substreams.begin()->second.total_bitrate_bps; | 977 stats.substreams.begin()->second.total_bitrate_bps; |
| 978 test::PrintResult("bitrate_stats_", | 978 test::PrintResult("bitrate_stats_", |
| 979 "min_transmit_bitrate_low_remb", | 979 "min_transmit_bitrate_low_remb", |
| 980 "bitrate_bps", | 980 "bitrate_bps", |
| 981 static_cast<size_t>(total_bitrate_bps), | 981 static_cast<size_t>(total_bitrate_bps), |
| 982 "bps", | 982 "bps", |
| (...skipping 764 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1747 uint8_t buffer[16] = {0}; | 1747 uint8_t buffer[16] = {0}; |
| 1748 EncodedImage encoded(buffer, sizeof(buffer), sizeof(buffer)); | 1748 EncodedImage encoded(buffer, sizeof(buffer), sizeof(buffer)); |
| 1749 encoded._timeStamp = input_image.timestamp(); | 1749 encoded._timeStamp = input_image.timestamp(); |
| 1750 encoded.capture_time_ms_ = input_image.render_time_ms(); | 1750 encoded.capture_time_ms_ = input_image.render_time_ms(); |
| 1751 | 1751 |
| 1752 for (size_t i = 0; i < kNumStreams; ++i) { | 1752 for (size_t i = 0; i < kNumStreams; ++i) { |
| 1753 specifics.codecSpecific.generic.simulcast_idx = static_cast<uint8_t>(i); | 1753 specifics.codecSpecific.generic.simulcast_idx = static_cast<uint8_t>(i); |
| 1754 encoded._frameType = (*frame_types)[i]; | 1754 encoded._frameType = (*frame_types)[i]; |
| 1755 encoded._encodedWidth = kEncodedResolution[i].width; | 1755 encoded._encodedWidth = kEncodedResolution[i].width; |
| 1756 encoded._encodedHeight = kEncodedResolution[i].height; | 1756 encoded._encodedHeight = kEncodedResolution[i].height; |
| 1757 DCHECK(callback_ != nullptr); | 1757 RTC_DCHECK(callback_ != nullptr); |
| 1758 if (callback_->Encoded(encoded, &specifics, nullptr) != 0) | 1758 if (callback_->Encoded(encoded, &specifics, nullptr) != 0) |
| 1759 return -1; | 1759 return -1; |
| 1760 } | 1760 } |
| 1761 | 1761 |
| 1762 observation_complete_->Set(); | 1762 observation_complete_->Set(); |
| 1763 return 0; | 1763 return 0; |
| 1764 } | 1764 } |
| 1765 void ModifyConfigs(VideoSendStream::Config* send_config, | 1765 void ModifyConfigs(VideoSendStream::Config* send_config, |
| 1766 std::vector<VideoReceiveStream::Config>* receive_configs, | 1766 std::vector<VideoReceiveStream::Config>* receive_configs, |
| 1767 VideoEncoderConfig* encoder_config) override { | 1767 VideoEncoderConfig* encoder_config) override { |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1891 EXPECT_TRUE(vp9videoHeader->flexible_mode); | 1891 EXPECT_TRUE(vp9videoHeader->flexible_mode); |
| 1892 observation_complete_->Set(); | 1892 observation_complete_->Set(); |
| 1893 } | 1893 } |
| 1894 | 1894 |
| 1895 } test; | 1895 } test; |
| 1896 | 1896 |
| 1897 RunBaseTest(&test); | 1897 RunBaseTest(&test); |
| 1898 } | 1898 } |
| 1899 | 1899 |
| 1900 } // namespace webrtc | 1900 } // namespace webrtc |
| OLD | NEW |