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 a regular interval
+  // on this callback.
   CastTransportSenderImpl(
       base::TickClock* clock,
       const CastTransportConfig& config,
       const CastTransportStatusCallback& status_callback,
+      const BulkRawEventsCallback& raw_events_callback,
       const scoped_refptr<base::SingleThreadTaskRunner>& transport_task_runner,
       PacketSender* external_transport);
 
   virtual ~CastTransportSenderImpl();
 
   // CastTransportSender implementation.
   virtual void SetPacketReceiver(const PacketReceiverCallback& packet_receiver)
       OVERRIDE;
 
   virtual void InsertCodedAudioFrame(const EncodedAudioFrame* audio_frame,
@@ skipping 15 matching lines @@
                              const MissingFramesAndPacketsMap& missing_packets)
       OVERRIDE;
 
   virtual void SubscribeAudioRtpStatsCallback(
       const CastTransportRtpStatistics& callback) OVERRIDE;
 
   virtual void SubscribeVideoRtpStatsCallback(
       const CastTransportRtpStatistics& callback) OVERRIDE;
 
  private:
+  // How often to send raw events.
+  static const int kSendRawEventsIntervalSecs = 1;
+
+  // 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();
+
   scoped_ptr<UdpTransport> transport_;
   PacedSender pacer_;
   RtcpBuilder rtcp_builder_;
   TransportAudioSender audio_sender_;
   TransportVideoSender video_sender_;
 
+  LoggingImpl logging_;
+
+  // 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_