src/media/cast/transport/transport_video_sender.h

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef MEDIA_CAST_TRANSPORT_TRANSPORT_VIDEO_SENDER_H_
   6 #define MEDIA_CAST_TRANSPORT_TRANSPORT_VIDEO_SENDER_H_
   7
   8 #include "base/callback.h"
   9 #include "base/memory/ref_counted.h"
  10 #include "base/memory/scoped_ptr.h"
  11 #include "base/threading/non_thread_safe.h"
  12 #include "base/time/tick_clock.h"
  13 #include "media/cast/transport/cast_transport_config.h"
  14 #include "media/cast/transport/rtp_sender/rtp_sender.h"
  15 #include "media/cast/transport/utility/transport_encryption_handler.h"
  16
  17 namespace media {
  18 class VideoFrame;
  19
  20 namespace cast {
  21 namespace transport {
  22
  23 class PacedSender;
  24
  25 // Not thread safe. Only called from the main cast transport thread.
  26 // This class owns all objects related to sending coded video, objects that
  27 // encrypt, create RTP packets and send to network.
  28 class TransportVideoSender : public base::NonThreadSafe {
  29  public:
  30   TransportVideoSender(
  31       const CastTransportConfig& config,
  32       base::TickClock* clock,
  33       const scoped_refptr<base::TaskRunner>& transport_task_runner,
  34       PacedSender* const paced_packet_sender);
  35
  36   virtual ~TransportVideoSender();
  37
  38   // Handles the encoded video frames to be processed.
  39   // Frames will be encrypted, packetized and transmitted to the network.
  40   void InsertCodedVideoFrame(const EncodedVideoFrame* coded_frame,
  41                              const base::TimeTicks& capture_time);
  42
  43   // Retransmision request.
  44   void ResendPackets(
  45       const MissingFramesAndPacketsMap& missing_frames_and_packets);
  46
  47   bool initialized() const { return initialized_; }
  48
  49   // Subscribe callback to get RTP Audio stats.
  50   void SubscribeVideoRtpStatsCallback(
  51       const CastTransportRtpStatistics& callback);
  52
  53  private:
  54   // Caller must allocate the destination |encrypted_video_frame| the data
  55   // member will be resized to hold the encrypted size.
  56   bool EncryptVideoFrame(const EncodedVideoFrame& encoded_frame,
  57                          EncodedVideoFrame* encrypted_video_frame);
  58
  59   const base::TimeDelta rtp_max_delay_;
  60   TransportEncryptionHandler encryptor_;
  61   RtpSender rtp_sender_;
  62   bool initialized_;
  63
  64   DISALLOW_IMPLICIT_CONSTRUCTORS(TransportVideoSender);
  65 };
  66
  67 }  // namespace transport
  68 }  // namespace cast
  69 }  // namespace media
  70
  71 #endif  // MEDIA_CAST_TRANSPORT_TRANSPORT_VIDEO_SENDER_H_