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

Add --extend_run_time_duration flag to video_replay.

Browse Source 
Bug: webrtc:14508, webrtc:14103
Change-Id: I728388ff6a70bf42de87e6bbb0969df8ecc5a1b1
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/279641
Commit-Queue: Philip Eliasson <philipel@webrtc.org>
Reviewed-by: Harald Alvestrand <hta@webrtc.org>
Cr-Commit-Position: refs/heads/main@{#38435}
This commit is contained in:
philipel 2022-10-18 08:51:17 +02:00 committed by WebRTC LUCI CQ
parent 7768299bd4
commit 720bc4df3d
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
rtc_tools/video_replay.cc
View File

@ -159,6 +159,13 @@ ABSL_FLAG(bool, disable_preview, false, "Disable decoded video preview.");
ABSL_FLAG(bool, disable_decoding, false, "Disable video decoding."); ABSL_FLAG(bool, disable_decoding, false, "Disable video decoding.");
ABSL_FLAG(int,
extend_run_time_duration,
0,
"Extends the run time of the receiving client after the last RTP "
"packet has been delivered. Typically useful to let the last few "
"frames be decoded and rendered. Duration given in seconds.");
namespace { namespace {
bool ValidatePayloadType(int32_t payload_type) { bool ValidatePayloadType(int32_t payload_type) {
return payload_type > 0 && payload_type <= 127; return payload_type > 0 && payload_type <= 127;
@ -605,9 +612,10 @@ class RtpReplayer final {
} }
} }
} }
// One more call to SleepOrAdvanceTime is required to process the last // Note that even when `extend_run_time_duration` is zero
// `SleepOrAdvanceTime` should still be called in order to process the last
// delivered packet when running in simulated time. // delivered packet when running in simulated time.
SleepOrAdvanceTime(0); SleepOrAdvanceTime(absl::GetFlag(FLAGS_extend_run_time_duration) * 1000);
fprintf(stderr, "num_packets: %d\n", num_packets); fprintf(stderr, "num_packets: %d\n", num_packets);
@ -672,6 +680,7 @@ int main(int argc, char* argv[]) {
RTC_CHECK(ValidateRtpHeaderExtensionId( RTC_CHECK(ValidateRtpHeaderExtensionId(
absl::GetFlag(FLAGS_transmission_offset_id))); absl::GetFlag(FLAGS_transmission_offset_id)));
RTC_CHECK(ValidateInputFilenameNotEmpty(absl::GetFlag(FLAGS_input_file))); RTC_CHECK(ValidateInputFilenameNotEmpty(absl::GetFlag(FLAGS_input_file)));
RTC_CHECK_GE(absl::GetFlag(FLAGS_extend_run_time_duration), 0);
rtc::ThreadManager::Instance()->WrapCurrentThread(); rtc::ThreadManager::Instance()->WrapCurrentThread();
webrtc::test::RunTest(webrtc::RtpReplay); webrtc::test::RunTest(webrtc::RtpReplay);