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> | 10 #include <algorithm> |
(...skipping 213 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
224 | 224 |
225 CreateVideoStreams(); | 225 CreateVideoStreams(); |
226 Start(); | 226 Start(); |
227 | 227 |
228 // Create frames that are smaller than the send width/height, this is done to | 228 // Create frames that are smaller than the send width/height, this is done to |
229 // check that the callbacks are done after processing video. | 229 // check that the callbacks are done after processing video. |
230 std::unique_ptr<test::FrameGenerator> frame_generator( | 230 std::unique_ptr<test::FrameGenerator> frame_generator( |
231 test::FrameGenerator::CreateSquareGenerator(kWidth, kHeight)); | 231 test::FrameGenerator::CreateSquareGenerator(kWidth, kHeight)); |
232 test::FrameForwarder frame_forwarder; | 232 test::FrameForwarder frame_forwarder; |
233 video_send_stream_->SetSource( | 233 video_send_stream_->SetSource( |
234 &frame_forwarder, VideoSendStream::DegradationPreference::kBalanced); | 234 &frame_forwarder, |
| 235 VideoSendStream::DegradationPreference::kMaintainFramerate); |
235 | 236 |
236 frame_forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); | 237 frame_forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); |
237 EXPECT_TRUE(renderer.Wait()) | 238 EXPECT_TRUE(renderer.Wait()) |
238 << "Timed out while waiting for the frame to render."; | 239 << "Timed out while waiting for the frame to render."; |
239 | 240 |
240 Stop(); | 241 Stop(); |
241 | 242 |
242 sender_transport.StopSending(); | 243 sender_transport.StopSending(); |
243 receiver_transport.StopSending(); | 244 receiver_transport.StopSending(); |
244 | 245 |
(...skipping 26 matching lines...) Expand all Loading... |
271 video_receive_configs_[0].renderer = &renderer; | 272 video_receive_configs_[0].renderer = &renderer; |
272 | 273 |
273 CreateVideoStreams(); | 274 CreateVideoStreams(); |
274 Start(); | 275 Start(); |
275 | 276 |
276 std::unique_ptr<test::FrameGenerator> frame_generator( | 277 std::unique_ptr<test::FrameGenerator> frame_generator( |
277 test::FrameGenerator::CreateSquareGenerator(kDefaultWidth, | 278 test::FrameGenerator::CreateSquareGenerator(kDefaultWidth, |
278 kDefaultHeight)); | 279 kDefaultHeight)); |
279 test::FrameForwarder frame_forwarder; | 280 test::FrameForwarder frame_forwarder; |
280 video_send_stream_->SetSource( | 281 video_send_stream_->SetSource( |
281 &frame_forwarder, VideoSendStream::DegradationPreference::kBalanced); | 282 &frame_forwarder, |
| 283 VideoSendStream::DegradationPreference::kMaintainFramerate); |
282 frame_forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); | 284 frame_forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); |
283 | 285 |
284 EXPECT_TRUE(renderer.Wait()) | 286 EXPECT_TRUE(renderer.Wait()) |
285 << "Timed out while waiting for the frame to render."; | 287 << "Timed out while waiting for the frame to render."; |
286 | 288 |
287 Stop(); | 289 Stop(); |
288 | 290 |
289 sender_transport.StopSending(); | 291 sender_transport.StopSending(); |
290 receiver_transport.StopSending(); | 292 receiver_transport.StopSending(); |
291 | 293 |
(...skipping 1218 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1510 UpdateReceiveConfig(i, &receive_config); | 1512 UpdateReceiveConfig(i, &receive_config); |
1511 | 1513 |
1512 receive_streams[i] = | 1514 receive_streams[i] = |
1513 receiver_call->CreateVideoReceiveStream(std::move(receive_config)); | 1515 receiver_call->CreateVideoReceiveStream(std::move(receive_config)); |
1514 receive_streams[i]->Start(); | 1516 receive_streams[i]->Start(); |
1515 | 1517 |
1516 frame_generators[i] = test::FrameGeneratorCapturer::Create( | 1518 frame_generators[i] = test::FrameGeneratorCapturer::Create( |
1517 width, height, 30, Clock::GetRealTimeClock()); | 1519 width, height, 30, Clock::GetRealTimeClock()); |
1518 send_streams[i]->SetSource( | 1520 send_streams[i]->SetSource( |
1519 frame_generators[i], | 1521 frame_generators[i], |
1520 VideoSendStream::DegradationPreference::kBalanced); | 1522 VideoSendStream::DegradationPreference::kMaintainFramerate); |
1521 frame_generators[i]->Start(); | 1523 frame_generators[i]->Start(); |
1522 } | 1524 } |
1523 | 1525 |
1524 Wait(); | 1526 Wait(); |
1525 | 1527 |
1526 for (size_t i = 0; i < kNumStreams; ++i) { | 1528 for (size_t i = 0; i < kNumStreams; ++i) { |
1527 frame_generators[i]->Stop(); | 1529 frame_generators[i]->Stop(); |
1528 sender_call->DestroyVideoSendStream(send_streams[i]); | 1530 sender_call->DestroyVideoSendStream(send_streams[i]); |
1529 receiver_call->DestroyVideoReceiveStream(receive_streams[i]); | 1531 receiver_call->DestroyVideoReceiveStream(receive_streams[i]); |
1530 delete frame_generators[i]; | 1532 delete frame_generators[i]; |
(...skipping 428 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1959 video_receive_configs_[0].pre_decode_callback = &pre_decode_observer; | 1961 video_receive_configs_[0].pre_decode_callback = &pre_decode_observer; |
1960 | 1962 |
1961 CreateVideoStreams(); | 1963 CreateVideoStreams(); |
1962 Start(); | 1964 Start(); |
1963 | 1965 |
1964 std::unique_ptr<test::FrameGenerator> frame_generator( | 1966 std::unique_ptr<test::FrameGenerator> frame_generator( |
1965 test::FrameGenerator::CreateSquareGenerator(kDefaultWidth, | 1967 test::FrameGenerator::CreateSquareGenerator(kDefaultWidth, |
1966 kDefaultHeight)); | 1968 kDefaultHeight)); |
1967 test::FrameForwarder forwarder; | 1969 test::FrameForwarder forwarder; |
1968 video_send_stream_->SetSource( | 1970 video_send_stream_->SetSource( |
1969 &forwarder, VideoSendStream::DegradationPreference::kBalanced); | 1971 &forwarder, VideoSendStream::DegradationPreference::kMaintainFramerate); |
1970 forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); | 1972 forwarder.IncomingCapturedFrame(*frame_generator->NextFrame()); |
1971 | 1973 |
1972 EXPECT_TRUE(post_encode_observer.Wait()) | 1974 EXPECT_TRUE(post_encode_observer.Wait()) |
1973 << "Timed out while waiting for send-side encoded-frame callback."; | 1975 << "Timed out while waiting for send-side encoded-frame callback."; |
1974 | 1976 |
1975 EXPECT_TRUE(pre_decode_observer.Wait()) | 1977 EXPECT_TRUE(pre_decode_observer.Wait()) |
1976 << "Timed out while waiting for pre-decode encoded-frame callback."; | 1978 << "Timed out while waiting for pre-decode encoded-frame callback."; |
1977 | 1979 |
1978 post_encode_observer.ExpectEqualFrames(pre_decode_observer); | 1980 post_encode_observer.ExpectEqualFrames(pre_decode_observer); |
1979 | 1981 |
(...skipping 2361 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4341 std::unique_ptr<VideoEncoder> encoder_; | 4343 std::unique_ptr<VideoEncoder> encoder_; |
4342 std::unique_ptr<VideoDecoder> decoder_; | 4344 std::unique_ptr<VideoDecoder> decoder_; |
4343 rtc::CriticalSection crit_; | 4345 rtc::CriticalSection crit_; |
4344 int recorded_frames_ GUARDED_BY(crit_); | 4346 int recorded_frames_ GUARDED_BY(crit_); |
4345 } test(this); | 4347 } test(this); |
4346 | 4348 |
4347 RunBaseTest(&test); | 4349 RunBaseTest(&test); |
4348 } | 4350 } |
4349 | 4351 |
4350 } // namespace webrtc | 4352 } // namespace webrtc |
OLD | NEW |