Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(14)

Unified Diff: media/cast/logging/encoding_event_subscriber.cc

Issue 1515433002: Replace uses of raw uint32's with a type-checked RtpTimeTicks data type. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Speculative workaround fix for win8_chromium_ng compile error. Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: media/cast/logging/encoding_event_subscriber.cc
diff --git a/media/cast/logging/encoding_event_subscriber.cc b/media/cast/logging/encoding_event_subscriber.cc
index fa3310d274a919339b1bfdcca9654fb666b90fd3..27e9405d8050ebaa73e749e546ac5b7dec86a49f 100644
--- a/media/cast/logging/encoding_event_subscriber.cc
+++ b/media/cast/logging/encoding_event_subscriber.cc
@@ -51,12 +51,9 @@ namespace cast {
EncodingEventSubscriber::EncodingEventSubscriber(
EventMediaType event_media_type,
size_t max_frames)
- : event_media_type_(event_media_type),
- max_frames_(max_frames),
- frame_event_storage_index_(0),
- packet_event_storage_index_(0),
- seen_first_rtp_timestamp_(false),
- first_rtp_timestamp_(0u) {}
+ : event_media_type_(event_media_type), max_frames_(max_frames) {
+ Reset();
+}
EncodingEventSubscriber::~EncodingEventSubscriber() {
DCHECK(thread_checker_.CalledOnValidThread());
@@ -69,7 +66,7 @@ void EncodingEventSubscriber::OnReceiveFrameEvent(
if (event_media_type_ != frame_event.media_type)
return;
- RtpTimestamp relative_rtp_timestamp =
+ const RtpTimeDelta relative_rtp_timestamp =
GetRelativeRtpTimestamp(frame_event.rtp_timestamp);
FrameEventMap::iterator it = frame_event_map_.find(relative_rtp_timestamp);
linked_ptr<AggregatedFrameEvent> event_proto;
@@ -77,7 +74,8 @@ void EncodingEventSubscriber::OnReceiveFrameEvent(
// Look up existing entry. If not found, create a new entry and add to map.
if (it == frame_event_map_.end()) {
event_proto.reset(new AggregatedFrameEvent);
- event_proto->set_relative_rtp_timestamp(relative_rtp_timestamp);
+ event_proto->set_relative_rtp_timestamp(
+ relative_rtp_timestamp.lower_32_bits());
frame_event_map_.insert(
std::make_pair(relative_rtp_timestamp, event_proto));
} else {
@@ -87,7 +85,8 @@ void EncodingEventSubscriber::OnReceiveFrameEvent(
<< ". Using new frame event proto.";
AddFrameEventToStorage(event_proto);
event_proto.reset(new AggregatedFrameEvent);
- event_proto->set_relative_rtp_timestamp(relative_rtp_timestamp);
+ event_proto->set_relative_rtp_timestamp(
+ relative_rtp_timestamp.lower_32_bits());
it->second = event_proto;
}
}
@@ -136,7 +135,7 @@ void EncodingEventSubscriber::OnReceivePacketEvent(
if (event_media_type_ != packet_event.media_type)
return;
- RtpTimestamp relative_rtp_timestamp =
+ const RtpTimeDelta relative_rtp_timestamp =
GetRelativeRtpTimestamp(packet_event.rtp_timestamp);
PacketEventMap::iterator it =
packet_event_map_.find(relative_rtp_timestamp);
@@ -146,7 +145,8 @@ void EncodingEventSubscriber::OnReceivePacketEvent(
// Look up existing entry. If not found, create a new entry and add to map.
if (it == packet_event_map_.end()) {
event_proto.reset(new AggregatedPacketEvent);
- event_proto->set_relative_rtp_timestamp(relative_rtp_timestamp);
+ event_proto->set_relative_rtp_timestamp(
+ relative_rtp_timestamp.lower_32_bits());
packet_event_map_.insert(
std::make_pair(relative_rtp_timestamp, event_proto));
base_packet_event_proto = GetNewBasePacketEvent(
@@ -173,7 +173,8 @@ void EncodingEventSubscriber::OnReceivePacketEvent(
<< "Using new packet event proto.";
AddPacketEventToStorage(event_proto);
event_proto.reset(new AggregatedPacketEvent);
- event_proto->set_relative_rtp_timestamp(relative_rtp_timestamp);
+ event_proto->set_relative_rtp_timestamp(
+ relative_rtp_timestamp.lower_32_bits());
it->second = event_proto;
}
@@ -186,7 +187,8 @@ void EncodingEventSubscriber::OnReceivePacketEvent(
<< packet_event.packet_id << ". Using new packet event proto.";
AddPacketEventToStorage(event_proto);
event_proto.reset(new AggregatedPacketEvent);
- event_proto->set_relative_rtp_timestamp(relative_rtp_timestamp);
+ event_proto->set_relative_rtp_timestamp(
+ relative_rtp_timestamp.lower_32_bits());
it->second = event_proto;
base_packet_event_proto = GetNewBasePacketEvent(
event_proto.get(), packet_event.packet_id, packet_event.size);
@@ -225,7 +227,7 @@ void EncodingEventSubscriber::GetEventsAndReset(LogMetadata* metadata,
&IsRtpTimestampLessThan<linked_ptr<AggregatedPacketEvent> >);
metadata->set_is_audio(event_media_type_ == AUDIO_EVENT);
- metadata->set_first_rtp_timestamp(first_rtp_timestamp_);
+ metadata->set_first_rtp_timestamp(first_rtp_timestamp_.lower_32_bits());
metadata->set_num_frame_events(frame_event_storage_.size());
metadata->set_num_packet_events(packet_event_storage_.size());
metadata->set_reference_timestamp_ms_at_unix_epoch(
@@ -280,8 +282,8 @@ void EncodingEventSubscriber::AddPacketEventToStorage(
packet_event_storage_index_ = (packet_event_storage_index_ + 1) % max_frames_;
}
-RtpTimestamp EncodingEventSubscriber::GetRelativeRtpTimestamp(
- RtpTimestamp rtp_timestamp) {
+RtpTimeDelta EncodingEventSubscriber::GetRelativeRtpTimestamp(
+ RtpTimeTicks rtp_timestamp) {
if (!seen_first_rtp_timestamp_) {
seen_first_rtp_timestamp_ = true;
first_rtp_timestamp_ = rtp_timestamp;
@@ -298,7 +300,7 @@ void EncodingEventSubscriber::Reset() {
packet_event_storage_.clear();
packet_event_storage_index_ = 0;
seen_first_rtp_timestamp_ = false;
- first_rtp_timestamp_ = 0u;
+ first_rtp_timestamp_ = RtpTimeTicks();
}
} // namespace cast
« no previous file with comments | « media/cast/logging/encoding_event_subscriber.h ('k') | media/cast/logging/encoding_event_subscriber_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698