OLD | NEW |
---|---|
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 Loading... | |
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 |
OLD | NEW |