Index: webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc b/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
index 332a0f81f9e098f30b16168a630a8336fc1e9296..dcae547b1c42cf364ba6dca31ab337cf1ecce972 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_sender_unittest.cc |
@@ -90,9 +90,7 @@ class LoopbackTransportTest : public webrtc::Transport { |
sent_packets_.push_back(buffer); |
return true; |
} |
- bool SendRtcp(const uint8_t* data, size_t len) override { |
- return false; |
- } |
+ bool SendRtcp(const uint8_t* data, size_t len) override { return false; } |
int packets_sent_; |
size_t last_sent_packet_len_; |
size_t total_bytes_sent_; |
@@ -163,11 +161,8 @@ class RtpSenderTest : public ::testing::Test { |
void SendPacket(int64_t capture_time_ms, int payload_length) { |
uint32_t timestamp = capture_time_ms * 90; |
- int32_t rtp_length = rtp_sender_->BuildRTPheader(packet_, |
- kPayload, |
- kMarkerBit, |
- timestamp, |
- capture_time_ms); |
+ int32_t rtp_length = rtp_sender_->BuildRTPheader( |
+ packet_, kPayload, kMarkerBit, timestamp, capture_time_ms); |
ASSERT_GE(rtp_length, 0); |
// Packet should be stored in a send bucket. |
@@ -186,7 +181,7 @@ class RtpSenderTestWithoutPacer : public RtpSenderTest { |
class RtpSenderVideoTest : public RtpSenderTest { |
protected: |
- virtual void SetUp() override { |
+ void SetUp() override { |
// TODO(pbos): Set up to use pacer. |
SetUpRtpSender(false); |
rtp_sender_video_.reset( |
@@ -228,53 +223,57 @@ TEST_F(RtpSenderTestWithoutPacer, |
RegisterRtpTransmissionTimeOffsetHeaderExtension) { |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
EXPECT_EQ(kRtpOneByteHeaderLength + kTransmissionTimeOffsetLength, |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset)); |
+ kRtpExtensionTransmissionTimeOffset)); |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
} |
TEST_F(RtpSenderTestWithoutPacer, RegisterRtpAbsoluteSendTimeHeaderExtension) { |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
EXPECT_EQ(RtpUtility::Word32Align(kRtpOneByteHeaderLength + |
kAbsoluteSendTimeLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime)); |
+ kRtpExtensionAbsoluteSendTime)); |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
} |
TEST_F(RtpSenderTestWithoutPacer, RegisterRtpAudioLevelHeaderExtension) { |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel, kAudioLevelExtensionId)); |
+ EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAudioLevel, |
+ kAudioLevelExtensionId)); |
EXPECT_EQ( |
RtpUtility::Word32Align(kRtpOneByteHeaderLength + kAudioLevelLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel)); |
+ EXPECT_EQ(0, |
+ rtp_sender_->DeregisterRtpHeaderExtension(kRtpExtensionAudioLevel)); |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
} |
TEST_F(RtpSenderTestWithoutPacer, RegisterRtpHeaderExtensions) { |
EXPECT_EQ(0u, rtp_sender_->RtpHeaderExtensionTotalLength()); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
EXPECT_EQ(RtpUtility::Word32Align(kRtpOneByteHeaderLength + |
kTransmissionTimeOffsetLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
EXPECT_EQ(RtpUtility::Word32Align(kRtpOneByteHeaderLength + |
kTransmissionTimeOffsetLength + |
kAbsoluteSendTimeLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel, kAudioLevelExtensionId)); |
+ EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAudioLevel, |
+ kAudioLevelExtensionId)); |
EXPECT_EQ(RtpUtility::Word32Align( |
kRtpOneByteHeaderLength + kTransmissionTimeOffsetLength + |
kAbsoluteSendTimeLength + kAudioLevelLength), |
@@ -290,18 +289,18 @@ TEST_F(RtpSenderTestWithoutPacer, RegisterRtpHeaderExtensions) { |
// Deregister starts. |
EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset)); |
+ kRtpExtensionTransmissionTimeOffset)); |
EXPECT_EQ(RtpUtility::Word32Align(kRtpOneByteHeaderLength + |
kAbsoluteSendTimeLength + |
kAudioLevelLength + kVideoRotationLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime)); |
+ kRtpExtensionAbsoluteSendTime)); |
EXPECT_EQ(RtpUtility::Word32Align(kRtpOneByteHeaderLength + |
kAudioLevelLength + kVideoRotationLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
- EXPECT_EQ(0, rtp_sender_->DeregisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel)); |
+ EXPECT_EQ(0, |
+ rtp_sender_->DeregisterRtpHeaderExtension(kRtpExtensionAudioLevel)); |
EXPECT_EQ( |
RtpUtility::Word32Align(kRtpOneByteHeaderLength + kVideoRotationLength), |
rtp_sender_->RtpHeaderExtensionTotalLength()); |
@@ -354,7 +353,8 @@ TEST_F(RtpSenderTestWithoutPacer, |
BuildRTPPacketWithTransmissionOffsetExtension) { |
EXPECT_EQ(0, rtp_sender_->SetTransmissionTimeOffset(kTimeOffset)); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
size_t length = static_cast<size_t>(rtp_sender_->BuildRTPheader( |
packet_, kPayload, kMarkerBit, kTimestamp, 0)); |
@@ -393,7 +393,8 @@ TEST_F(RtpSenderTestWithoutPacer, |
const int kNegTimeOffset = -500; |
EXPECT_EQ(0, rtp_sender_->SetTransmissionTimeOffset(kNegTimeOffset)); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
size_t length = static_cast<size_t>(rtp_sender_->BuildRTPheader( |
packet_, kPayload, kMarkerBit, kTimestamp, 0)); |
@@ -419,8 +420,9 @@ TEST_F(RtpSenderTestWithoutPacer, |
TEST_F(RtpSenderTestWithoutPacer, BuildRTPPacketWithAbsoluteSendTimeExtension) { |
EXPECT_EQ(0, rtp_sender_->SetAbsoluteSendTime(kAbsoluteSendTime)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
size_t length = static_cast<size_t>(rtp_sender_->BuildRTPheader( |
packet_, kPayload, kMarkerBit, kTimestamp, 0)); |
@@ -508,8 +510,8 @@ TEST_F(RtpSenderTestWithoutPacer, |
} |
TEST_F(RtpSenderTestWithoutPacer, BuildRTPPacketWithAudioLevelExtension) { |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel, kAudioLevelExtensionId)); |
+ EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAudioLevel, |
+ kAudioLevelExtensionId)); |
size_t length = static_cast<size_t>(rtp_sender_->BuildRTPheader( |
packet_, kPayload, kMarkerBit, kTimestamp, 0)); |
@@ -554,11 +556,13 @@ TEST_F(RtpSenderTestWithoutPacer, BuildRTPPacketWithHeaderExtensions) { |
EXPECT_EQ(0, |
rtp_sender_->SetTransportSequenceNumber(kTransportSequenceNumber)); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel, kAudioLevelExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAudioLevel, |
+ kAudioLevelExtensionId)); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
kRtpExtensionTransportSequenceNumber, |
kTransportSequenceNumberExtensionId)); |
@@ -626,9 +630,11 @@ TEST_F(RtpSenderTest, TrafficSmoothingWithExtensions) { |
rtp_sender_->SetStorePacketsStatus(true, 10); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
rtp_sender_->SetTargetBitrate(300000); |
int64_t capture_time_ms = fake_clock_.TimeInMilliseconds(); |
int rtp_length_int = rtp_sender_->BuildRTPheader( |
@@ -676,9 +682,11 @@ TEST_F(RtpSenderTest, TrafficSmoothingRetransmits) { |
rtp_sender_->SetStorePacketsStatus(true, 10); |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
rtp_sender_->SetTargetBitrate(300000); |
int64_t capture_time_ms = fake_clock_.TimeInMilliseconds(); |
int rtp_length_int = rtp_sender_->BuildRTPheader( |
@@ -740,10 +748,12 @@ TEST_F(RtpSenderTest, SendPadding) { |
rtp_sender_->SetStorePacketsStatus(true, 10); |
size_t rtp_header_len = kRtpHeaderSize; |
EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionTransmissionTimeOffset, kTransmissionTimeOffsetExtensionId)); |
+ kRtpExtensionTransmissionTimeOffset, |
+ kTransmissionTimeOffsetExtensionId)); |
rtp_header_len += 4; // 4 bytes extension. |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
rtp_header_len += 4; // 4 bytes extension. |
rtp_header_len += 4; // 4 extra bytes common to all extension headers. |
@@ -815,8 +825,8 @@ TEST_F(RtpSenderTest, SendPadding) { |
// Send a regular video packet again. |
capture_time_ms = fake_clock_.TimeInMilliseconds(); |
- rtp_length_int = rtp_sender_->BuildRTPheader( |
- packet_, kPayload, kMarkerBit, timestamp, capture_time_ms); |
+ rtp_length_int = rtp_sender_->BuildRTPheader(packet_, kPayload, kMarkerBit, |
+ timestamp, capture_time_ms); |
ASSERT_NE(-1, rtp_length_int); |
rtp_length = static_cast<size_t>(rtp_length_int); |
@@ -830,8 +840,8 @@ TEST_F(RtpSenderTest, SendPadding) { |
EXPECT_EQ(++total_packets_sent, transport_.packets_sent_); |
EXPECT_EQ(rtp_length, transport_.last_sent_packet_len_); |
// Parse sent packet. |
- ASSERT_TRUE(rtp_parser->Parse(transport_.last_sent_packet_, rtp_length, |
- &rtp_header)); |
+ ASSERT_TRUE( |
+ rtp_parser->Parse(transport_.last_sent_packet_, rtp_length, &rtp_header)); |
// Verify sequence number and timestamp. |
EXPECT_EQ(seq_num, rtp_header.sequenceNumber); |
@@ -858,8 +868,9 @@ TEST_F(RtpSenderTest, SendRedundantPayloads) { |
uint16_t seq_num = kSeqNum; |
rtp_sender_->SetStorePacketsStatus(true, 10); |
int32_t rtp_header_len = kRtpHeaderSize; |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAbsoluteSendTime, kAbsoluteSendTimeExtensionId)); |
+ EXPECT_EQ( |
+ 0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAbsoluteSendTime, |
+ kAbsoluteSendTimeExtensionId)); |
rtp_header_len += 4; // 4 bytes extension. |
rtp_header_len += 4; // 4 extra bytes common to all extension headers. |
@@ -876,8 +887,8 @@ TEST_F(RtpSenderTest, SendRedundantPayloads) { |
kAbsoluteSendTimeExtensionId); |
rtp_sender_->SetTargetBitrate(300000); |
const size_t kNumPayloadSizes = 10; |
- const size_t kPayloadSizes[kNumPayloadSizes] = {500, 550, 600, 650, 700, 750, |
- 800, 850, 900, 950}; |
+ const size_t kPayloadSizes[kNumPayloadSizes] = {500, 550, 600, 650, 700, |
+ 750, 800, 850, 900, 950}; |
// Send 10 packets of increasing size. |
for (size_t i = 0; i < kNumPayloadSizes; ++i) { |
int64_t capture_time_ms = fake_clock_.TimeInMilliseconds(); |
@@ -923,8 +934,8 @@ TEST_F(RtpSenderTestWithoutPacer, SendGenericVideo) { |
webrtc::RTPHeader rtp_header; |
ASSERT_TRUE(rtp_parser.Parse(rtp_header)); |
- const uint8_t* payload_data = GetPayloadData(rtp_header, |
- transport_.last_sent_packet_); |
+ const uint8_t* payload_data = |
+ GetPayloadData(rtp_header, transport_.last_sent_packet_); |
uint8_t generic_header = *payload_data++; |
ASSERT_EQ(sizeof(payload) + sizeof(generic_header), |
@@ -1043,9 +1054,8 @@ TEST_F(RtpSenderTest, BitrateCallbacks) { |
char payload_name[RTP_PAYLOAD_NAME_SIZE] = "GENERIC"; |
const uint8_t payload_type = 127; |
- ASSERT_EQ( |
- 0, |
- rtp_sender_->RegisterPayload(payload_name, payload_type, 90000, 0, 1500)); |
+ ASSERT_EQ(0, rtp_sender_->RegisterPayload(payload_name, payload_type, 90000, |
+ 0, 1500)); |
uint8_t payload[] = {47, 11, 32, 93, 89}; |
rtp_sender_->SetStorePacketsStatus(true, 1); |
uint32_t ssrc = rtp_sender_->SSRC(); |
@@ -1057,13 +1067,8 @@ TEST_F(RtpSenderTest, BitrateCallbacks) { |
// Send a few frames. |
for (uint32_t i = 0; i < kNumPackets; ++i) { |
ASSERT_EQ(0, |
- rtp_sender_->SendOutgoingData(kVideoFrameKey, |
- payload_type, |
- 1234, |
- 4321, |
- payload, |
- sizeof(payload), |
- 0)); |
+ rtp_sender_->SendOutgoingData(kVideoFrameKey, payload_type, 1234, |
+ 4321, payload, sizeof(payload), 0)); |
fake_clock_.AdvanceTimeMilliseconds(kPacketInterval); |
} |
@@ -1100,8 +1105,7 @@ class RtpSenderAudioTest : public RtpSenderTest { |
TEST_F(RtpSenderTestWithoutPacer, StreamDataCountersCallbacks) { |
class TestCallback : public StreamDataCountersCallback { |
public: |
- TestCallback() |
- : StreamDataCountersCallback(), ssrc_(0), counters_() {} |
+ TestCallback() : StreamDataCountersCallback(), ssrc_(0), counters_() {} |
virtual ~TestCallback() {} |
void DataCountersUpdated(const StreamDataCounters& counters, |
@@ -1127,7 +1131,6 @@ TEST_F(RtpSenderTestWithoutPacer, StreamDataCountersCallbacks) { |
MatchPacketCounter(counters.retransmitted, counters_.retransmitted); |
EXPECT_EQ(counters.fec.packets, counters_.fec.packets); |
} |
- |
} callback; |
const uint8_t kRedPayloadType = 96; |
@@ -1214,8 +1217,8 @@ TEST_F(RtpSenderAudioTest, SendAudio) { |
webrtc::RTPHeader rtp_header; |
ASSERT_TRUE(rtp_parser.Parse(rtp_header)); |
- const uint8_t* payload_data = GetPayloadData(rtp_header, |
- transport_.last_sent_packet_); |
+ const uint8_t* payload_data = |
+ GetPayloadData(rtp_header, transport_.last_sent_packet_); |
ASSERT_EQ(sizeof(payload), |
GetPayloadDataLength(rtp_header, transport_.last_sent_packet_len_)); |
@@ -1225,8 +1228,8 @@ TEST_F(RtpSenderAudioTest, SendAudio) { |
TEST_F(RtpSenderAudioTest, SendAudioWithAudioLevelExtension) { |
EXPECT_EQ(0, rtp_sender_->SetAudioLevel(kAudioLevel)); |
- EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension( |
- kRtpExtensionAudioLevel, kAudioLevelExtensionId)); |
+ EXPECT_EQ(0, rtp_sender_->RegisterRtpHeaderExtension(kRtpExtensionAudioLevel, |
+ kAudioLevelExtensionId)); |
char payload_name[RTP_PAYLOAD_NAME_SIZE] = "PAYLOAD_NAME"; |
const uint8_t payload_type = 127; |
@@ -1243,19 +1246,20 @@ TEST_F(RtpSenderAudioTest, SendAudioWithAudioLevelExtension) { |
webrtc::RTPHeader rtp_header; |
ASSERT_TRUE(rtp_parser.Parse(rtp_header)); |
- const uint8_t* payload_data = GetPayloadData(rtp_header, |
- transport_.last_sent_packet_); |
+ const uint8_t* payload_data = |
+ GetPayloadData(rtp_header, transport_.last_sent_packet_); |
ASSERT_EQ(sizeof(payload), |
GetPayloadDataLength(rtp_header, transport_.last_sent_packet_len_)); |
EXPECT_EQ(0, memcmp(payload, payload_data, sizeof(payload))); |
- uint8_t extension[] = { 0xbe, 0xde, 0x00, 0x01, |
- (kAudioLevelExtensionId << 4) + 0, // ID + length. |
- kAudioLevel, // Data. |
- 0x00, 0x00 // Padding. |
- }; |
+ uint8_t extension[] = { |
+ 0xbe, 0xde, 0x00, 0x01, |
+ (kAudioLevelExtensionId << 4) + 0, // ID + length. |
+ kAudioLevel, // Data. |
+ 0x00, 0x00 // Padding. |
+ }; |
EXPECT_EQ(0, memcmp(extension, payload_data - sizeof(extension), |
sizeof(extension))); |
@@ -1270,14 +1274,14 @@ TEST_F(RtpSenderAudioTest, SendAudioWithAudioLevelExtension) { |
TEST_F(RtpSenderAudioTest, CheckMarkerBitForTelephoneEvents) { |
char payload_name[RTP_PAYLOAD_NAME_SIZE] = "telephone-event"; |
uint8_t payload_type = 126; |
- ASSERT_EQ(0, rtp_sender_->RegisterPayload(payload_name, payload_type, 0, |
- 0, 0)); |
+ ASSERT_EQ(0, |
+ rtp_sender_->RegisterPayload(payload_name, payload_type, 0, 0, 0)); |
// For Telephone events, payload is not added to the registered payload list, |
// it will register only the payload used for audio stream. |
// Registering the payload again for audio stream with different payload name. |
strcpy(payload_name, "payload_name"); |
- ASSERT_EQ(0, rtp_sender_->RegisterPayload(payload_name, payload_type, 8000, |
- 1, 0)); |
+ ASSERT_EQ( |
+ 0, rtp_sender_->RegisterPayload(payload_name, payload_type, 8000, 1, 0)); |
int64_t capture_time_ms = fake_clock_.TimeInMilliseconds(); |
// DTMF event key=9, duration=500 and attenuationdB=10 |
rtp_sender_->SendTelephoneEvent(9, 500, 10); |
@@ -1298,8 +1302,7 @@ TEST_F(RtpSenderAudioTest, CheckMarkerBitForTelephoneEvents) { |
ASSERT_TRUE(rtp_parser.get() != nullptr); |
webrtc::RTPHeader rtp_header; |
ASSERT_TRUE(rtp_parser->Parse(transport_.last_sent_packet_, |
- transport_.last_sent_packet_len_, |
- &rtp_header)); |
+ transport_.last_sent_packet_len_, &rtp_header)); |
// Marker Bit should be set to 1 for first packet. |
EXPECT_TRUE(rtp_header.markerBit); |
@@ -1307,8 +1310,7 @@ TEST_F(RtpSenderAudioTest, CheckMarkerBitForTelephoneEvents) { |
capture_time_ms + 4000, 0, nullptr, |
0, nullptr)); |
ASSERT_TRUE(rtp_parser->Parse(transport_.last_sent_packet_, |
- transport_.last_sent_packet_len_, |
- &rtp_header)); |
+ transport_.last_sent_packet_len_, &rtp_header)); |
// Marker Bit should be set to 0 for rest of the packets. |
EXPECT_FALSE(rtp_header.markerBit); |
} |
@@ -1321,19 +1323,13 @@ TEST_F(RtpSenderTestWithoutPacer, BytesReportedCorrectly) { |
rtp_sender_->SetRtxPayloadType(kPayloadType - 1, kPayloadType); |
rtp_sender_->SetRtxStatus(kRtxRetransmitted | kRtxRedundantPayloads); |
- ASSERT_EQ( |
- 0, |
- rtp_sender_->RegisterPayload(kPayloadName, kPayloadType, 90000, 0, 1500)); |
+ ASSERT_EQ(0, rtp_sender_->RegisterPayload(kPayloadName, kPayloadType, 90000, |
+ 0, 1500)); |
uint8_t payload[] = {47, 11, 32, 93, 89}; |
- ASSERT_EQ(0, |
- rtp_sender_->SendOutgoingData(kVideoFrameKey, |
- kPayloadType, |
- 1234, |
- 4321, |
- payload, |
- sizeof(payload), |
- 0)); |
+ ASSERT_EQ( |
+ 0, rtp_sender_->SendOutgoingData(kVideoFrameKey, kPayloadType, 1234, 4321, |
+ payload, sizeof(payload), 0)); |
// Will send 2 full-size padding packets. |
rtp_sender_->TimeToSendPadding(1); |
@@ -1353,17 +1349,17 @@ TEST_F(RtpSenderTestWithoutPacer, BytesReportedCorrectly) { |
EXPECT_EQ(rtx_stats.transmitted.padding_bytes, 2 * kMaxPaddingSize); |
EXPECT_EQ(rtp_stats.transmitted.TotalBytes(), |
- rtp_stats.transmitted.payload_bytes + |
- rtp_stats.transmitted.header_bytes + |
- rtp_stats.transmitted.padding_bytes); |
+ rtp_stats.transmitted.payload_bytes + |
+ rtp_stats.transmitted.header_bytes + |
+ rtp_stats.transmitted.padding_bytes); |
EXPECT_EQ(rtx_stats.transmitted.TotalBytes(), |
- rtx_stats.transmitted.payload_bytes + |
- rtx_stats.transmitted.header_bytes + |
- rtx_stats.transmitted.padding_bytes); |
+ rtx_stats.transmitted.payload_bytes + |
+ rtx_stats.transmitted.header_bytes + |
+ rtx_stats.transmitted.padding_bytes); |
- EXPECT_EQ(transport_.total_bytes_sent_, |
- rtp_stats.transmitted.TotalBytes() + |
- rtx_stats.transmitted.TotalBytes()); |
+ EXPECT_EQ( |
+ transport_.total_bytes_sent_, |
+ rtp_stats.transmitted.TotalBytes() + rtx_stats.transmitted.TotalBytes()); |
} |
TEST_F(RtpSenderTestWithoutPacer, RespectsNackBitrateLimit) { |