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

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

Issue 1706803002: Simplify EncoderStateFeedback. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Created 4 years, 10 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
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2012 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 10
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
44 MOCK_METHOD1(OnReceivedIntraFrameRequest, 44 MOCK_METHOD1(OnReceivedIntraFrameRequest,
45 void(uint32_t)); 45 void(uint32_t));
46 MOCK_METHOD2(OnReceivedSLI, 46 MOCK_METHOD2(OnReceivedSLI,
47 void(uint32_t ssrc, uint8_t picture_id)); 47 void(uint32_t ssrc, uint8_t picture_id));
48 MOCK_METHOD2(OnReceivedRPSI, 48 MOCK_METHOD2(OnReceivedRPSI,
49 void(uint32_t ssrc, uint64_t picture_id)); 49 void(uint32_t ssrc, uint64_t picture_id));
50 MOCK_METHOD2(OnLocalSsrcChanged, 50 MOCK_METHOD2(OnLocalSsrcChanged,
51 void(uint32_t old_ssrc, uint32_t new_ssrc)); 51 void(uint32_t old_ssrc, uint32_t new_ssrc));
52 }; 52 };
53 53
54 class VieKeyRequestTest : public ::testing::Test { 54 class VieKeyRequestTest : public ::testing::Test {
danilchap 2016/02/17 16:14:00 Since only one test left, may be class could be re
pbos-webrtc 2016/02/18 16:00:29 Done.
55 protected: 55 protected:
56 VieKeyRequestTest() 56 VieKeyRequestTest()
57 : pacer_(Clock::GetRealTimeClock(), 57 : pacer_(Clock::GetRealTimeClock(),
58 &router_, 58 &router_,
59 BitrateController::kDefaultStartBitrateKbps, 59 BitrateController::kDefaultStartBitrateKbps,
60 PacedSender::kDefaultPaceMultiplier * 60 PacedSender::kDefaultPaceMultiplier *
61 BitrateController::kDefaultStartBitrateKbps, 61 BitrateController::kDefaultStartBitrateKbps,
62 0) {} 62 0) {}
63 virtual void SetUp() { 63 virtual void SetUp() {
64 process_thread_.reset(new NiceMock<MockProcessThread>); 64 process_thread_.reset(new NiceMock<MockProcessThread>);
65 encoder_state_feedback_.reset(new EncoderStateFeedback());
66 } 65 }
67 rtc::scoped_ptr<MockProcessThread> process_thread_; 66 rtc::scoped_ptr<MockProcessThread> process_thread_;
68 rtc::scoped_ptr<EncoderStateFeedback> encoder_state_feedback_; 67 EncoderStateFeedback encoder_state_feedback_;
69 PacketRouter router_; 68 PacketRouter router_;
70 PacedSender pacer_; 69 PacedSender pacer_;
71 }; 70 };
72 71
73 TEST_F(VieKeyRequestTest, CreateAndTriggerRequests) { 72 TEST_F(VieKeyRequestTest, CreateAndTriggerRequests) {
danilchap 2016/02/17 16:14:00 OnLocalSsrcChanged probably should be tested too.
pbos-webrtc 2016/02/18 16:00:29 Added DCHECKs to verify in runtime that it's never
74 const int ssrc = 1234; 73 const int ssrc = 1234;
danilchap 2016/02/17 16:14:01 const uint32_t ssrc
pbos-webrtc 2016/02/18 16:00:29 Done
75 MockVieEncoder encoder(process_thread_.get(), &pacer_); 74 MockVieEncoder encoder(process_thread_.get(), &pacer_);
76 encoder_state_feedback_->AddEncoder(std::vector<uint32_t>(1, ssrc), &encoder); 75 encoder_state_feedback_.Init(std::vector<uint32_t>(1, ssrc), &encoder);
77 76
78 EXPECT_CALL(encoder, OnReceivedIntraFrameRequest(ssrc)) 77 EXPECT_CALL(encoder, OnReceivedIntraFrameRequest(ssrc))
79 .Times(1); 78 .Times(1);
80 encoder_state_feedback_->GetRtcpIntraFrameObserver()-> 79 encoder_state_feedback_.OnReceivedIntraFrameRequest(ssrc);
81 OnReceivedIntraFrameRequest(ssrc);
82 80
83 const uint8_t sli_picture_id = 3; 81 const uint8_t sli_picture_id = 3;
84 EXPECT_CALL(encoder, OnReceivedSLI(ssrc, sli_picture_id)) 82 EXPECT_CALL(encoder, OnReceivedSLI(ssrc, sli_picture_id))
85 .Times(1); 83 .Times(1);
86 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedSLI( 84 encoder_state_feedback_.OnReceivedSLI(ssrc, sli_picture_id);
87 ssrc, sli_picture_id);
88 85
89 const uint64_t rpsi_picture_id = 9; 86 const uint64_t rpsi_picture_id = 9;
90 EXPECT_CALL(encoder, OnReceivedRPSI(ssrc, rpsi_picture_id)) 87 EXPECT_CALL(encoder, OnReceivedRPSI(ssrc, rpsi_picture_id))
91 .Times(1); 88 .Times(1);
92 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedRPSI( 89 encoder_state_feedback_.OnReceivedRPSI(ssrc, rpsi_picture_id);
93 ssrc, rpsi_picture_id);
94 90
95 encoder_state_feedback_->RemoveEncoder(&encoder); 91 encoder_state_feedback_.TearDown();
96 }
97
98 // Register multiple encoders and make sure the request is relayed to correct
99 // ViEEncoder.
100 TEST_F(VieKeyRequestTest, MultipleEncoders) {
101 const int ssrc_1 = 1234;
102 const int ssrc_2 = 5678;
103 MockVieEncoder encoder_1(process_thread_.get(), &pacer_);
104 MockVieEncoder encoder_2(process_thread_.get(), &pacer_);
105 encoder_state_feedback_->AddEncoder(std::vector<uint32_t>(1, ssrc_1),
106 &encoder_1);
107 encoder_state_feedback_->AddEncoder(std::vector<uint32_t>(1, ssrc_2),
108 &encoder_2);
109
110 EXPECT_CALL(encoder_1, OnReceivedIntraFrameRequest(ssrc_1))
111 .Times(1);
112 EXPECT_CALL(encoder_2, OnReceivedIntraFrameRequest(ssrc_2))
113 .Times(1);
114 encoder_state_feedback_->GetRtcpIntraFrameObserver()->
115 OnReceivedIntraFrameRequest(ssrc_1);
116 encoder_state_feedback_->GetRtcpIntraFrameObserver()->
117 OnReceivedIntraFrameRequest(ssrc_2);
118
119 const uint8_t sli_pid_1 = 3;
120 const uint8_t sli_pid_2 = 4;
121 EXPECT_CALL(encoder_1, OnReceivedSLI(ssrc_1, sli_pid_1))
122 .Times(1);
123 EXPECT_CALL(encoder_2, OnReceivedSLI(ssrc_2, sli_pid_2))
124 .Times(1);
125 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedSLI(
126 ssrc_1, sli_pid_1);
127 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedSLI(
128 ssrc_2, sli_pid_2);
129
130 const uint64_t rpsi_pid_1 = 9;
131 const uint64_t rpsi_pid_2 = 10;
132 EXPECT_CALL(encoder_1, OnReceivedRPSI(ssrc_1, rpsi_pid_1))
133 .Times(1);
134 EXPECT_CALL(encoder_2, OnReceivedRPSI(ssrc_2, rpsi_pid_2))
135 .Times(1);
136 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedRPSI(
137 ssrc_1, rpsi_pid_1);
138 encoder_state_feedback_->GetRtcpIntraFrameObserver()->OnReceivedRPSI(
139 ssrc_2, rpsi_pid_2);
140
141 encoder_state_feedback_->RemoveEncoder(&encoder_1);
142 EXPECT_CALL(encoder_2, OnReceivedIntraFrameRequest(ssrc_2))
143 .Times(1);
144 encoder_state_feedback_->GetRtcpIntraFrameObserver()->
145 OnReceivedIntraFrameRequest(ssrc_2);
146 encoder_state_feedback_->RemoveEncoder(&encoder_2);
147 } 92 }
148 93
149 } // namespace webrtc 94 } // namespace webrtc
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698