1 files changed, 116 insertions, 0 deletions
diff --git a/MediaBrowser.Server.Startup.Common/LiveTv/TunerHosts/SatIp/Rtp/RtpPacket.cs b/MediaBrowser.Server.Startup.Common/LiveTv/TunerHosts/SatIp/Rtp/RtpPacket.cs
new file mode 100644
index 0000000000..489d7f087c
--- /dev/null
+++ b/MediaBrowser.Server.Startup.Common/LiveTv/TunerHosts/SatIp/Rtp/RtpPacket.cs
@@ -0,0 +1,116 @@
+/*  
+    Copyright (C) <2007-2016>  <Kay Diefenthal>
+
+    SatIp.RtspSample is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    SatIp.RtspSample is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with SatIp.RtspSample.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+using System;
+using System.Collections.ObjectModel;
+using System.Text;
+
+namespace MediaBrowser.Server.Implementations.LiveTv.TunerHosts.SatIp.Rtp
+{
+    public class RtpPacket
+    {
+        private static int MinHeaderLength = 12;
+        public int HeaderSize = MinHeaderLength;
+        public int Version { get; set; }
+        public Boolean Padding { get; set; }
+        public Boolean Extension { get; set; }
+        public int ContributingSourceCount { get; set; }
+        public Boolean Marker { get; set; }
+        public int PayloadType { get; set; }
+        public int SequenceNumber { get; set; }
+        public long TimeStamp { get; set; }
+        public long SynchronizationSource { get; set; }
+        public Collection<string> ContributingSources { get; private set; }
+        public int ExtensionHeaderId = 0;
+        public int ExtensionHeaderLength = 0;       
+        public bool HasPayload { get; set; }
+        public byte[] Payload { get; set; }
+        public RtpPacket()
+        {
+            
+        }
+        public static RtpPacket Decode(byte[] buffer)
+        {
+            var packet = new RtpPacket();
+            packet.Version = buffer[0] >> 6;
+            packet.Padding = (buffer[0] & 0x20) != 0;
+            packet.Extension = (buffer[0] & 0x10) != 0;
+            packet.ContributingSourceCount = buffer[0] & 0x0f;
+
+            packet.Marker = (buffer[1] & 0x80) != 0;
+            packet.PayloadType = buffer[1] & 0x7f;
+
+            packet.SequenceNumber = Utils.Convert2BytesToInt(buffer, 2);
+            packet.TimeStamp = Utils.Convert4BytesToLong(buffer, 4);
+            packet.SynchronizationSource = Utils.Convert4BytesToLong(buffer, 8);
+
+            int index = 12;
+
+            if (packet.ContributingSourceCount != 0)
+            {
+                packet.ContributingSources = new Collection<string>();
+
+                while (packet.ContributingSources.Count < packet.ContributingSourceCount)
+                {
+                    packet.ContributingSources.Add(Utils.ConvertBytesToString(buffer, index, 4));
+                    index += 4;
+                }
+            }
+            var dataoffset = 0;
+            if (!packet.Extension)
+                dataoffset = index;
+            else
+            {
+                packet.ExtensionHeaderId = Utils.Convert2BytesToInt(buffer, index);
+                packet.ExtensionHeaderLength = Utils.Convert2BytesToInt(buffer, index + 2);
+                dataoffset = index + packet.ExtensionHeaderLength + 4;
+            }
+
+            var dataLength = buffer.Length - dataoffset;
+            if (dataLength > dataoffset)
+            {
+                packet.HasPayload = true;
+                packet.Payload = new byte[dataLength];
+                Array.Copy(buffer, dataoffset, packet.Payload, 0, dataLength);
+            }
+            else
+            {
+                packet.HasPayload = false;
+            }
+            return packet;
+        }        
+
+        public override string ToString()
+        {
+            StringBuilder sb = new StringBuilder();
+            sb.AppendFormat("RTP Packet");
+            sb.AppendFormat("Version: {0} \n", Version);
+            sb.AppendFormat("Padding: {0} \n", Padding);
+            sb.AppendFormat("Extension: {0} \n", Extension);
+            sb.AppendFormat("Contributing Source Identifiers Count: {0} \n", ContributingSourceCount);
+            sb.AppendFormat("Marker: {0} \n", Marker);
+            sb.AppendFormat("Payload Type: {0} \n", PayloadType);
+            sb.AppendFormat("Sequence Number: {0} \n", SequenceNumber);
+            sb.AppendFormat("Timestamp: {0} .\n", TimeStamp);
+            sb.AppendFormat("Synchronization Source Identifier: {0} \n", SynchronizationSource);
+            sb.AppendFormat("\n");
+            return sb.ToString();
+        }
+
+    }
+
+}