Google Git
Sign in
webrtc / src / a4d873786f10eedd72de25ad0d94ad7c53c1f68a / . / logging / rtc_event_log / rtc_event_log_unittest_helper.cc
blob: 830230536df2f28e6712cba74dd25872ed74d118 [file] [log] [blame]
/*
* Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
*
* Use of this source code is governed by a BSD-style license
* that can be found in the LICENSE file in the root of the source
* tree. An additional intellectual property rights grant can be found
* in the file PATENTS. All contributing project authors may
* be found in the AUTHORS file in the root of the source tree.
*/
#include "logging/rtc_event_log/rtc_event_log_unittest_helper.h"
#include <string.h> // memcmp
#include <cmath>
#include <cstdint>
#include <limits>
#include <memory>
#include <numeric>
#include <string>
#include <utility>
#include <vector>
#include "absl/memory/memory.h"
#include "absl/types/optional.h"
#include "api/array_view.h"
#include "api/rtp_headers.h"
#include "api/rtp_parameters.h"
#include "modules/audio_coding/audio_network_adaptor/include/audio_network_adaptor_config.h"
#include "modules/remote_bitrate_estimator/include/bwe_defines.h"
#include "modules/rtp_rtcp/include/rtp_cvo.h"
#include "modules/rtp_rtcp/include/rtp_rtcp_defines.h"
#include "modules/rtp_rtcp/source/rtcp_packet/dlrr.h"
#include "modules/rtp_rtcp/source/rtcp_packet/rrtr.h"
#include "modules/rtp_rtcp/source/rtcp_packet/target_bitrate.h"
#include "modules/rtp_rtcp/source/rtp_header_extensions.h"
#include "modules/rtp_rtcp/source/rtp_packet_received.h"
#include "modules/rtp_rtcp/source/rtp_packet_to_send.h"
#include "rtc_base/buffer.h"
#include "rtc_base/checks.h"
#include "system_wrappers/include/ntp_time.h"
#include "test/gtest.h"
namespace webrtc {
namespace test {
namespace {
struct ExtensionPair {
RTPExtensionType type;
const char* name;
};
constexpr int kMaxCsrcs = 3;
// Maximum serialized size of a header extension, including 1 byte ID.
constexpr int kMaxExtensionSizeBytes = 4;
constexpr int kMaxNumExtensions = 5;
constexpr ExtensionPair kExtensions[kMaxNumExtensions] = {
{RTPExtensionType::kRtpExtensionTransmissionTimeOffset,
RtpExtension::kTimestampOffsetUri},
{RTPExtensionType::kRtpExtensionAbsoluteSendTime,
RtpExtension::kAbsSendTimeUri},
{RTPExtensionType::kRtpExtensionTransportSequenceNumber,
RtpExtension::kTransportSequenceNumberUri},
{RTPExtensionType::kRtpExtensionAudioLevel, RtpExtension::kAudioLevelUri},
{RTPExtensionType::kRtpExtensionVideoRotation,
RtpExtension::kVideoRotationUri}};
template <typename T>
void ShuffleInPlace(Random* prng, rtc::ArrayView<T> array) {
RTC_DCHECK_LE(array.size(), std::numeric_limits<uint32_t>::max());
for (uint32_t i = 0; i + 1 < array.size(); i++) {
uint32_t other = prng->Rand(i, static_cast<uint32_t>(array.size() - 1));
std::swap(array[i], array[other]);
}
}
absl::optional<int> GetExtensionId(const std::vector<RtpExtension>& extensions,
const std::string& uri) {
for (const auto& extension : extensions) {
if (extension.uri == uri)
return extension.id;
}
return absl::nullopt;
}
} // namespace
std::unique_ptr<RtcEventAlrState> EventGenerator::NewAlrState() {
return absl::make_unique<RtcEventAlrState>(prng_.Rand<bool>());
}
std::unique_ptr<RtcEventAudioPlayout> EventGenerator::NewAudioPlayout(
uint32_t ssrc) {
return absl::make_unique<RtcEventAudioPlayout>(ssrc);
}
std::unique_ptr<RtcEventAudioNetworkAdaptation>
EventGenerator::NewAudioNetworkAdaptation() {
std::unique_ptr<AudioEncoderRuntimeConfig> config =
absl::make_unique<AudioEncoderRuntimeConfig>();
config->bitrate_bps = prng_.Rand(0, 3000000);
config->enable_fec = prng_.Rand<bool>();
config->enable_dtx = prng_.Rand<bool>();
config->frame_length_ms = prng_.Rand(10, 120);
config->num_channels = prng_.Rand(1, 2);
config->uplink_packet_loss_fraction = prng_.Rand<float>();
return absl::make_unique<RtcEventAudioNetworkAdaptation>(std::move(config));
}
std::unique_ptr<RtcEventBweUpdateDelayBased>
EventGenerator::NewBweUpdateDelayBased() {
constexpr int32_t kMaxBweBps = 20000000;
int32_t bitrate_bps = prng_.Rand(0, kMaxBweBps);
BandwidthUsage state = static_cast<BandwidthUsage>(
prng_.Rand(static_cast<uint32_t>(BandwidthUsage::kLast) - 1));
return absl::make_unique<RtcEventBweUpdateDelayBased>(bitrate_bps, state);
}
std::unique_ptr<RtcEventBweUpdateLossBased>
EventGenerator::NewBweUpdateLossBased() {
constexpr int32_t kMaxBweBps = 20000000;
constexpr int32_t kMaxPackets = 1000;
int32_t bitrate_bps = prng_.Rand(0, kMaxBweBps);
uint8_t fraction_lost = prng_.Rand<uint8_t>();
int32_t total_packets = prng_.Rand(1, kMaxPackets);
return absl::make_unique<RtcEventBweUpdateLossBased>(
bitrate_bps, fraction_lost, total_packets);
}
std::unique_ptr<RtcEventDtlsTransportState>
EventGenerator::NewDtlsTransportState() {
DtlsTransportState state = static_cast<DtlsTransportState>(
prng_.Rand(static_cast<uint32_t>(DtlsTransportState::kNumValues) - 1));
return absl::make_unique<RtcEventDtlsTransportState>(state);
}
std::unique_ptr<RtcEventDtlsWritableState>
EventGenerator::NewDtlsWritableState() {
bool writable = prng_.Rand<bool>();
return absl::make_unique<RtcEventDtlsWritableState>(writable);
}
std::unique_ptr<RtcEventProbeClusterCreated>
EventGenerator::NewProbeClusterCreated() {
constexpr int kMaxBweBps = 20000000;
constexpr int kMaxNumProbes = 10000;
int id = prng_.Rand(1, kMaxNumProbes);
int bitrate_bps = prng_.Rand(0, kMaxBweBps);
int min_probes = prng_.Rand(5, 50);
int min_bytes = prng_.Rand(500, 50000);
return absl::make_unique<RtcEventProbeClusterCreated>(id, bitrate_bps,
min_probes, min_bytes);
}
std::unique_ptr<RtcEventProbeResultFailure>
EventGenerator::NewProbeResultFailure() {
constexpr int kMaxNumProbes = 10000;
int id = prng_.Rand(1, kMaxNumProbes);
ProbeFailureReason reason = static_cast<ProbeFailureReason>(
prng_.Rand(static_cast<uint32_t>(ProbeFailureReason::kLast) - 1));
return absl::make_unique<RtcEventProbeResultFailure>(id, reason);
}
std::unique_ptr<RtcEventProbeResultSuccess>
EventGenerator::NewProbeResultSuccess() {
constexpr int kMaxBweBps = 20000000;
constexpr int kMaxNumProbes = 10000;
int id = prng_.Rand(1, kMaxNumProbes);
int bitrate_bps = prng_.Rand(0, kMaxBweBps);
return absl::make_unique<RtcEventProbeResultSuccess>(id, bitrate_bps);
}
std::unique_ptr<RtcEventIceCandidatePairConfig>
EventGenerator::NewIceCandidatePairConfig() {
IceCandidateType local_candidate_type = static_cast<IceCandidateType>(
prng_.Rand(static_cast<uint32_t>(IceCandidateType::kNumValues) - 1));
IceCandidateNetworkType local_network_type =
static_cast<IceCandidateNetworkType>(prng_.Rand(
static_cast<uint32_t>(IceCandidateNetworkType::kNumValues) - 1));
IceCandidatePairAddressFamily local_address_family =
static_cast<IceCandidatePairAddressFamily>(prng_.Rand(
static_cast<uint32_t>(IceCandidatePairAddressFamily::kNumValues) -
1));
IceCandidateType remote_candidate_type = static_cast<IceCandidateType>(
prng_.Rand(static_cast<uint32_t>(IceCandidateType::kNumValues) - 1));
IceCandidatePairAddressFamily remote_address_family =
static_cast<IceCandidatePairAddressFamily>(prng_.Rand(
static_cast<uint32_t>(IceCandidatePairAddressFamily::kNumValues) -
1));
IceCandidatePairProtocol protocol_type =
static_cast<IceCandidatePairProtocol>(prng_.Rand(
static_cast<uint32_t>(IceCandidatePairProtocol::kNumValues) - 1));
IceCandidatePairDescription desc;
desc.local_candidate_type = local_candidate_type;
desc.local_relay_protocol = protocol_type;
desc.local_network_type = local_network_type;
desc.local_address_family = local_address_family;
desc.remote_candidate_type = remote_candidate_type;
desc.remote_address_family = remote_address_family;
desc.candidate_pair_protocol = protocol_type;
IceCandidatePairConfigType type =
static_cast<IceCandidatePairConfigType>(prng_.Rand(
static_cast<uint32_t>(IceCandidatePairConfigType::kNumValues) - 1));
uint32_t pair_id = prng_.Rand<uint32_t>();
return absl::make_unique<RtcEventIceCandidatePairConfig>(type, pair_id, desc);
}
std::unique_ptr<RtcEventIceCandidatePair>
EventGenerator::NewIceCandidatePair() {
IceCandidatePairEventType type =
static_cast<IceCandidatePairEventType>(prng_.Rand(
static_cast<uint32_t>(IceCandidatePairEventType::kNumValues) - 1));
uint32_t pair_id = prng_.Rand<uint32_t>();
uint32_t transaction_id = prng_.Rand<uint32_t>();
return absl::make_unique<RtcEventIceCandidatePair>(type, pair_id,
transaction_id);
}
rtcp::ReportBlock EventGenerator::NewReportBlock() {
rtcp::ReportBlock report_block;
report_block.SetMediaSsrc(prng_.Rand<uint32_t>());
report_block.SetFractionLost(prng_.Rand<uint8_t>());
// cumulative_lost is a 3-byte signed value.
RTC_DCHECK(report_block.SetCumulativeLost(
prng_.Rand(-(1 << 23) + 1, (1 << 23) - 1)));
report_block.SetExtHighestSeqNum(prng_.Rand<uint32_t>());
report_block.SetJitter(prng_.Rand<uint32_t>());
report_block.SetLastSr(prng_.Rand<uint32_t>());
report_block.SetDelayLastSr(prng_.Rand<uint32_t>());
return report_block;
}
rtcp::SenderReport EventGenerator::NewSenderReport() {
rtcp::SenderReport sender_report;
sender_report.SetSenderSsrc(prng_.Rand<uint32_t>());
sender_report.SetNtp(NtpTime(prng_.Rand<uint32_t>(), prng_.Rand<uint32_t>()));
sender_report.SetRtpTimestamp(prng_.Rand<uint32_t>());
sender_report.SetPacketCount(prng_.Rand<uint32_t>());
sender_report.SetOctetCount(prng_.Rand<uint32_t>());
sender_report.AddReportBlock(NewReportBlock());
return sender_report;
}
rtcp::ReceiverReport EventGenerator::NewReceiverReport() {
rtcp::ReceiverReport receiver_report;
receiver_report.SetSenderSsrc(prng_.Rand<uint32_t>());
receiver_report.AddReportBlock(NewReportBlock());
return receiver_report;
}
rtcp::ExtendedReports EventGenerator::NewExtendedReports() {
rtcp::ExtendedReports extended_report;
extended_report.SetSenderSsrc(prng_.Rand<uint32_t>());
rtcp::Rrtr rrtr;
rrtr.SetNtp(NtpTime(prng_.Rand<uint32_t>(), prng_.Rand<uint32_t>()));
extended_report.SetRrtr(rrtr);
rtcp::ReceiveTimeInfo time_info(
prng_.Rand<uint32_t>(), prng_.Rand<uint32_t>(), prng_.Rand<uint32_t>());
extended_report.AddDlrrItem(time_info);
rtcp::TargetBitrate target_bitrate;
target_bitrate.AddTargetBitrate(/*spatial layer*/ prng_.Rand(0, 3),
/*temporal layer*/ prng_.Rand(0, 3),
/*bitrate kbps*/ prng_.Rand(0, 50000));
target_bitrate.AddTargetBitrate(/*spatial layer*/ prng_.Rand(4, 7),
/*temporal layer*/ prng_.Rand(4, 7),
/*bitrate kbps*/ prng_.Rand(0, 50000));
extended_report.SetTargetBitrate(target_bitrate);
return extended_report;
}
rtcp::Nack EventGenerator::NewNack() {
rtcp::Nack nack;
uint16_t base_seq_no = prng_.Rand<uint16_t>();
std::vector<uint16_t> nack_list;
nack_list.push_back(base_seq_no);
for (uint16_t i = 1u; i < 10u; i++) {
if (prng_.Rand<bool>())
nack_list.push_back(base_seq_no + i);
}
nack.SetPacketIds(nack_list);
return nack;
}
rtcp::Fir EventGenerator::NewFir() {
rtcp::Fir fir;
fir.SetSenderSsrc(prng_.Rand<uint32_t>());
fir.AddRequestTo(/*ssrc*/ prng_.Rand<uint32_t>(),
/*seq num*/ prng_.Rand<uint8_t>());
fir.AddRequestTo(/*ssrc*/ prng_.Rand<uint32_t>(),
/*seq num*/ prng_.Rand<uint8_t>());
return fir;
}
rtcp::Pli EventGenerator::NewPli() {
rtcp::Pli pli;
pli.SetSenderSsrc(prng_.Rand<uint32_t>());
pli.SetMediaSsrc(prng_.Rand<uint32_t>());
return pli;
}
rtcp::TransportFeedback EventGenerator::NewTransportFeedback() {
rtcp::TransportFeedback transport_feedback;
uint16_t base_seq_no = prng_.Rand<uint16_t>();
int64_t base_time_us = prng_.Rand<uint32_t>();
transport_feedback.SetBase(base_seq_no, base_time_us);
int64_t time_us = base_time_us;
for (uint16_t i = 1u; i < 10u; i++) {
time_us += prng_.Rand(0, 100000);
if (prng_.Rand<bool>()) {
transport_feedback.AddReceivedPacket(base_seq_no + i, time_us);
}
}
return transport_feedback;
}
rtcp::Remb EventGenerator::NewRemb() {
rtcp::Remb remb;
// The remb bitrate is transported as a 16-bit mantissa and an 8-bit exponent.
uint64_t bitrate_bps = prng_.Rand(0, (1 << 16) - 1) << prng_.Rand(7);
std::vector<uint32_t> ssrcs{prng_.Rand<uint32_t>(), prng_.Rand<uint32_t>()};
remb.SetSsrcs(ssrcs);
remb.SetBitrateBps(bitrate_bps);
return remb;
}
rtcp::LossNotification EventGenerator::NewLossNotification() {
rtcp::LossNotification loss_notification;
const uint16_t last_decoded = prng_.Rand<uint16_t>();
const uint16_t last_received =
last_decoded + (prng_.Rand<uint16_t>() & 0x7fff);
const bool decodability_flag = prng_.Rand<bool>();
EXPECT_TRUE(
loss_notification.Set(last_decoded, last_received, decodability_flag));
return loss_notification;
}
std::unique_ptr<RtcEventRouteChange> EventGenerator::NewRouteChange() {
return absl::make_unique<RtcEventRouteChange>(prng_.Rand<bool>(),
prng_.Rand(0, 128));
}
std::unique_ptr<RtcEventRtcpPacketIncoming>
EventGenerator::NewRtcpPacketIncoming() {
enum class SupportedRtcpTypes {
kSenderReport = 0,
kReceiverReport,
kExtendedReports,
kFir,
kPli,
kNack,
kRemb,
kTransportFeedback,
kNumValues
};
SupportedRtcpTypes type = static_cast<SupportedRtcpTypes>(
prng_.Rand(0, static_cast<int>(SupportedRtcpTypes::kNumValues) - 1));
switch (type) {
case SupportedRtcpTypes::kSenderReport: {
rtcp::SenderReport sender_report = NewSenderReport();
rtc::Buffer buffer = sender_report.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kReceiverReport: {
rtcp::ReceiverReport receiver_report = NewReceiverReport();
rtc::Buffer buffer = receiver_report.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kExtendedReports: {
rtcp::ExtendedReports extended_report = NewExtendedReports();
rtc::Buffer buffer = extended_report.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kFir: {
rtcp::Fir fir = NewFir();
rtc::Buffer buffer = fir.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kPli: {
rtcp::Pli pli = NewPli();
rtc::Buffer buffer = pli.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kNack: {
rtcp::Nack nack = NewNack();
rtc::Buffer buffer = nack.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kRemb: {
rtcp::Remb remb = NewRemb();
rtc::Buffer buffer = remb.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
case SupportedRtcpTypes::kTransportFeedback: {
rtcp::TransportFeedback transport_feedback = NewTransportFeedback();
rtc::Buffer buffer = transport_feedback.Build();
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
default:
RTC_NOTREACHED();
rtc::Buffer buffer;
return absl::make_unique<RtcEventRtcpPacketIncoming>(buffer);
}
}
std::unique_ptr<RtcEventRtcpPacketOutgoing>
EventGenerator::NewRtcpPacketOutgoing() {
enum class SupportedRtcpTypes {
kSenderReport = 0,
kReceiverReport,
kExtendedReports,
kFir,
kPli,
kNack,
kRemb,
kTransportFeedback,
kNumValues
};
SupportedRtcpTypes type = static_cast<SupportedRtcpTypes>(
prng_.Rand(0, static_cast<int>(SupportedRtcpTypes::kNumValues) - 1));
switch (type) {
case SupportedRtcpTypes::kSenderReport: {
rtcp::SenderReport sender_report = NewSenderReport();
rtc::Buffer buffer = sender_report.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kReceiverReport: {
rtcp::ReceiverReport receiver_report = NewReceiverReport();
rtc::Buffer buffer = receiver_report.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kExtendedReports: {
rtcp::ExtendedReports extended_report = NewExtendedReports();
rtc::Buffer buffer = extended_report.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kFir: {
rtcp::Fir fir = NewFir();
rtc::Buffer buffer = fir.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kPli: {
rtcp::Pli pli = NewPli();
rtc::Buffer buffer = pli.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kNack: {
rtcp::Nack nack = NewNack();
rtc::Buffer buffer = nack.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kRemb: {
rtcp::Remb remb = NewRemb();
rtc::Buffer buffer = remb.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
case SupportedRtcpTypes::kTransportFeedback: {
rtcp::TransportFeedback transport_feedback = NewTransportFeedback();
rtc::Buffer buffer = transport_feedback.Build();
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
default:
RTC_NOTREACHED();
rtc::Buffer buffer;
return absl::make_unique<RtcEventRtcpPacketOutgoing>(buffer);
}
}
std::unique_ptr<RtcEventGenericPacketSent>
EventGenerator::NewGenericPacketSent() {
return absl::make_unique<RtcEventGenericPacketSent>(
sent_packet_number_++, prng_.Rand(40, 50), prng_.Rand(0, 150),
prng_.Rand(0, 1000));
}
std::unique_ptr<RtcEventGenericPacketReceived>
EventGenerator::NewGenericPacketReceived() {
return absl::make_unique<RtcEventGenericPacketReceived>(
received_packet_number_++, prng_.Rand(40, 250));
}
std::unique_ptr<RtcEventGenericAckReceived>
EventGenerator::NewGenericAckReceived() {
absl::optional<int64_t> receive_timestamp = absl::nullopt;
if (prng_.Rand(0, 2) > 0) {
receive_timestamp = prng_.Rand(0, 100000);
}
AckedPacket packet = {prng_.Rand(40, 250), receive_timestamp};
return std::move(RtcEventGenericAckReceived::CreateLogs(
received_packet_number_++, std::vector<AckedPacket>{packet})[0]);
}
void EventGenerator::RandomizeRtpPacket(
size_t payload_size,
size_t padding_size,
uint32_t ssrc,
const RtpHeaderExtensionMap& extension_map,
RtpPacket* rtp_packet,
bool all_configured_exts) {
constexpr int kMaxPayloadType = 127;
rtp_packet->SetPayloadType(prng_.Rand(kMaxPayloadType));
rtp_packet->SetMarker(prng_.Rand<bool>());
rtp_packet->SetSequenceNumber(prng_.Rand<uint16_t>());
rtp_packet->SetSsrc(ssrc);
rtp_packet->SetTimestamp(prng_.Rand<uint32_t>());
uint32_t csrcs_count = prng_.Rand(0, kMaxCsrcs);
std::vector<uint32_t> csrcs;
for (size_t i = 0; i < csrcs_count; i++) {
csrcs.push_back(prng_.Rand<uint32_t>());
}
rtp_packet->SetCsrcs(csrcs);
if (extension_map.IsRegistered(TransmissionOffset::kId) &&
(all_configured_exts || prng_.Rand<bool>())) {
rtp_packet->SetExtension<TransmissionOffset>(prng_.Rand(0x00ffffff));
}
if (extension_map.IsRegistered(AudioLevel::kId) &&
(all_configured_exts || prng_.Rand<bool>())) {
rtp_packet->SetExtension<AudioLevel>(prng_.Rand<bool>(), prng_.Rand(127));
}
if (extension_map.IsRegistered(AbsoluteSendTime::kId) &&
(all_configured_exts || prng_.Rand<bool>())) {
rtp_packet->SetExtension<AbsoluteSendTime>(prng_.Rand(0x00ffffff));
}
if (extension_map.IsRegistered(VideoOrientation::kId) &&
(all_configured_exts || prng_.Rand<bool>())) {
rtp_packet->SetExtension<VideoOrientation>(prng_.Rand(3));
}
if (extension_map.IsRegistered(TransportSequenceNumber::kId) &&
(all_configured_exts || prng_.Rand<bool>())) {
rtp_packet->SetExtension<TransportSequenceNumber>(prng_.Rand<uint16_t>());
}
RTC_CHECK_LE(rtp_packet->headers_size() + payload_size, IP_PACKET_SIZE);
uint8_t* payload = rtp_packet->AllocatePayload(payload_size);
RTC_DCHECK(payload != nullptr);
for (size_t i = 0; i < payload_size; i++) {
payload[i] = prng_.Rand<uint8_t>();
}
RTC_CHECK(rtp_packet->SetPadding(padding_size));
}
std::unique_ptr<RtcEventRtpPacketIncoming> EventGenerator::NewRtpPacketIncoming(
uint32_t ssrc,
const RtpHeaderExtensionMap& extension_map,
bool all_configured_exts) {
constexpr size_t kMaxPaddingLength = 224;
const bool padding = prng_.Rand(0, 9) == 0; // Let padding be 10% probable.
const size_t padding_size = !padding ? 0u : prng_.Rand(0u, kMaxPaddingLength);
// 12 bytes RTP header, 4 bytes for 0xBEDE + alignment, 4 bytes per CSRC.
constexpr size_t kMaxHeaderSize =
16 + 4 * kMaxCsrcs + kMaxExtensionSizeBytes * kMaxNumExtensions;
// In principle, a packet can contain both padding and other payload.
// Currently, RTC eventlog encoder-parser can only maintain padding length if
// packet is full padding.
// TODO(webrtc:9730): Remove the deterministic logic for padding_size > 0.
size_t payload_size =
padding_size > 0 ? 0
: prng_.Rand(0u, static_cast<uint32_t>(IP_PACKET_SIZE -
1 - padding_size -
kMaxHeaderSize));
RtpPacketReceived rtp_packet(&extension_map);
RandomizeRtpPacket(payload_size, padding_size, ssrc, extension_map,
&rtp_packet, all_configured_exts);
return absl::make_unique<RtcEventRtpPacketIncoming>(rtp_packet);
}
std::unique_ptr<RtcEventRtpPacketOutgoing> EventGenerator::NewRtpPacketOutgoing(
uint32_t ssrc,
const RtpHeaderExtensionMap& extension_map,
bool all_configured_exts) {
constexpr size_t kMaxPaddingLength = 224;
const bool padding = prng_.Rand(0, 9) == 0; // Let padding be 10% probable.
const size_t padding_size = !padding ? 0u : prng_.Rand(0u, kMaxPaddingLength);
// 12 bytes RTP header, 4 bytes for 0xBEDE + alignment, 4 bytes per CSRC.
constexpr size_t kMaxHeaderSize =
16 + 4 * kMaxCsrcs + kMaxExtensionSizeBytes * kMaxNumExtensions;
// In principle,a packet can contain both padding and other payload.
// Currently, RTC eventlog encoder-parser can only maintain padding length if
// packet is full padding.
// TODO(webrtc:9730): Remove the deterministic logic for padding_size > 0.
size_t payload_size =
padding_size > 0 ? 0
: prng_.Rand(0u, static_cast<uint32_t>(IP_PACKET_SIZE -
1 - padding_size -
kMaxHeaderSize));
RtpPacketToSend rtp_packet(&extension_map,
kMaxHeaderSize + payload_size + padding_size);
RandomizeRtpPacket(payload_size, padding_size, ssrc, extension_map,
&rtp_packet, all_configured_exts);
int probe_cluster_id = prng_.Rand(0, 100000);
return absl::make_unique<RtcEventRtpPacketOutgoing>(rtp_packet,
probe_cluster_id);
}
RtpHeaderExtensionMap EventGenerator::NewRtpHeaderExtensionMap(
bool configure_all) {
RtpHeaderExtensionMap extension_map;
std::vector<int> id(RtpExtension::kOneByteHeaderExtensionMaxId -
RtpExtension::kMinId + 1);
std::iota(id.begin(), id.end(), RtpExtension::kMinId);
ShuffleInPlace(&prng_, rtc::ArrayView<int>(id));
if (configure_all || prng_.Rand<bool>()) {
extension_map.Register<AudioLevel>(id[0]);
}
if (configure_all || prng_.Rand<bool>()) {
extension_map.Register<TransmissionOffset>(id[1]);
}
if (configure_all || prng_.Rand<bool>()) {
extension_map.Register<AbsoluteSendTime>(id[2]);
}
if (configure_all || prng_.Rand<bool>()) {
extension_map.Register<VideoOrientation>(id[3]);
}
if (configure_all || prng_.Rand<bool>()) {
extension_map.Register<TransportSequenceNumber>(id[4]);
}
return extension_map;
}
std::unique_ptr<RtcEventAudioReceiveStreamConfig>
EventGenerator::NewAudioReceiveStreamConfig(
uint32_t ssrc,
const RtpHeaderExtensionMap& extensions) {
auto config = absl::make_unique<rtclog::StreamConfig>();
// Add SSRCs for the stream.
config->remote_ssrc = ssrc;
config->local_ssrc = prng_.Rand<uint32_t>();
// Add header extensions.
for (size_t i = 0; i < kMaxNumExtensions; i++) {
uint8_t id = extensions.GetId(kExtensions[i].type);
if (id != RtpHeaderExtensionMap::kInvalidId) {
config->rtp_extensions.emplace_back(kExtensions[i].name, id);
}
}
return absl::make_unique<RtcEventAudioReceiveStreamConfig>(std::move(config));
}
std::unique_ptr<RtcEventAudioSendStreamConfig>
EventGenerator::NewAudioSendStreamConfig(
uint32_t ssrc,
const RtpHeaderExtensionMap& extensions) {
auto config = absl::make_unique<rtclog::StreamConfig>();
// Add SSRC to the stream.
config->local_ssrc = ssrc;
// Add header extensions.
for (size_t i = 0; i < kMaxNumExtensions; i++) {
uint8_t id = extensions.GetId(kExtensions[i].type);
if (id != RtpHeaderExtensionMap::kInvalidId) {
config->rtp_extensions.emplace_back(kExtensions[i].name, id);
}
}
return absl::make_unique<RtcEventAudioSendStreamConfig>(std::move(config));
}
std::unique_ptr<RtcEventVideoReceiveStreamConfig>
EventGenerator::NewVideoReceiveStreamConfig(
uint32_t ssrc,
const RtpHeaderExtensionMap& extensions) {
auto config = absl::make_unique<rtclog::StreamConfig>();
// Add SSRCs for the stream.
config->remote_ssrc = ssrc;
config->local_ssrc = prng_.Rand<uint32_t>();
// Add extensions and settings for RTCP.
config->rtcp_mode =
prng_.Rand<bool>() ? RtcpMode::kCompound : RtcpMode::kReducedSize;
config->remb = prng_.Rand<bool>();
config->rtx_ssrc = prng_.Rand<uint32_t>();
config->codecs.emplace_back(prng_.Rand<bool>() ? "VP8" : "H264",
prng_.Rand(127), prng_.Rand(127));
// Add header extensions.
for (size_t i = 0; i < kMaxNumExtensions; i++) {
uint8_t id = extensions.GetId(kExtensions[i].type);
if (id != RtpHeaderExtensionMap::kInvalidId) {
config->rtp_extensions.emplace_back(kExtensions[i].name, id);
}
}
return absl::make_unique<RtcEventVideoReceiveStreamConfig>(std::move(config));
}
std::unique_ptr<RtcEventVideoSendStreamConfig>
EventGenerator::NewVideoSendStreamConfig(
uint32_t ssrc,
const RtpHeaderExtensionMap& extensions) {
auto config = absl::make_unique<rtclog::StreamConfig>();
config->codecs.emplace_back(prng_.Rand<bool>() ? "VP8" : "H264",
prng_.Rand(127), prng_.Rand(127));
config->local_ssrc = ssrc;
config->rtx_ssrc = prng_.Rand<uint32_t>();
// Add header extensions.
for (size_t i = 0; i < kMaxNumExtensions; i++) {
uint8_t id = extensions.GetId(kExtensions[i].type);
if (id != RtpHeaderExtensionMap::kInvalidId) {
config->rtp_extensions.emplace_back(kExtensions[i].name, id);
}
}
return absl::make_unique<RtcEventVideoSendStreamConfig>(std::move(config));
}
void EventVerifier::VerifyLoggedAlrStateEvent(
const RtcEventAlrState& original_event,
const LoggedAlrStateEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.in_alr(), logged_event.in_alr);
}
void EventVerifier::VerifyLoggedAudioPlayoutEvent(
const RtcEventAudioPlayout& original_event,
const LoggedAudioPlayoutEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.ssrc(), logged_event.ssrc);
}
void EventVerifier::VerifyLoggedAudioNetworkAdaptationEvent(
const RtcEventAudioNetworkAdaptation& original_event,
const LoggedAudioNetworkAdaptationEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.config().bitrate_bps,
logged_event.config.bitrate_bps);
EXPECT_EQ(original_event.config().enable_dtx, logged_event.config.enable_dtx);
EXPECT_EQ(original_event.config().enable_fec, logged_event.config.enable_fec);
EXPECT_EQ(original_event.config().frame_length_ms,
logged_event.config.frame_length_ms);
EXPECT_EQ(original_event.config().num_channels,
logged_event.config.num_channels);
// uplink_packet_loss_fraction
ASSERT_EQ(original_event.config().uplink_packet_loss_fraction.has_value(),
logged_event.config.uplink_packet_loss_fraction.has_value());
if (original_event.config().uplink_packet_loss_fraction.has_value()) {
const float original =
original_event.config().uplink_packet_loss_fraction.value();
const float logged =
logged_event.config.uplink_packet_loss_fraction.value();
const float uplink_packet_loss_fraction_delta = std::abs(original - logged);
EXPECT_LE(uplink_packet_loss_fraction_delta, 0.0001f);
}
}
void EventVerifier::VerifyLoggedBweDelayBasedUpdate(
const RtcEventBweUpdateDelayBased& original_event,
const LoggedBweDelayBasedUpdate& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.bitrate_bps(), logged_event.bitrate_bps);
EXPECT_EQ(original_event.detector_state(), logged_event.detector_state);
}
void EventVerifier::VerifyLoggedBweLossBasedUpdate(
const RtcEventBweUpdateLossBased& original_event,
const LoggedBweLossBasedUpdate& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.bitrate_bps(), logged_event.bitrate_bps);
EXPECT_EQ(original_event.fraction_loss(), logged_event.fraction_lost);
EXPECT_EQ(original_event.total_packets(), logged_event.expected_packets);
}
void EventVerifier::VerifyLoggedBweProbeClusterCreatedEvent(
const RtcEventProbeClusterCreated& original_event,
const LoggedBweProbeClusterCreatedEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.id(), logged_event.id);
EXPECT_EQ(original_event.bitrate_bps(), logged_event.bitrate_bps);
EXPECT_EQ(original_event.min_probes(), logged_event.min_packets);
EXPECT_EQ(original_event.min_bytes(), logged_event.min_bytes);
}
void EventVerifier::VerifyLoggedBweProbeFailureEvent(
const RtcEventProbeResultFailure& original_event,
const LoggedBweProbeFailureEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.id(), logged_event.id);
EXPECT_EQ(original_event.failure_reason(), logged_event.failure_reason);
}
void EventVerifier::VerifyLoggedBweProbeSuccessEvent(
const RtcEventProbeResultSuccess& original_event,
const LoggedBweProbeSuccessEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.id(), logged_event.id);
EXPECT_EQ(original_event.bitrate_bps(), logged_event.bitrate_bps);
}
void EventVerifier::VerifyLoggedDtlsTransportState(
const RtcEventDtlsTransportState& original_event,
const LoggedDtlsTransportState& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.dtls_transport_state(),
logged_event.dtls_transport_state);
}
void EventVerifier::VerifyLoggedDtlsWritableState(
const RtcEventDtlsWritableState& original_event,
const LoggedDtlsWritableState& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.writable(), logged_event.writable);
}
void EventVerifier::VerifyLoggedIceCandidatePairConfig(
const RtcEventIceCandidatePairConfig& original_event,
const LoggedIceCandidatePairConfig& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.type(), logged_event.type);
EXPECT_EQ(original_event.candidate_pair_id(), logged_event.candidate_pair_id);
EXPECT_EQ(original_event.candidate_pair_desc().local_candidate_type,
logged_event.local_candidate_type);
EXPECT_EQ(original_event.candidate_pair_desc().local_relay_protocol,
logged_event.local_relay_protocol);
EXPECT_EQ(original_event.candidate_pair_desc().local_network_type,
logged_event.local_network_type);
EXPECT_EQ(original_event.candidate_pair_desc().local_address_family,
logged_event.local_address_family);
EXPECT_EQ(original_event.candidate_pair_desc().remote_candidate_type,
logged_event.remote_candidate_type);
EXPECT_EQ(original_event.candidate_pair_desc().remote_address_family,
logged_event.remote_address_family);
EXPECT_EQ(original_event.candidate_pair_desc().candidate_pair_protocol,
logged_event.candidate_pair_protocol);
}
void EventVerifier::VerifyLoggedIceCandidatePairEvent(
const RtcEventIceCandidatePair& original_event,
const LoggedIceCandidatePairEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.type(), logged_event.type);
EXPECT_EQ(original_event.candidate_pair_id(), logged_event.candidate_pair_id);
if (encoding_type_ == RtcEventLog::EncodingType::NewFormat) {
EXPECT_EQ(original_event.transaction_id(), logged_event.transaction_id);
}
}
void VerifyLoggedRtpHeader(const RtpPacket& original_header,
const RTPHeader& logged_header) {
// Standard RTP header.
EXPECT_EQ(original_header.Marker(), logged_header.markerBit);
EXPECT_EQ(original_header.PayloadType(), logged_header.payloadType);
EXPECT_EQ(original_header.SequenceNumber(), logged_header.sequenceNumber);
EXPECT_EQ(original_header.Timestamp(), logged_header.timestamp);
EXPECT_EQ(original_header.Ssrc(), logged_header.ssrc);
EXPECT_EQ(original_header.headers_size(), logged_header.headerLength);
// TransmissionOffset header extension.
ASSERT_EQ(original_header.HasExtension<TransmissionOffset>(),
logged_header.extension.hasTransmissionTimeOffset);
if (logged_header.extension.hasTransmissionTimeOffset) {
int32_t offset;
ASSERT_TRUE(original_header.GetExtension<TransmissionOffset>(&offset));
EXPECT_EQ(offset, logged_header.extension.transmissionTimeOffset);
}
// AbsoluteSendTime header extension.
ASSERT_EQ(original_header.HasExtension<AbsoluteSendTime>(),
logged_header.extension.hasAbsoluteSendTime);
if (logged_header.extension.hasAbsoluteSendTime) {
uint32_t sendtime;
ASSERT_TRUE(original_header.GetExtension<AbsoluteSendTime>(&sendtime));
EXPECT_EQ(sendtime, logged_header.extension.absoluteSendTime);
}
// TransportSequenceNumber header extension.
ASSERT_EQ(original_header.HasExtension<TransportSequenceNumber>(),
logged_header.extension.hasTransportSequenceNumber);
if (logged_header.extension.hasTransportSequenceNumber) {
uint16_t seqnum;
ASSERT_TRUE(original_header.GetExtension<TransportSequenceNumber>(&seqnum));
EXPECT_EQ(seqnum, logged_header.extension.transportSequenceNumber);
}
// AudioLevel header extension.
ASSERT_EQ(original_header.HasExtension<AudioLevel>(),
logged_header.extension.hasAudioLevel);
if (logged_header.extension.hasAudioLevel) {
bool voice_activity;
uint8_t audio_level;
ASSERT_TRUE(original_header.GetExtension<AudioLevel>(&voice_activity,
&audio_level));
EXPECT_EQ(voice_activity, logged_header.extension.voiceActivity);
EXPECT_EQ(audio_level, logged_header.extension.audioLevel);
}
// VideoOrientation header extension.
ASSERT_EQ(original_header.HasExtension<VideoOrientation>(),
logged_header.extension.hasVideoRotation);
if (logged_header.extension.hasVideoRotation) {
uint8_t rotation;
ASSERT_TRUE(original_header.GetExtension<VideoOrientation>(&rotation));
EXPECT_EQ(ConvertCVOByteToVideoRotation(rotation),
logged_header.extension.videoRotation);
}
}
void EventVerifier::VerifyLoggedRouteChangeEvent(
const RtcEventRouteChange& original_event,
const LoggedRouteChangeEvent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.connected(), logged_event.connected);
EXPECT_EQ(original_event.overhead(), logged_event.overhead);
}
void EventVerifier::VerifyLoggedRtpPacketIncoming(
const RtcEventRtpPacketIncoming& original_event,
const LoggedRtpPacketIncoming& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.header().headers_size(),
logged_event.rtp.header_length);
EXPECT_EQ(original_event.packet_length(), logged_event.rtp.total_length);
// Currently, RTC eventlog encoder-parser can only maintain padding length
// if packet is full padding.
EXPECT_EQ(original_event.padding_length(),
logged_event.rtp.header.paddingLength);
VerifyLoggedRtpHeader(original_event.header(), logged_event.rtp.header);
}
void EventVerifier::VerifyLoggedRtpPacketOutgoing(
const RtcEventRtpPacketOutgoing& original_event,
const LoggedRtpPacketOutgoing& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.header().headers_size(),
logged_event.rtp.header_length);
EXPECT_EQ(original_event.packet_length(), logged_event.rtp.total_length);
// Currently, RTC eventlog encoder-parser can only maintain padding length
// if packet is full padding.
EXPECT_EQ(original_event.padding_length(),
logged_event.rtp.header.paddingLength);
// TODO(terelius): Probe cluster ID isn't parsed, used or tested. Unless
// someone has a strong reason to keep it, it'll be removed.
VerifyLoggedRtpHeader(original_event.header(), logged_event.rtp.header);
}
void EventVerifier::VerifyLoggedGenericPacketSent(
const RtcEventGenericPacketSent& original_event,
const LoggedGenericPacketSent& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.packet_number(), logged_event.packet_number);
EXPECT_EQ(original_event.overhead_length(), logged_event.overhead_length);
EXPECT_EQ(original_event.payload_length(), logged_event.payload_length);
EXPECT_EQ(original_event.padding_length(), logged_event.padding_length);
}
void EventVerifier::VerifyLoggedGenericPacketReceived(
const RtcEventGenericPacketReceived& original_event,
const LoggedGenericPacketReceived& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.packet_number(), logged_event.packet_number);
EXPECT_EQ(static_cast<int>(original_event.packet_length()),
logged_event.packet_length);
}
void EventVerifier::VerifyLoggedGenericAckReceived(
const RtcEventGenericAckReceived& original_event,
const LoggedGenericAckReceived& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
EXPECT_EQ(original_event.packet_number(), logged_event.packet_number);
EXPECT_EQ(original_event.acked_packet_number(),
logged_event.acked_packet_number);
EXPECT_EQ(original_event.receive_acked_packet_time_ms(),
logged_event.receive_acked_packet_time_ms);
}
void EventVerifier::VerifyLoggedRtcpPacketIncoming(
const RtcEventRtcpPacketIncoming& original_event,
const LoggedRtcpPacketIncoming& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
ASSERT_EQ(original_event.packet().size(), logged_event.rtcp.raw_data.size());
EXPECT_EQ(
memcmp(original_event.packet().data(), logged_event.rtcp.raw_data.data(),
original_event.packet().size()),
0);
}
void EventVerifier::VerifyLoggedRtcpPacketOutgoing(
const RtcEventRtcpPacketOutgoing& original_event,
const LoggedRtcpPacketOutgoing& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
ASSERT_EQ(original_event.packet().size(), logged_event.rtcp.raw_data.size());
EXPECT_EQ(
memcmp(original_event.packet().data(), logged_event.rtcp.raw_data.data(),
original_event.packet().size()),
0);
}
void EventVerifier::VerifyReportBlock(
const rtcp::ReportBlock& original_report_block,
const rtcp::ReportBlock& logged_report_block) {
EXPECT_EQ(original_report_block.source_ssrc(),
logged_report_block.source_ssrc());
EXPECT_EQ(original_report_block.fraction_lost(),
logged_report_block.fraction_lost());
EXPECT_EQ(original_report_block.cumulative_lost_signed(),
logged_report_block.cumulative_lost_signed());
EXPECT_EQ(original_report_block.extended_high_seq_num(),
logged_report_block.extended_high_seq_num());
EXPECT_EQ(original_report_block.jitter(), logged_report_block.jitter());
EXPECT_EQ(original_report_block.last_sr(), logged_report_block.last_sr());
EXPECT_EQ(original_report_block.delay_since_last_sr(),
logged_report_block.delay_since_last_sr());
}
void EventVerifier::VerifyLoggedSenderReport(
int64_t log_time_us,
const rtcp::SenderReport& original_sr,
const LoggedRtcpPacketSenderReport& logged_sr) {
EXPECT_EQ(log_time_us, logged_sr.log_time_us());
EXPECT_EQ(original_sr.sender_ssrc(), logged_sr.sr.sender_ssrc());
EXPECT_EQ(original_sr.ntp(), logged_sr.sr.ntp());
EXPECT_EQ(original_sr.rtp_timestamp(), logged_sr.sr.rtp_timestamp());
EXPECT_EQ(original_sr.sender_packet_count(),
logged_sr.sr.sender_packet_count());
EXPECT_EQ(original_sr.sender_octet_count(),
logged_sr.sr.sender_octet_count());
ASSERT_EQ(original_sr.report_blocks().size(),
logged_sr.sr.report_blocks().size());
for (size_t i = 0; i < original_sr.report_blocks().size(); i++) {
VerifyReportBlock(original_sr.report_blocks()[i],
logged_sr.sr.report_blocks()[i]);
}
}
void EventVerifier::VerifyLoggedReceiverReport(
int64_t log_time_us,
const rtcp::ReceiverReport& original_rr,
const LoggedRtcpPacketReceiverReport& logged_rr) {
EXPECT_EQ(log_time_us, logged_rr.log_time_us());
EXPECT_EQ(original_rr.sender_ssrc(), logged_rr.rr.sender_ssrc());
ASSERT_EQ(original_rr.report_blocks().size(),
logged_rr.rr.report_blocks().size());
for (size_t i = 0; i < original_rr.report_blocks().size(); i++) {
VerifyReportBlock(original_rr.report_blocks()[i],
logged_rr.rr.report_blocks()[i]);
}
}
void EventVerifier::VerifyLoggedExtendedReports(
int64_t log_time_us,
const rtcp::ExtendedReports& original_xr,
const LoggedRtcpPacketExtendedReports& logged_xr) {
EXPECT_EQ(original_xr.sender_ssrc(), logged_xr.xr.sender_ssrc());
EXPECT_EQ(original_xr.rrtr().has_value(), logged_xr.xr.rrtr().has_value());
if (original_xr.rrtr().has_value() && logged_xr.xr.rrtr().has_value()) {
EXPECT_EQ(original_xr.rrtr()->ntp(), logged_xr.xr.rrtr()->ntp());
}
const auto& original_subblocks = original_xr.dlrr().sub_blocks();
const auto& logged_subblocks = logged_xr.xr.dlrr().sub_blocks();
ASSERT_EQ(original_subblocks.size(), logged_subblocks.size());
for (size_t i = 0; i < original_subblocks.size(); i++) {
EXPECT_EQ(original_subblocks[i].ssrc, logged_subblocks[i].ssrc);
EXPECT_EQ(original_subblocks[i].last_rr, logged_subblocks[i].last_rr);
EXPECT_EQ(original_subblocks[i].delay_since_last_rr,
logged_subblocks[i].delay_since_last_rr);
}
EXPECT_EQ(original_xr.target_bitrate().has_value(),
logged_xr.xr.target_bitrate().has_value());
if (original_xr.target_bitrate().has_value() &&
logged_xr.xr.target_bitrate().has_value()) {
const auto& original_bitrates =
original_xr.target_bitrate()->GetTargetBitrates();
const auto& logged_bitrates =
logged_xr.xr.target_bitrate()->GetTargetBitrates();
ASSERT_EQ(original_bitrates.size(), logged_bitrates.size());
for (size_t i = 0; i < original_bitrates.size(); i++) {
EXPECT_EQ(original_bitrates[i].spatial_layer,
logged_bitrates[i].spatial_layer);
EXPECT_EQ(original_bitrates[i].temporal_layer,
logged_bitrates[i].temporal_layer);
EXPECT_EQ(original_bitrates[i].target_bitrate_kbps,
logged_bitrates[i].target_bitrate_kbps);
}
}
}
void EventVerifier::VerifyLoggedFir(int64_t log_time_us,
const rtcp::Fir& original_fir,
const LoggedRtcpPacketFir& logged_fir) {
EXPECT_EQ(original_fir.sender_ssrc(), logged_fir.fir.sender_ssrc());
const auto& original_requests = original_fir.requests();
const auto& logged_requests = logged_fir.fir.requests();
ASSERT_EQ(original_requests.size(), logged_requests.size());
for (size_t i = 0; i < original_requests.size(); i++) {
EXPECT_EQ(original_requests[i].ssrc, logged_requests[i].ssrc);
EXPECT_EQ(original_requests[i].seq_nr, logged_requests[i].seq_nr);
}
}
void EventVerifier::VerifyLoggedPli(int64_t log_time_us,
const rtcp::Pli& original_pli,
const LoggedRtcpPacketPli& logged_pli) {
EXPECT_EQ(original_pli.sender_ssrc(), logged_pli.pli.sender_ssrc());
EXPECT_EQ(original_pli.media_ssrc(), logged_pli.pli.media_ssrc());
}
void EventVerifier::VerifyLoggedNack(int64_t log_time_us,
const rtcp::Nack& original_nack,
const LoggedRtcpPacketNack& logged_nack) {
EXPECT_EQ(log_time_us, logged_nack.log_time_us());
EXPECT_EQ(original_nack.packet_ids(), logged_nack.nack.packet_ids());
}
void EventVerifier::VerifyLoggedTransportFeedback(
int64_t log_time_us,
const rtcp::TransportFeedback& original_transport_feedback,
const LoggedRtcpPacketTransportFeedback& logged_transport_feedback) {
EXPECT_EQ(log_time_us, logged_transport_feedback.log_time_us());
ASSERT_EQ(
original_transport_feedback.GetReceivedPackets().size(),
logged_transport_feedback.transport_feedback.GetReceivedPackets().size());
for (size_t i = 0;
i < original_transport_feedback.GetReceivedPackets().size(); i++) {
EXPECT_EQ(
original_transport_feedback.GetReceivedPackets()[i].sequence_number(),
logged_transport_feedback.transport_feedback.GetReceivedPackets()[i]
.sequence_number());
EXPECT_EQ(
original_transport_feedback.GetReceivedPackets()[i].delta_us(),
logged_transport_feedback.transport_feedback.GetReceivedPackets()[i]
.delta_us());
}
}
void EventVerifier::VerifyLoggedRemb(int64_t log_time_us,
const rtcp::Remb& original_remb,
const LoggedRtcpPacketRemb& logged_remb) {
EXPECT_EQ(log_time_us, logged_remb.log_time_us());
EXPECT_EQ(original_remb.ssrcs(), logged_remb.remb.ssrcs());
EXPECT_EQ(original_remb.bitrate_bps(), logged_remb.remb.bitrate_bps());
}
void EventVerifier::VerifyLoggedLossNotification(
int64_t log_time_us,
const rtcp::LossNotification& original_loss_notification,
const LoggedRtcpPacketLossNotification& logged_loss_notification) {
EXPECT_EQ(log_time_us, logged_loss_notification.log_time_us());
EXPECT_EQ(original_loss_notification.last_decoded(),
logged_loss_notification.loss_notification.last_decoded());
EXPECT_EQ(original_loss_notification.last_received(),
logged_loss_notification.loss_notification.last_received());
EXPECT_EQ(original_loss_notification.decodability_flag(),
logged_loss_notification.loss_notification.decodability_flag());
}
void EventVerifier::VerifyLoggedStartEvent(
int64_t start_time_us,
int64_t utc_start_time_us,
const LoggedStartEvent& logged_event) const {
EXPECT_EQ(start_time_us / 1000, logged_event.log_time_ms());
if (encoding_type_ == RtcEventLog::EncodingType::NewFormat) {
EXPECT_EQ(utc_start_time_us / 1000, logged_event.utc_start_time_ms);
}
}
void EventVerifier::VerifyLoggedStopEvent(
int64_t stop_time_us,
const LoggedStopEvent& logged_event) const {
EXPECT_EQ(stop_time_us / 1000, logged_event.log_time_ms());
}
void VerifyLoggedStreamConfig(const rtclog::StreamConfig& original_config,
const rtclog::StreamConfig& logged_config) {
EXPECT_EQ(original_config.local_ssrc, logged_config.local_ssrc);
EXPECT_EQ(original_config.remote_ssrc, logged_config.remote_ssrc);
EXPECT_EQ(original_config.rtx_ssrc, logged_config.rtx_ssrc);
EXPECT_EQ(original_config.rtp_extensions.size(),
logged_config.rtp_extensions.size());
size_t recognized_extensions = 0;
for (size_t i = 0; i < kMaxNumExtensions; i++) {
auto original_id =
GetExtensionId(original_config.rtp_extensions, kExtensions[i].name);
auto logged_id =
GetExtensionId(logged_config.rtp_extensions, kExtensions[i].name);
EXPECT_EQ(original_id, logged_id)
<< "IDs for " << kExtensions[i].name << " don't match. Original ID "
<< original_id.value_or(-1) << ". Parsed ID " << logged_id.value_or(-1)
<< ".";
if (original_id) {
recognized_extensions++;
}
}
EXPECT_EQ(recognized_extensions, original_config.rtp_extensions.size());
}
void EventVerifier::VerifyLoggedAudioRecvConfig(
const RtcEventAudioReceiveStreamConfig& original_event,
const LoggedAudioRecvConfig& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
VerifyLoggedStreamConfig(original_event.config(), logged_event.config);
}
void EventVerifier::VerifyLoggedAudioSendConfig(
const RtcEventAudioSendStreamConfig& original_event,
const LoggedAudioSendConfig& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
VerifyLoggedStreamConfig(original_event.config(), logged_event.config);
}
void EventVerifier::VerifyLoggedVideoRecvConfig(
const RtcEventVideoReceiveStreamConfig& original_event,
const LoggedVideoRecvConfig& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
VerifyLoggedStreamConfig(original_event.config(), logged_event.config);
}
void EventVerifier::VerifyLoggedVideoSendConfig(
const RtcEventVideoSendStreamConfig& original_event,
const LoggedVideoSendConfig& logged_event) const {
EXPECT_EQ(original_event.timestamp_ms(), logged_event.log_time_ms());
VerifyLoggedStreamConfig(original_event.config(), logged_event.config);
}
} // namespace test
} // namespace webrtc