Index: media/cast/logging/encoding_event_subscriber_unittest.cc |
diff --git a/media/cast/logging/encoding_event_subscriber_unittest.cc b/media/cast/logging/encoding_event_subscriber_unittest.cc |
index 6d6dcb391e8784f05581ab86f518ebecb6a5f60f..6d711ff55860d618439370a76e21b44940e7c1c6 100644 |
--- a/media/cast/logging/encoding_event_subscriber_unittest.cc |
+++ b/media/cast/logging/encoding_event_subscriber_unittest.cc |
@@ -41,8 +41,7 @@ class EncodingEventSubscriberTest : public ::testing::Test { |
new CastEnvironment(scoped_ptr<base::TickClock>(testing_clock_), |
task_runner_, |
task_runner_, |
- task_runner_)), |
- first_rtp_timestamp_(0) {} |
+ task_runner_)) {} |
void Init(EventMediaType event_media_type) { |
DCHECK(!event_subscriber_); |
@@ -58,7 +57,8 @@ class EncodingEventSubscriberTest : public ::testing::Test { |
void GetEventsAndReset() { |
event_subscriber_->GetEventsAndReset( |
&metadata_, &frame_events_, &packet_events_); |
- first_rtp_timestamp_ = metadata_.first_rtp_timestamp(); |
+ first_rtp_timestamp_ = |
+ RtpTimeTicks().Expand(metadata_.first_rtp_timestamp()); |
} |
base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
@@ -68,7 +68,7 @@ class EncodingEventSubscriberTest : public ::testing::Test { |
FrameEventList frame_events_; |
PacketEventList packet_events_; |
LogMetadata metadata_; |
- RtpTimestamp first_rtp_timestamp_; |
+ RtpTimeTicks first_rtp_timestamp_; |
}; |
TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) { |
@@ -84,7 +84,8 @@ TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) { |
capture_begin_event->timestamp = now; |
capture_begin_event->type = FRAME_CAPTURE_BEGIN; |
capture_begin_event->media_type = VIDEO_EVENT; |
- capture_begin_event->rtp_timestamp = i * 100; |
+ capture_begin_event->rtp_timestamp = |
+ RtpTimeTicks().Expand<uint32_t>(i * 100); |
cast_environment_->logger()->DispatchFrameEvent( |
std::move(capture_begin_event)); |
@@ -92,7 +93,7 @@ TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) { |
capture_end_event->timestamp = now; |
capture_end_event->type = FRAME_CAPTURE_END; |
capture_end_event->media_type = VIDEO_EVENT; |
- capture_end_event->rtp_timestamp = i * 100; |
+ capture_end_event->rtp_timestamp = RtpTimeTicks().Expand<uint32_t>(i * 100); |
capture_end_event->width = width; |
capture_end_event->height = height; |
cast_environment_->logger()->DispatchFrameEvent( |
@@ -102,7 +103,7 @@ TEST_F(EncodingEventSubscriberTest, FrameEventTruncating) { |
decoded_event->timestamp = now; |
decoded_event->type = FRAME_DECODED; |
decoded_event->media_type = VIDEO_EVENT; |
- decoded_event->rtp_timestamp = i * 100; |
+ decoded_event->rtp_timestamp = RtpTimeTicks().Expand<uint32_t>(i * 100); |
decoded_event->frame_id = 0; |
cast_environment_->logger()->DispatchFrameEvent(std::move(decoded_event)); |
@@ -136,7 +137,7 @@ TEST_F(EncodingEventSubscriberTest, PacketEventTruncating) { |
receive_event->timestamp = now; |
receive_event->type = PACKET_RECEIVED; |
receive_event->media_type = AUDIO_EVENT; |
- receive_event->rtp_timestamp = i * 100; |
+ receive_event->rtp_timestamp = RtpTimeTicks().Expand<uint32_t>(i * 100); |
receive_event->frame_id = 0; |
receive_event->packet_id = i; |
receive_event->max_packet_id = 10; |
@@ -155,7 +156,7 @@ TEST_F(EncodingEventSubscriberTest, EventFiltering) { |
Init(VIDEO_EVENT); |
base::TimeTicks now(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
scoped_ptr<FrameEvent> video_event(new FrameEvent()); |
video_event->timestamp = now; |
video_event->type = FRAME_DECODED; |
@@ -192,7 +193,7 @@ TEST_F(EncodingEventSubscriberTest, EventFiltering) { |
TEST_F(EncodingEventSubscriberTest, FrameEvent) { |
Init(VIDEO_EVENT); |
base::TimeTicks now(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
scoped_ptr<FrameEvent> decode_event(new FrameEvent()); |
decode_event->timestamp = now; |
decode_event->type = FRAME_DECODED; |
@@ -205,12 +206,12 @@ TEST_F(EncodingEventSubscriberTest, FrameEvent) { |
ASSERT_EQ(1u, frame_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
FrameEventList::iterator it = frame_events_.begin(); |
linked_ptr<AggregatedFrameEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->event_type_size()); |
EXPECT_EQ(media::cast::proto::FRAME_DECODED, event->event_type(0)); |
@@ -227,7 +228,7 @@ TEST_F(EncodingEventSubscriberTest, FrameEvent) { |
TEST_F(EncodingEventSubscriberTest, FrameEventDelay) { |
Init(AUDIO_EVENT); |
base::TimeTicks now(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
int delay_ms = 100; |
scoped_ptr<FrameEvent> playout_event(new FrameEvent()); |
playout_event->timestamp = now; |
@@ -242,12 +243,12 @@ TEST_F(EncodingEventSubscriberTest, FrameEventDelay) { |
ASSERT_EQ(1u, frame_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
FrameEventList::iterator it = frame_events_.begin(); |
linked_ptr<AggregatedFrameEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->event_type_size()); |
EXPECT_EQ(media::cast::proto::FRAME_PLAYOUT, event->event_type(0)); |
@@ -262,7 +263,7 @@ TEST_F(EncodingEventSubscriberTest, FrameEventDelay) { |
TEST_F(EncodingEventSubscriberTest, FrameEventSize) { |
Init(VIDEO_EVENT); |
base::TimeTicks now(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
int size = 123; |
bool key_frame = true; |
int target_bitrate = 1024; |
@@ -285,12 +286,12 @@ TEST_F(EncodingEventSubscriberTest, FrameEventSize) { |
ASSERT_EQ(1u, frame_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
FrameEventList::iterator it = frame_events_.begin(); |
linked_ptr<AggregatedFrameEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->event_type_size()); |
EXPECT_EQ(media::cast::proto::FRAME_ENCODED, event->event_type(0)); |
@@ -308,8 +309,8 @@ TEST_F(EncodingEventSubscriberTest, FrameEventSize) { |
TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) { |
Init(AUDIO_EVENT); |
- RtpTimestamp rtp_timestamp1 = 100; |
- RtpTimestamp rtp_timestamp2 = 200; |
+ RtpTimeTicks rtp_timestamp1 = RtpTimeTicks().Expand(UINT32_C(100)); |
+ RtpTimeTicks rtp_timestamp2 = rtp_timestamp1.Expand(UINT32_C(200)); |
base::TimeTicks now1(testing_clock_->NowTicks()); |
scoped_ptr<FrameEvent> playout_event(new FrameEvent()); |
playout_event->timestamp = now1; |
@@ -347,12 +348,12 @@ TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) { |
ASSERT_EQ(2u, frame_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp1 - first_rtp_timestamp_; |
FrameEventList::iterator it = frame_events_.begin(); |
linked_ptr<AggregatedFrameEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp1 - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(2, event->event_type_size()); |
EXPECT_EQ(media::cast::proto::FRAME_PLAYOUT, event->event_type(0)); |
@@ -364,12 +365,12 @@ TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) { |
EXPECT_FALSE(event->has_key_frame()); |
- relative_rtp_timestamp = rtp_timestamp2 - first_rtp_timestamp_; |
++it; |
event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp2 - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->event_type_size()); |
EXPECT_EQ(media::cast::proto::FRAME_ENCODED, event->event_type(0)); |
@@ -385,7 +386,7 @@ TEST_F(EncodingEventSubscriberTest, MultipleFrameEvents) { |
TEST_F(EncodingEventSubscriberTest, PacketEvent) { |
Init(AUDIO_EVENT); |
base::TimeTicks now(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
int packet_id = 2; |
int size = 100; |
scoped_ptr<PacketEvent> receive_event(new PacketEvent()); |
@@ -403,12 +404,12 @@ TEST_F(EncodingEventSubscriberTest, PacketEvent) { |
ASSERT_EQ(1u, packet_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
PacketEventList::iterator it = packet_events_.begin(); |
linked_ptr<AggregatedPacketEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->base_packet_event_size()); |
const BasePacketEvent& base_event = event->base_packet_event(0); |
@@ -427,7 +428,7 @@ TEST_F(EncodingEventSubscriberTest, PacketEvent) { |
TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) { |
Init(VIDEO_EVENT); |
base::TimeTicks now1(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
int packet_id = 2; |
int size = 100; |
scoped_ptr<PacketEvent> send_event(new PacketEvent()); |
@@ -458,12 +459,12 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) { |
ASSERT_EQ(1u, packet_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
PacketEventList::iterator it = packet_events_.begin(); |
linked_ptr<AggregatedPacketEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->base_packet_event_size()); |
const BasePacketEvent& base_event = event->base_packet_event(0); |
@@ -481,7 +482,7 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForPacket) { |
TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForFrame) { |
Init(VIDEO_EVENT); |
base::TimeTicks now1(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
int packet_id_1 = 2; |
int packet_id_2 = 3; |
int size = 100; |
@@ -513,12 +514,12 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForFrame) { |
ASSERT_EQ(1u, packet_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp - first_rtp_timestamp_; |
PacketEventList::iterator it = packet_events_.begin(); |
linked_ptr<AggregatedPacketEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(2, event->base_packet_event_size()); |
const BasePacketEvent& base_event = event->base_packet_event(0); |
@@ -541,8 +542,8 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEventsForFrame) { |
TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) { |
Init(VIDEO_EVENT); |
base::TimeTicks now1(testing_clock_->NowTicks()); |
- RtpTimestamp rtp_timestamp_1 = 100; |
- RtpTimestamp rtp_timestamp_2 = 200; |
+ RtpTimeTicks rtp_timestamp_1 = RtpTimeTicks().Expand(UINT32_C(100)); |
+ RtpTimeTicks rtp_timestamp_2 = rtp_timestamp_1.Expand(UINT32_C(200)); |
int packet_id_1 = 2; |
int packet_id_2 = 3; |
int size = 100; |
@@ -574,12 +575,12 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) { |
ASSERT_EQ(2u, packet_events_.size()); |
- RtpTimestamp relative_rtp_timestamp = rtp_timestamp_1 - first_rtp_timestamp_; |
PacketEventList::iterator it = packet_events_.begin(); |
linked_ptr<AggregatedPacketEvent> event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp_1 - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->base_packet_event_size()); |
const BasePacketEvent& base_event = event->base_packet_event(0); |
@@ -590,12 +591,12 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) { |
ASSERT_EQ(1, base_event.event_timestamp_ms_size()); |
EXPECT_EQ(InMilliseconds(now1), base_event.event_timestamp_ms(0)); |
- relative_rtp_timestamp = rtp_timestamp_2 - first_rtp_timestamp_; |
++it; |
ASSERT_TRUE(it != packet_events_.end()); |
event = *it; |
- EXPECT_EQ(relative_rtp_timestamp, event->relative_rtp_timestamp()); |
+ EXPECT_EQ((rtp_timestamp_2 - first_rtp_timestamp_).lower_32_bits(), |
+ event->relative_rtp_timestamp()); |
ASSERT_EQ(1, event->base_packet_event_size()); |
const BasePacketEvent& base_event_2 = event->base_packet_event(0); |
@@ -607,9 +608,9 @@ TEST_F(EncodingEventSubscriberTest, MultiplePacketEvents) { |
EXPECT_EQ(InMilliseconds(now2), base_event_2.event_timestamp_ms(0)); |
} |
-TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { |
+TEST_F(EncodingEventSubscriberTest, FirstRtpTimeTicks) { |
Init(VIDEO_EVENT); |
- RtpTimestamp rtp_timestamp = 12345; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(12345)); |
base::TimeTicks now(testing_clock_->NowTicks()); |
scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); |
@@ -624,7 +625,8 @@ TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { |
capture_end_event->timestamp = now; |
capture_end_event->type = FRAME_CAPTURE_END; |
capture_end_event->media_type = VIDEO_EVENT; |
- capture_end_event->rtp_timestamp = rtp_timestamp + 30; |
+ capture_end_event->rtp_timestamp = |
+ rtp_timestamp + RtpTimeDelta::FromTicks(30); |
capture_end_event->width = 1280; |
capture_end_event->height = 720; |
cast_environment_->logger()->DispatchFrameEvent(std::move(capture_end_event)); |
@@ -642,7 +644,7 @@ TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { |
EXPECT_EQ(1280, (*it)->width()); |
EXPECT_EQ(720, (*it)->height()); |
- rtp_timestamp = 67890; |
+ rtp_timestamp = rtp_timestamp.Expand(UINT32_C(67890)); |
capture_begin_event.reset(new FrameEvent()); |
capture_begin_event->timestamp = now; |
@@ -657,9 +659,9 @@ TEST_F(EncodingEventSubscriberTest, FirstRtpTimestamp) { |
EXPECT_EQ(rtp_timestamp, first_rtp_timestamp_); |
} |
-TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { |
+TEST_F(EncodingEventSubscriberTest, RelativeRtpTimeTicksWrapAround) { |
Init(VIDEO_EVENT); |
- RtpTimestamp rtp_timestamp = 0xffffffff - 20; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks() - RtpTimeDelta::FromTicks(20); |
base::TimeTicks now(testing_clock_->NowTicks()); |
scoped_ptr<FrameEvent> capture_begin_event(new FrameEvent()); |
@@ -670,12 +672,13 @@ TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { |
cast_environment_->logger()->DispatchFrameEvent( |
std::move(capture_begin_event)); |
- // RtpTimestamp has now wrapped around. |
+ // RtpTimeTicks has now wrapped around. |
scoped_ptr<FrameEvent> capture_end_event(new FrameEvent()); |
capture_end_event->timestamp = now; |
capture_end_event->type = FRAME_CAPTURE_END; |
capture_end_event->media_type = VIDEO_EVENT; |
- capture_end_event->rtp_timestamp = rtp_timestamp + 30; |
+ capture_end_event->rtp_timestamp = |
+ rtp_timestamp + RtpTimeDelta::FromTicks(30); |
capture_end_event->width = 1280; |
capture_end_event->height = 720; |
cast_environment_->logger()->DispatchFrameEvent(std::move(capture_end_event)); |
@@ -695,7 +698,7 @@ TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { |
TEST_F(EncodingEventSubscriberTest, MaxEventsPerProto) { |
Init(VIDEO_EVENT); |
- RtpTimestamp rtp_timestamp = 100; |
+ RtpTimeTicks rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); |
for (int i = 0; i < kMaxEventsPerProto + 1; i++) { |
scoped_ptr<FrameEvent> ack_event(new FrameEvent()); |
ack_event->timestamp = testing_clock_->NowTicks(); |