Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(108)

Side by Side Diff: webrtc/video/video_send_stream_tests.cc

Issue 1335353005: Remove channel ids from various interfaces. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: rebase Created 5 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « webrtc/video/video_send_stream.cc ('k') | webrtc/video_engine/vie_channel.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 310 matching lines...) Expand 10 before | Expand all | Expand 10 after
321 private: 321 private:
322 Action OnSendRtp(const uint8_t* packet, size_t length) override { 322 Action OnSendRtp(const uint8_t* packet, size_t length) override {
323 RTPHeader header; 323 RTPHeader header;
324 EXPECT_TRUE(parser_->Parse(packet, length, &header)); 324 EXPECT_TRUE(parser_->Parse(packet, length, &header));
325 325
326 // Send lossy receive reports to trigger FEC enabling. 326 // Send lossy receive reports to trigger FEC enabling.
327 if (send_count_++ % 2 != 0) { 327 if (send_count_++ % 2 != 0) {
328 // Receive statistics reporting having lost 50% of the packets. 328 // Receive statistics reporting having lost 50% of the packets.
329 FakeReceiveStatistics lossy_receive_stats( 329 FakeReceiveStatistics lossy_receive_stats(
330 kSendSsrcs[0], header.sequenceNumber, send_count_ / 2, 127); 330 kSendSsrcs[0], header.sequenceNumber, send_count_ / 2, 127);
331 RTCPSender rtcp_sender(0, false, Clock::GetRealTimeClock(), 331 RTCPSender rtcp_sender(false, Clock::GetRealTimeClock(),
332 &lossy_receive_stats, nullptr); 332 &lossy_receive_stats, nullptr);
333 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_)); 333 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_));
334 334
335 rtcp_sender.SetRTCPStatus(kRtcpNonCompound); 335 rtcp_sender.SetRTCPStatus(kRtcpNonCompound);
336 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]); 336 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]);
337 337
338 RTCPSender::FeedbackState feedback_state; 338 RTCPSender::FeedbackState feedback_state;
339 339
340 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr)); 340 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr));
341 } 341 }
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
403 private: 403 private:
404 Action OnSendRtp(const uint8_t* packet, size_t length) override { 404 Action OnSendRtp(const uint8_t* packet, size_t length) override {
405 RTPHeader header; 405 RTPHeader header;
406 EXPECT_TRUE(parser_->Parse(packet, length, &header)); 406 EXPECT_TRUE(parser_->Parse(packet, length, &header));
407 407
408 // Nack second packet after receiving the third one. 408 // Nack second packet after receiving the third one.
409 if (++send_count_ == 3) { 409 if (++send_count_ == 3) {
410 uint16_t nack_sequence_number = header.sequenceNumber - 1; 410 uint16_t nack_sequence_number = header.sequenceNumber - 1;
411 nacked_sequence_number_ = nack_sequence_number; 411 nacked_sequence_number_ = nack_sequence_number;
412 NullReceiveStatistics null_stats; 412 NullReceiveStatistics null_stats;
413 RTCPSender rtcp_sender( 413 RTCPSender rtcp_sender(false, Clock::GetRealTimeClock(), &null_stats,
414 0, false, Clock::GetRealTimeClock(), &null_stats, nullptr); 414 nullptr);
415 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_)); 415 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_));
416 416
417 rtcp_sender.SetRTCPStatus(kRtcpNonCompound); 417 rtcp_sender.SetRTCPStatus(kRtcpNonCompound);
418 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]); 418 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]);
419 419
420 RTCPSender::FeedbackState feedback_state; 420 RTCPSender::FeedbackState feedback_state;
421 421
422 EXPECT_EQ(0, 422 EXPECT_EQ(0,
423 rtcp_sender.SendRTCP( 423 rtcp_sender.SendRTCP(
424 feedback_state, kRtcpNack, 1, &nack_sequence_number)); 424 feedback_state, kRtcpNack, 1, &nack_sequence_number));
(...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after
585 585
586 return SEND_PACKET; 586 return SEND_PACKET;
587 } 587 }
588 588
589 void TriggerLossReport(const RTPHeader& header) { 589 void TriggerLossReport(const RTPHeader& header) {
590 // Send lossy receive reports to trigger FEC enabling. 590 // Send lossy receive reports to trigger FEC enabling.
591 if (packet_count_++ % 2 != 0) { 591 if (packet_count_++ % 2 != 0) {
592 // Receive statistics reporting having lost 50% of the packets. 592 // Receive statistics reporting having lost 50% of the packets.
593 FakeReceiveStatistics lossy_receive_stats( 593 FakeReceiveStatistics lossy_receive_stats(
594 kSendSsrcs[0], header.sequenceNumber, packet_count_ / 2, 127); 594 kSendSsrcs[0], header.sequenceNumber, packet_count_ / 2, 127);
595 RTCPSender rtcp_sender(0, false, Clock::GetRealTimeClock(), 595 RTCPSender rtcp_sender(false, Clock::GetRealTimeClock(),
596 &lossy_receive_stats, nullptr); 596 &lossy_receive_stats, nullptr);
597 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_)); 597 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_));
598 598
599 rtcp_sender.SetRTCPStatus(kRtcpNonCompound); 599 rtcp_sender.SetRTCPStatus(kRtcpNonCompound);
600 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]); 600 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]);
601 601
602 RTCPSender::FeedbackState feedback_state; 602 RTCPSender::FeedbackState feedback_state;
603 603
604 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr)); 604 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr));
605 } 605 }
(...skipping 210 matching lines...) Expand 10 before | Expand all | Expand 10 after
816 kBeforeSuspend, 816 kBeforeSuspend,
817 kDuringSuspend, 817 kDuringSuspend,
818 kWaitingForPacket, 818 kWaitingForPacket,
819 kWaitingForStats 819 kWaitingForStats
820 }; 820 };
821 821
822 virtual void SendRtcpFeedback(int remb_value) 822 virtual void SendRtcpFeedback(int remb_value)
823 EXCLUSIVE_LOCKS_REQUIRED(crit_) { 823 EXCLUSIVE_LOCKS_REQUIRED(crit_) {
824 FakeReceiveStatistics receive_stats( 824 FakeReceiveStatistics receive_stats(
825 kSendSsrcs[0], last_sequence_number_, rtp_count_, 0); 825 kSendSsrcs[0], last_sequence_number_, rtp_count_, 0);
826 RTCPSender rtcp_sender(0, false, clock_, &receive_stats, nullptr); 826 RTCPSender rtcp_sender(false, clock_, &receive_stats, nullptr);
827 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_)); 827 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_));
828 828
829 rtcp_sender.SetRTCPStatus(kRtcpNonCompound); 829 rtcp_sender.SetRTCPStatus(kRtcpNonCompound);
830 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]); 830 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]);
831 if (remb_value > 0) { 831 if (remb_value > 0) {
832 rtcp_sender.SetREMBStatus(true); 832 rtcp_sender.SetREMBStatus(true);
833 rtcp_sender.SetREMBData(remb_value, std::vector<uint32_t>()); 833 rtcp_sender.SetREMBData(remb_value, std::vector<uint32_t>());
834 } 834 }
835 RTCPSender::FeedbackState feedback_state; 835 RTCPSender::FeedbackState feedback_state;
836 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr)); 836 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr));
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
875 875
876 Action OnSendRtcp(const uint8_t* packet, size_t length) override { 876 Action OnSendRtcp(const uint8_t* packet, size_t length) override {
877 rtc::CritScope lock(&crit_); 877 rtc::CritScope lock(&crit_);
878 const int kVideoMutedThresholdMs = 10000; 878 const int kVideoMutedThresholdMs = 10000;
879 if (last_packet_time_ms_ > 0 && 879 if (last_packet_time_ms_ > 0 &&
880 clock_->TimeInMilliseconds() - last_packet_time_ms_ > 880 clock_->TimeInMilliseconds() - last_packet_time_ms_ >
881 kVideoMutedThresholdMs) 881 kVideoMutedThresholdMs)
882 observation_complete_->Set(); 882 observation_complete_->Set();
883 // Receive statistics reporting having lost 50% of the packets. 883 // Receive statistics reporting having lost 50% of the packets.
884 FakeReceiveStatistics receive_stats(kSendSsrcs[0], 1, 1, 0); 884 FakeReceiveStatistics receive_stats(kSendSsrcs[0], 1, 1, 0);
885 RTCPSender rtcp_sender(0, false, Clock::GetRealTimeClock(), 885 RTCPSender rtcp_sender(false, Clock::GetRealTimeClock(), &receive_stats,
886 &receive_stats, nullptr); 886 nullptr);
887 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_)); 887 EXPECT_EQ(0, rtcp_sender.RegisterSendTransport(&transport_adapter_));
888 888
889 rtcp_sender.SetRTCPStatus(kRtcpNonCompound); 889 rtcp_sender.SetRTCPStatus(kRtcpNonCompound);
890 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]); 890 rtcp_sender.SetRemoteSSRC(kSendSsrcs[0]);
891 891
892 RTCPSender::FeedbackState feedback_state; 892 RTCPSender::FeedbackState feedback_state;
893 893
894 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr)); 894 EXPECT_EQ(0, rtcp_sender.SendRTCP(feedback_state, kRtcpRr));
895 return SEND_PACKET; 895 return SEND_PACKET;
896 } 896 }
(...skipping 994 matching lines...) Expand 10 before | Expand all | Expand 10 after
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
OLDNEW
« no previous file with comments | « webrtc/video/video_send_stream.cc ('k') | webrtc/video_engine/vie_channel.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698