Cast: Log sender side packet events.

media/cast/logging/logging_impl.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/big_endian.h"
 #include "base/debug/trace_event.h"
 #include "media/cast/logging/logging_impl.h"
 
 namespace media {
 namespace cast {
@@ skipping 60 matching lines @@
   }
 
   if (config_.enable_tracing) {
     std::string event_string = CastLoggingToString(event);
     TRACE_EVENT_INSTANT2(event_string.c_str(), "FED", TRACE_EVENT_SCOPE_THREAD,
                          "rtp_timestamp", rtp_timestamp, "delay",
                          delay.InMilliseconds());
   }
 }
 
+void LoggingImpl::InsertSinglePacketEvent(const base::TimeTicks& time_of_event,
+                                          CastLoggingEvent event,
+                                          const Packet& packet) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+
+  // Parse basic properties.
+  uint32 rtp_timestamp;
+  uint16 packet_id, max_packet_id;
+  const uint8* packet_data = &packet[0];
+  base::BigEndianReader big_endian_reader(
+      reinterpret_cast<const char*>(packet_data + 4), 4);
+  big_endian_reader.ReadU32(&rtp_timestamp);
+  base::BigEndianReader cast_big_endian_reader(
+      reinterpret_cast<const char*>(packet_data + 12 + 2), 4);
+  cast_big_endian_reader.ReadU16(&packet_id);
+  cast_big_endian_reader.ReadU16(&max_packet_id);
+
+  // rtp_timestamp is enough - no need for frame_id as well.
+  InsertPacketEvent(time_of_event,
+                    event,
+                    rtp_timestamp,
+                    kFrameIdUnknown,
+                    packet_id,
+                    max_packet_id,
+                    packet.size());
+}
+
 void LoggingImpl::InsertPacketListEvent(const base::TimeTicks& time_of_event,
                                         CastLoggingEvent event,
                                         const PacketList& packets) {
   DCHECK(thread_checker_.CalledOnValidThread());
-  for (unsigned int i = 0; i < packets.size(); ++i) {
-    const Packet& packet = packets[i];
-    // Parse basic properties.
-    uint32 rtp_timestamp;
-    uint16 packet_id, max_packet_id;
-    const uint8* packet_data = &packet[0];
-    base::BigEndianReader big_endian_reader(
-        reinterpret_cast<const char*>(packet_data + 4), 4);
-    big_endian_reader.ReadU32(&rtp_timestamp);
-    base::BigEndianReader cast_big_endian_reader(
-        reinterpret_cast<const char*>(packet_data + 12 + 2), 4);
-    cast_big_endian_reader.ReadU16(&packet_id);
-    cast_big_endian_reader.ReadU16(&max_packet_id);
-    // rtp_timestamp is enough - no need for frame_id as well.
-    InsertPacketEvent(time_of_event, event, rtp_timestamp, kFrameIdUnknown,
-                      packet_id, max_packet_id, packet.size());
+  for (PacketList::const_iterator it = packets.begin(); it != packets.end();
+       ++it) {
+    InsertSinglePacketEvent(time_of_event, event, *it);
   }
 }
 
 void LoggingImpl::InsertPacketEvent(const base::TimeTicks& time_of_event,
                                     CastLoggingEvent event,
                                     uint32 rtp_timestamp, uint32 frame_id,
                                     uint16 packet_id, uint16 max_packet_id,
                                     size_t size) {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (config_.enable_raw_data_collection) {
@@ skipping 55 matching lines @@
   return stats_.GetGenericStatsData();
 }
 
 void LoggingImpl::ResetStats() {
   DCHECK(thread_checker_.CalledOnValidThread());
   stats_.Reset();
 }
 
 }  // namespace cast
 }  // namespace media