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 123a8fe7bd10541340366ecae43b263f30c79aa1..a3d0341994f89ae7ae6e2bd0a0598f5aca50885e 100644 |
--- a/media/cast/logging/encoding_event_subscriber_unittest.cc |
+++ b/media/cast/logging/encoding_event_subscriber_unittest.cc |
@@ -37,8 +37,7 @@ class EncodingEventSubscriberTest : public ::testing::Test { |
scoped_ptr<base::TickClock>(testing_clock_).Pass(), |
task_runner_, |
task_runner_, |
- task_runner_)), |
- first_rtp_timestamp_(0) {} |
+ task_runner_)) {} |
void Init(EventMediaType event_media_type) { |
DCHECK(!event_subscriber_); |
@@ -54,7 +53,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. |
@@ -64,7 +64,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) { |
@@ -80,14 +80,15 @@ 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(capture_begin_event.Pass()); |
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 = 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(capture_end_event.Pass()); |
@@ -96,7 +97,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(decoded_event.Pass()); |
@@ -130,7 +131,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; |
@@ -149,7 +150,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; |
@@ -186,7 +187,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; |
@@ -199,12 +200,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)); |
@@ -221,7 +222,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; |
@@ -236,12 +237,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)); |
@@ -256,7 +257,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; |
@@ -279,12 +280,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)); |
@@ -302,8 +303,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)); |
Irfan
2015/12/09 21:24:28
Should we add an explicit constructor so we can do
miu
2015/12/10 00:38:36
No. I explicitly want to avoid this since it woul
|
+ 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; |
@@ -341,12 +342,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)); |
@@ -358,12 +359,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)); |
@@ -379,7 +380,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()); |
@@ -397,12 +398,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); |
@@ -421,7 +422,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()); |
@@ -452,12 +453,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); |
@@ -475,7 +476,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; |
@@ -507,12 +508,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); |
@@ -535,8 +536,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; |
@@ -568,12 +569,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); |
@@ -584,12 +585,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); |
@@ -601,9 +602,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()); |
@@ -617,7 +618,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(capture_end_event.Pass()); |
@@ -635,7 +637,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; |
@@ -649,9 +651,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()); |
@@ -661,12 +663,13 @@ TEST_F(EncodingEventSubscriberTest, RelativeRtpTimestampWrapAround) { |
capture_begin_event->rtp_timestamp = rtp_timestamp; |
cast_environment_->logger()->DispatchFrameEvent(capture_begin_event.Pass()); |
- // 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(capture_end_event.Pass()); |
@@ -686,7 +689,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(); |