Cast: Log sender side packet events.

media/cast/transport/cast_transport_sender_impl.cc

 // Copyright 2014 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 "media/cast/transport/cast_transport_sender_impl.h"
 
 #include "base/single_thread_task_runner.h"
 #include "media/cast/transport/cast_transport_config.h"
 #include "media/cast/transport/cast_transport_defines.h"
 
@@ skipping 37 matching lines @@
     PacketSender* external_transport)
     : clock_(clock),
       status_callback_(status_callback),
       transport_task_runner_(transport_task_runner),
       transport_(external_transport ? NULL
                                     : new UdpTransport(net_log,
                                                        transport_task_runner,
                                                        local_end_point,
                                                        remote_end_point,
                                                        status_callback)),
+      logging_(logging_config),
       pacer_(clock,
+             &logging_,
              external_transport ? external_transport : transport_.get(),
              transport_task_runner),
       rtcp_builder_(&pacer_),
-      logging_(logging_config),
       raw_events_callback_(raw_events_callback) {
   if (!raw_events_callback_.is_null()) {
     DCHECK(logging_config.enable_raw_data_collection);
     DCHECK(raw_events_callback_interval > base::TimeDelta());
     event_subscriber_.reset(new SimpleEventSubscriber);
     logging_.AddRawEventSubscriber(event_subscriber_.get());
     raw_events_timer_.Start(FROM_HERE,
                             raw_events_callback_interval,
                             this,
                             &CastTransportSenderImpl::SendRawEvents);
   }
 }
 
 CastTransportSenderImpl::~CastTransportSenderImpl() {
   if (event_subscriber_.get())
     logging_.RemoveRawEventSubscriber(event_subscriber_.get());
 }
 
 void CastTransportSenderImpl::InitializeAudio(
     const CastTransportAudioConfig& config) {
+  pacer_.RegisterAudioSsrc(config.base.ssrc);
   audio_sender_.reset(new TransportAudioSender(
-      config, clock_, transport_task_runner_, &pacer_));
+      config, clock_, &logging_, transport_task_runner_, &pacer_));
   if (audio_sender_->initialized())
     status_callback_.Run(TRANSPORT_AUDIO_INITIALIZED);
   else
     status_callback_.Run(TRANSPORT_AUDIO_UNINITIALIZED);
 }
 
 void CastTransportSenderImpl::InitializeVideo(
     const CastTransportVideoConfig& config) {
+  pacer_.RegisterVideoSsrc(config.base.ssrc);
   video_sender_.reset(new TransportVideoSender(
-      config, clock_, transport_task_runner_, &pacer_));
+      config, clock_, &logging_, transport_task_runner_, &pacer_));
   if (video_sender_->initialized())
     status_callback_.Run(TRANSPORT_VIDEO_INITIALIZED);
   else
     status_callback_.Run(TRANSPORT_VIDEO_UNINITIALIZED);
 }
 
 void CastTransportSenderImpl::SetPacketReceiver(
     const PacketReceiverCallback& packet_receiver) {
   transport_->StartReceiving(packet_receiver);
 }
@@ skipping 51 matching lines @@
   DCHECK(event_subscriber_.get());
   DCHECK(!raw_events_callback_.is_null());
   std::vector<PacketEvent> packet_events;
   event_subscriber_->GetPacketEventsAndReset(&packet_events);
   raw_events_callback_.Run(packet_events);
 }
 
 }  // namespace transport
 }  // namespace cast
 }  // namespace media