| Index: webrtc/modules/video_coding/packet_buffer.cc
|
| diff --git a/webrtc/modules/video_coding/packet_buffer.cc b/webrtc/modules/video_coding/packet_buffer.cc
|
| index ff013e00102894a9b5621dd083b57e656e52f5ab..6c3cfacac52323a457c9bed1d30ef8b3801b65d1 100644
|
| --- a/webrtc/modules/video_coding/packet_buffer.cc
|
| +++ b/webrtc/modules/video_coding/packet_buffer.cc
|
| @@ -59,6 +59,7 @@ bool PacketBuffer::InsertPacket(VCMPacket* packet) {
|
| std::vector<std::unique_ptr<RtpFrameObject>> found_frames;
|
| {
|
| rtc::CritScope lock(&crit_);
|
| +
|
| uint16_t seq_num = packet->seqNum;
|
| size_t index = seq_num % size_;
|
|
|
| @@ -107,6 +108,11 @@ bool PacketBuffer::InsertPacket(VCMPacket* packet) {
|
| data_buffer_[index] = *packet;
|
| packet->dataPtr = nullptr;
|
|
|
| + int64_t now_ms = clock_->TimeInMilliseconds();
|
| + last_received_packet_ms_ = rtc::Optional<int64_t>(now_ms);
|
| + if (packet->frameType == kVideoFrameKey)
|
| + last_received_keyframe_packet_ms_ = rtc::Optional<int64_t>(now_ms);
|
| +
|
| found_frames = FindFrames(seq_num);
|
| }
|
|
|
| @@ -143,6 +149,18 @@ void PacketBuffer::Clear() {
|
|
|
| first_packet_received_ = false;
|
| is_cleared_to_first_seq_num_ = false;
|
| + last_received_packet_ms_ = rtc::Optional<int64_t>();
|
| + last_received_keyframe_packet_ms_ = rtc::Optional<int64_t>();
|
| +}
|
| +
|
| +rtc::Optional<int64_t> PacketBuffer::LastReceivedPacketMs() const {
|
| + rtc::CritScope lock(&crit_);
|
| + return last_received_packet_ms_;
|
| +}
|
| +
|
| +rtc::Optional<int64_t> PacketBuffer::LastReceivedKeyframePacketMs() const {
|
| + rtc::CritScope lock(&crit_);
|
| + return last_received_keyframe_packet_ms_;
|
| }
|
|
|
| bool PacketBuffer::ExpandBufferSize() {
|
|
|