1 files changed, 173 insertions, 0 deletions
diff --git a/chromium/media/cast/rtcp/rtcp.h b/chromium/media/cast/rtcp/rtcp.h
new file mode 100644
index 00000000000..31962a526c6
--- /dev/null
+++ b/chromium/media/cast/rtcp/rtcp.h
@@ -0,0 +1,173 @@
+// 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.
+
+#ifndef MEDIA_CAST_RTCP_RTCP_H_
+#define MEDIA_CAST_RTCP_RTCP_H_
+
+#include <list>
+#include <map>
+#include <set>
+#include <string>
+
+#include "base/basictypes.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/time/default_tick_clock.h"
+#include "base/time/tick_clock.h"
+#include "base/time/time.h"
+#include "media/cast/cast_config.h"
+#include "media/cast/cast_defines.h"
+#include "media/cast/rtcp/rtcp_defines.h"
+
+namespace media {
+namespace cast {
+
+class LocalRtcpReceiverFeedback;
+class LocalRtcpRttFeedback;
+class PacedPacketSender;
+class RtcpReceiver;
+class RtcpSender;
+
+class RtcpSenderFeedback {
+ public:
+  virtual void OnReceivedReportBlock(const RtcpReportBlock& report_block) = 0;
+
+  virtual void OnReceivedIntraFrameRequest() = 0;
+
+  virtual void OnReceivedRpsi(uint8 payload_type, uint64 picture_id) = 0;
+
+  virtual void OnReceivedRemb(uint32 bitrate) = 0;
+
+  virtual void OnReceivedNackRequest(
+      const std::list<uint16>& nack_sequence_numbers) = 0;
+
+  virtual void OnReceivedCastFeedback(const RtcpCastMessage& cast_feedback) = 0;
+
+  virtual ~RtcpSenderFeedback() {}
+};
+
+class RtpSenderStatistics {
+ public:
+  virtual void GetStatistics(const base::TimeTicks& now,
+                             RtcpSenderInfo* sender_info) = 0;
+
+  virtual ~RtpSenderStatistics() {}
+};
+
+class RtpReceiverStatistics {
+ public:
+  virtual void GetStatistics(uint8* fraction_lost,
+                             uint32* cumulative_lost,  // 24 bits valid.
+                             uint32* extended_high_sequence_number,
+                             uint32* jitter) = 0;
+
+  virtual ~RtpReceiverStatistics() {}
+};
+
+class Rtcp {
+ public:
+  Rtcp(RtcpSenderFeedback* sender_feedback,
+       PacedPacketSender* paced_packet_sender,
+       RtpSenderStatistics* rtp_sender_statistics,
+       RtpReceiverStatistics* rtp_receiver_statistics,
+       RtcpMode rtcp_mode,
+       const base::TimeDelta& rtcp_interval,
+       bool sending_media,
+       uint32 local_ssrc,
+       const std::string& c_name);
+
+  virtual ~Rtcp();
+
+  static bool IsRtcpPacket(const uint8* rtcp_buffer, int length);
+
+  static uint32 GetSsrcOfSender(const uint8* rtcp_buffer, int length);
+
+  base::TimeTicks TimeToSendNextRtcpReport();
+  void SendRtcpReport(uint32 media_ssrc);
+  void SendRtcpPli(uint32 media_ssrc);
+  void SendRtcpCast(const RtcpCastMessage& cast_message);
+  void SetRemoteSSRC(uint32 ssrc);
+
+  void IncomingRtcpPacket(const uint8* rtcp_buffer, int length);
+  bool Rtt(base::TimeDelta* rtt, base::TimeDelta* avg_rtt,
+           base::TimeDelta* min_rtt,  base::TimeDelta* max_rtt) const;
+  bool RtpTimestampInSenderTime(int frequency,
+                                uint32 rtp_timestamp,
+                                base::TimeTicks* rtp_timestamp_in_ticks) const;
+
+  void set_clock(base::TickClock* clock) {
+    clock_ = clock;
+  }
+
+ protected:
+  int CheckForWrapAround(uint32 new_timestamp,
+                         uint32 old_timestamp) const;
+
+  void OnReceivedLipSyncInfo(uint32 rtp_timestamp,
+                             uint32 ntp_seconds,
+                             uint32 ntp_fraction);
+
+ private:
+  friend class LocalRtcpRttFeedback;
+  friend class LocalRtcpReceiverFeedback;
+
+  void SendRtcp(const base::TimeTicks& now,
+                uint32 packet_type_flags,
+                uint32 media_ssrc,
+                const RtcpCastMessage* cast_message);
+
+  void OnReceivedNtp(uint32 ntp_seconds, uint32 ntp_fraction);
+
+  void OnReceivedDelaySinceLastReport(uint32 receivers_ssrc,
+                                      uint32 last_report,
+                                      uint32 delay_since_last_report);
+
+  void OnReceivedSendReportRequest();
+
+  void UpdateRtt(const base::TimeDelta& sender_delay,
+                 const base::TimeDelta& receiver_delay);
+
+  void UpdateNextTimeToSendRtcp();
+
+  const base::TimeDelta rtcp_interval_;
+  const RtcpMode rtcp_mode_;
+  const bool sending_media_;
+  const uint32 local_ssrc_;
+
+  // Not owned by this class.
+  RtpSenderStatistics* const rtp_sender_statistics_;
+  RtpReceiverStatistics* const rtp_receiver_statistics_;
+
+  scoped_ptr<LocalRtcpRttFeedback> rtt_feedback_;
+  scoped_ptr<LocalRtcpReceiverFeedback> receiver_feedback_;
+  scoped_ptr<RtcpSender> rtcp_sender_;
+  scoped_ptr<RtcpReceiver> rtcp_receiver_;
+
+  base::TimeTicks next_time_to_send_rtcp_;
+
+  base::TimeTicks time_last_report_sent_;
+  uint32 last_report_sent_;
+
+  base::TimeTicks time_last_report_received_;
+  uint32 last_report_received_;
+
+  uint32 last_received_rtp_timestamp_;
+  uint32 last_received_ntp_seconds_;
+  uint32 last_received_ntp_fraction_;
+
+  base::TimeDelta rtt_;
+  base::TimeDelta min_rtt_;
+  base::TimeDelta max_rtt_;
+  int number_of_rtt_in_avg_;
+  float avg_rtt_ms_;
+
+  base::DefaultTickClock default_tick_clock_;
+  base::TickClock* clock_;
+
+  DISALLOW_COPY_AND_ASSIGN(Rtcp);
+};
+
+}  // namespace cast
+}  // namespace media
+
+#endif  // MEDIA_CAST_RTCP_RTCP_H_