admin/webrtc_m130
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[Unwrap] Migrate RtcEventLog parser to use RtpSequenceNumberUnwrapper

Browse Source 
Bug: webrtc:13982
Change-Id: I974aafd810ee3b266689a76fc3ed3b7a62440df5
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/288963
Reviewed-by: Björn Terelius <terelius@webrtc.org>
Auto-Submit: Evan Shrubsole <eshr@webrtc.org>
Commit-Queue: Björn Terelius <terelius@webrtc.org>
Cr-Commit-Position: refs/heads/main@{#39080}
This commit is contained in:
Evan Shrubsole 2023-01-09 13:40:58 +00:00 committed by WebRTC LUCI CQ
parent d22dc86211
commit 9337ac8650
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
logging/rtc_event_log/rtc_event_log_parser.cc
View File

@ -32,7 +32,6 @@
#include "logging/rtc_event_log/events/logged_rtp_rtcp.h" #include "logging/rtc_event_log/events/logged_rtp_rtcp.h"
#include "logging/rtc_event_log/rtc_event_processor.h" #include "logging/rtc_event_log/rtc_event_processor.h"
#include "modules/audio_coding/audio_network_adaptor/include/audio_network_adaptor.h" #include "modules/audio_coding/audio_network_adaptor/include/audio_network_adaptor.h"
#include "modules/include/module_common_types_public.h"
#include "modules/rtp_rtcp/include/rtp_cvo.h" #include "modules/rtp_rtcp/include/rtp_cvo.h"
#include "modules/rtp_rtcp/include/rtp_rtcp_defines.h" #include "modules/rtp_rtcp/include/rtp_rtcp_defines.h"
#include "modules/rtp_rtcp/source/byte_io.h" #include "modules/rtp_rtcp/source/byte_io.h"
@ -2289,7 +2288,7 @@ std::vector<LoggedPacketInfo> ParsedRtcEventLog::GetPacketInfos(
std::map<int64_t, size_t> indices; std::map<int64_t, size_t> indices;
uint16_t current_overhead = kDefaultOverhead; uint16_t current_overhead = kDefaultOverhead;
Timestamp last_log_time = Timestamp::Zero(); Timestamp last_log_time = Timestamp::Zero();
SequenceNumberUnwrapper seq_num_unwrapper; RtpSequenceNumberUnwrapper seq_num_unwrapper;
auto advance_time = [&](Timestamp new_log_time) { auto advance_time = [&](Timestamp new_log_time) {
if (overhead_iter != overheads.end() && if (overhead_iter != overheads.end() &&
@ -2301,7 +2300,7 @@ std::vector<LoggedPacketInfo> ParsedRtcEventLog::GetPacketInfos(
// therefore we don't want to match up sequence numbers as we might have had // therefore we don't want to match up sequence numbers as we might have had
// a wraparound. // a wraparound.
if (new_log_time - last_log_time > TimeDelta::Seconds(30)) { if (new_log_time - last_log_time > TimeDelta::Seconds(30)) {
seq_num_unwrapper = SequenceNumberUnwrapper(); seq_num_unwrapper.Reset();
indices.clear(); indices.clear();
} }
RTC_DCHECK_GE(new_log_time, last_log_time); RTC_DCHECK_GE(new_log_time, last_log_time);