Cast: IPC from browser to renderer to send packet events from transport to cast library.

media/cast/transport/cast_transport_sender_impl.h

 // 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.
 
 #ifndef MEDIA_CAST_TRANSPORT_CAST_TRANSPORT_IMPL_H_
 #define MEDIA_CAST_TRANSPORT_CAST_TRANSPORT_IMPL_H_
 
 #include "base/callback.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/time/tick_clock.h"
 #include "base/time/time.h"
+#include "base/timer/timer.h"
+#include "media/cast/logging/logging_defines.h"
+#include "media/cast/logging/simple_event_subscriber.h"
 #include "media/cast/transport/cast_transport_config.h"
 #include "media/cast/transport/cast_transport_sender.h"
 #include "media/cast/transport/pacing/paced_sender.h"
 #include "media/cast/transport/rtcp/rtcp_builder.h"
 #include "media/cast/transport/transport_audio_sender.h"
 #include "media/cast/transport/transport_video_sender.h"
 
 namespace media {
 namespace cast {
 namespace transport {
 
 class CastTransportSenderImpl : public CastTransportSender {
  public:
   // external_transport is only used for testing.
   // Note that SetPacketReceiver does not work if an external
   // transport is provided.
+  // |raw_events_callback|: Raw events will be returned on this callback
+  // which will be invoked every |raw_events_callback_interval|.
+  // This can be a null callback, i.e. if user is not interested in raw events.
+  // |raw_events_callback_interval|: This can be |base::TimeDelta()| if
+  // |raw_events_callback| is a null callback.
   CastTransportSenderImpl(
       net::NetLog* net_log,
       base::TickClock* clock,
       const net::IPEndPoint& local_end_point,
       const net::IPEndPoint& remote_end_point,
+      const CastLoggingConfig& logging_config,
       const CastTransportStatusCallback& status_callback,
+      const BulkRawEventsCallback& raw_events_callback,
+      base::TimeDelta raw_events_callback_interval,
       const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner,
       PacketSender* external_transport);
 
   virtual ~CastTransportSenderImpl();
 
   virtual void InitializeAudio(const CastTransportAudioConfig& config) OVERRIDE;
 
   virtual void InitializeVideo(const CastTransportVideoConfig& config) OVERRIDE;
 
   // CastTransportSender implementation.
@@ skipping 19 matching lines @@
                              const MissingFramesAndPacketsMap& missing_packets)
       OVERRIDE;
 
   virtual void SubscribeAudioRtpStatsCallback(
       const CastTransportRtpStatistics& callback) OVERRIDE;
 
   virtual void SubscribeVideoRtpStatsCallback(
       const CastTransportRtpStatistics& callback) OVERRIDE;
 
  private:
+  // If raw events logging is enabled, this is called periodically.
+  // Calls |raw_events_callback_| with events collected by |event_subscriber_|
+  // since last call.
+  void SendRawEvents();
+
   base::TickClock* clock_;  // Not owned by this class.
   CastTransportStatusCallback status_callback_;
   scoped_refptr<base::SingleThreadTaskRunner> transport_task_runner_;
+
   scoped_ptr<UdpTransport> transport_;
+  LoggingImpl logging_;
   PacedSender pacer_;
   RtcpBuilder rtcp_builder_;
   scoped_ptr<TransportAudioSender> audio_sender_;
   scoped_ptr<TransportVideoSender> video_sender_;
 
+  // This is non-null iff raw events logging is enabled.
+  scoped_ptr<SimpleEventSubscriber> event_subscriber_;
+  base::RepeatingTimer<CastTransportSenderImpl> raw_events_timer_;
+
+  BulkRawEventsCallback raw_events_callback_;
+
   DISALLOW_COPY_AND_ASSIGN(CastTransportSenderImpl);
 };
 
 }  // namespace transport
 }  // namespace cast
 }  // namespace media
 
 #endif  // MEDIA_CAST_TRANSPORT_CAST_TRANSPORT_IMPL_H_