Reply to thread

Message

<blockquote data-quote="KayDiefenthal" data-source="post: 1261289" data-attributes="member: 22825">wie das file entstanden ist st relativ einfach [code]private void RtpListenerThread()&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; try&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; try&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; while (!_rtpListenerThreadStopEvent.WaitOne(1)))&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; byte[] receivedbytes = _udpClient.Receive(ref _serverEndPoint);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if(receivedbytes != null)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; RtpPacket packet = RtpPacket.Decode(receivedbytes);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if((packet.HasPayload)&amp;&amp;(packet.PayloadType == 33))&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _filestream.Write(packet.Payload,0,packet.Payload.Lenght)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _filestream.Flush();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; finally&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; switch (_transmissionMode)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; case TransmissionMode.Multicast:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _udpClient.DropMulticastGroup(_multicastEndPoint.Address);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _udpClient.Close();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; break;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; case TransmissionMode.Unicast:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _udpClient.Close();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; break;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; catch (ThreadAbortException)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; catch (Exception ex)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Logger.Error(string.Format(&quot;SAT&gt;IP : RTP listener thread exception&quot;), ex);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Logger.Warn(&quot;SAT&gt;IP : RTP listener thread stopping&quot;);&nbsp; &nbsp; &nbsp; &nbsp; }[/code][code]public class RtpPacket&nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; private static int MinHeaderLength = 12;&nbsp; &nbsp; &nbsp; &nbsp; public int HeaderSize = MinHeaderLength;&nbsp; &nbsp; &nbsp; &nbsp; public int Version { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public Boolean Padding { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public Boolean Extension { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public int ContributingSourceCount { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public Boolean Marker { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public int PayloadType { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public int SequenceNumber { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public long TimeStamp { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public long SynchronizationSource { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public Collection&lt;string&gt; ContributingSources { get; private set; }&nbsp; &nbsp; &nbsp; &nbsp; public int ExtensionHeaderId = 0;&nbsp; &nbsp; &nbsp; &nbsp; public int ExtensionHeaderLength = 0;&nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public bool HasPayload { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public byte[] Payload { get; set; }&nbsp; &nbsp; &nbsp; &nbsp; public RtpPacket()&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; public static RtpPacket Decode(byte[] buffer)&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var packet = new RtpPacket();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.Version = buffer[0] &gt;&gt; 6;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.Padding = (buffer[0] &amp; 0x20) != 0;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.Extension = (buffer[0] &amp; 0x10) != 0;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //packet.ContributingSourceCount = buffer[0] &amp; 0x0f;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.Marker = (buffer[1] &amp; 0x80) != 0;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.PayloadType = buffer[1] &amp; 0x7f;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.SequenceNumber = Utils.Convert2BytesToInt(buffer, 2);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.TimeStamp = Utils.Convert4BytesToLong(buffer, 4);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.SynchronizationSource = Utils.Convert4BytesToLong(buffer, 8);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int index = 12;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (packet.ContributingSourceCount != 0)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.ContributingSources = new Collection&lt;string&gt;();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; while (packet.ContributingSources.Count &lt; packet.ContributingSourceCount)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.ContributingSources.Add(Utils.ConvertBytesToString(buffer, index, 4));&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; index += 4;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var dataoffset = 0;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (!packet.Extension)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; dataoffset = index;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; else&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.ExtensionHeaderId = Utils.Convert2BytesToInt(buffer, index);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.ExtensionHeaderLength = Utils.Convert2BytesToInt(buffer, index + 2);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; dataoffset = index + packet.ExtensionHeaderLength + 4;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var dataLength = buffer.Length - dataoffset;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (dataLength &gt; dataoffset)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.HasPayload = true;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.Payload = new byte[dataLength];&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Array.Copy(buffer, dataoffset, packet.Payload, 0, dataLength);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; else&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; packet.HasPayload = false;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return packet;&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; public override string ToString()&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; StringBuilder sb = new StringBuilder();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;RTP Packet&quot;);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Version: {0} \n&quot;, Version);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Padding: {0} \n&quot;, Padding);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Extension: {0} \n&quot;, Extension);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Contributing Source Identifiers Count: {0} \n&quot;, ContributingSourceCount);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Marker: {0} \n&quot;, Marker);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Payload Type: {0} \n&quot;, PayloadType);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Sequence Number: {0} \n&quot;, SequenceNumber);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Timestamp: {0} .\n&quot;, TimeStamp);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;Synchronization Source Identifier: {0} \n&quot;, SynchronizationSource);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.AppendFormat(&quot;\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return sb.ToString();&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; }[/code]</blockquote>

[QUOTE="KayDiefenthal, post: 1261289, member: 22825"] wie das file entstanden ist st relativ einfach [code] private void RtpListenerThread() { try { try { while (!_rtpListenerThreadStopEvent.WaitOne(1))) { byte[] receivedbytes = _udpClient.Receive(ref _serverEndPoint); if(receivedbytes != null) { RtpPacket packet = RtpPacket.Decode(receivedbytes); if((packet.HasPayload)&&(packet.PayloadType == 33)) { _filestream.Write(packet.Payload,0,packet.Payload.Lenght) _filestream.Flush(); } } } } finally { switch (_transmissionMode) { case TransmissionMode.Multicast: _udpClient.DropMulticastGroup(_multicastEndPoint.Address); _udpClient.Close(); break; case TransmissionMode.Unicast: _udpClient.Close(); break; } } } catch (ThreadAbortException) { } catch (Exception ex) { Logger.Error(string.Format("SAT>IP : RTP listener thread exception"), ex); return; } Logger.Warn("SAT>IP : RTP listener thread stopping"); } [/code] [code] 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(); } } [/code] [/QUOTE]

Verification