| 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 | 10 |
| (...skipping 456 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 467 uint32_t VideoReceiveStream::GetPlayoutTimestamp() const { | 467 uint32_t VideoReceiveStream::GetPlayoutTimestamp() const { |
| 468 RTC_NOTREACHED(); | 468 RTC_NOTREACHED(); |
| 469 return 0; | 469 return 0; |
| 470 } | 470 } |
| 471 | 471 |
| 472 void VideoReceiveStream::SetMinimumPlayoutDelay(int delay_ms) { | 472 void VideoReceiveStream::SetMinimumPlayoutDelay(int delay_ms) { |
| 473 RTC_DCHECK_RUN_ON(&module_process_thread_checker_); | 473 RTC_DCHECK_RUN_ON(&module_process_thread_checker_); |
| 474 video_receiver_.SetMinimumPlayoutDelay(delay_ms); | 474 video_receiver_.SetMinimumPlayoutDelay(delay_ms); |
| 475 } | 475 } |
| 476 | 476 |
| 477 void VideoReceiveStream::AddSecondarySink(RtpPacketSinkInterface* sink) { |
| 478 rtp_video_stream_receiver_.AddSecondarySink(sink); |
| 479 } |
| 480 |
| 481 void VideoReceiveStream::RemoveSecondarySink( |
| 482 const RtpPacketSinkInterface* sink) { |
| 483 rtp_video_stream_receiver_.RemoveSecondarySink(sink); |
| 484 } |
| 485 |
| 477 void VideoReceiveStream::DecodeThreadFunction(void* ptr) { | 486 void VideoReceiveStream::DecodeThreadFunction(void* ptr) { |
| 478 while (static_cast<VideoReceiveStream*>(ptr)->Decode()) { | 487 while (static_cast<VideoReceiveStream*>(ptr)->Decode()) { |
| 479 } | 488 } |
| 480 } | 489 } |
| 481 | 490 |
| 482 bool VideoReceiveStream::Decode() { | 491 bool VideoReceiveStream::Decode() { |
| 483 TRACE_EVENT0("webrtc", "VideoReceiveStream::Decode"); | 492 TRACE_EVENT0("webrtc", "VideoReceiveStream::Decode"); |
| 484 static const int kMaxWaitForFrameMs = 3000; | 493 static const int kMaxWaitForFrameMs = 3000; |
| 485 std::unique_ptr<video_coding::FrameObject> frame; | 494 std::unique_ptr<video_coding::FrameObject> frame; |
| 486 video_coding::FrameBuffer::ReturnReason res = | 495 video_coding::FrameBuffer::ReturnReason res = |
| (...skipping 30 matching lines...) Expand all Loading... |
| 517 if (stream_is_active && !receiving_keyframe) { | 526 if (stream_is_active && !receiving_keyframe) { |
| 518 LOG(LS_WARNING) << "No decodable frame in " << kMaxWaitForFrameMs | 527 LOG(LS_WARNING) << "No decodable frame in " << kMaxWaitForFrameMs |
| 519 << " ms, requesting keyframe."; | 528 << " ms, requesting keyframe."; |
| 520 RequestKeyFrame(); | 529 RequestKeyFrame(); |
| 521 } | 530 } |
| 522 } | 531 } |
| 523 return true; | 532 return true; |
| 524 } | 533 } |
| 525 } // namespace internal | 534 } // namespace internal |
| 526 } // namespace webrtc | 535 } // namespace webrtc |
| OLD | NEW |