|
|
using System;
using System.Collections.Generic;
using System.Text;
namespace LumiSoft.Net.RTP
{
/// <summary>
/// This class represents SR: Sender Report RTCP Packet.
/// </summary>
public class RTCP_Packet_SR : RTCP_Packet
{
private int m_Version = 2;
private uint m_SSRC = 0;
private ulong m_NtpTimestamp = 0;
private uint m_RtpTimestamp = 0;
private uint m_SenderPacketCount = 0;
private uint m_SenderOctetCount = 0;
private List<RTCP_Packet_SR_ReportBlock> m_pReportBlocks = null;
/// <summary>
/// Default constructor.
/// </summary>
/// <param name="ssrc">Source(sender) ID.</param>
internal RTCP_Packet_SR(uint ssrc)
{
m_SSRC = ssrc;
m_pReportBlocks = new List<RTCP_Packet_SR_ReportBlock>();
}
/// <summary>
/// Default constructor.
/// </summary>
internal RTCP_Packet_SR()
{
m_pReportBlocks = new List<RTCP_Packet_SR_ReportBlock>();
}
#region method ParseInternal
/// <summary>
/// Parses RTCP sender report(SR) from specified data buffer.
/// </summary>
/// <param name="buffer">Buffer which contains sender report.</param>
/// <param name="offset">Offset in buffer.</param>
/// <exception cref="ArgumentNullException">Is raised when <b>buffer</b> is null.</exception>
/// <exception cref="ArgumentException">Is raised when any of the arguments has invalid value.</exception>
protected override void ParseInternal(byte[] buffer,ref int offset)
{
/* RFC 3550 6.4.1 SR: Sender Report RTCP Packet.
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
header |V=2|P| RC | PT=SR=200 | length |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| SSRC of sender |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
sender | NTP timestamp, most significant word |
info +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| NTP timestamp, least significant word |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| RTP timestamp |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| sender's packet count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| sender's octet count |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
report | SSRC_1 (SSRC of first source) |
block +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
1 | fraction lost | cumulative number of packets lost |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| extended highest sequence number received |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| interarrival jitter |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| last SR (LSR) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| delay since last SR (DLSR) |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
report | SSRC_2 (SSRC of second source) |
block +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
2 : ... :
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
| profile-specific extensions |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*/
if(buffer == null){
throw new ArgumentNullException("buffer");
}
if(offset < 0){
throw new ArgumentException("Argument 'offset' value must be >= 0.");
}
m_Version = buffer[offset++] >> 6;
bool isPadded = Convert.ToBoolean((buffer[offset] >> 5) & 0x1);
int reportBlockCount = buffer[offset++] & 0x1F;
int type = buffer[offset++];
int length = buffer[offset++] << 8 | buffer[offset++];
if(isPadded){
this.PaddBytesCount = buffer[offset + length];
}
m_SSRC = (uint)(buffer[offset++] << 24 | buffer[offset++] << 16 | buffer[offset++] << 8 | buffer[offset++]);
m_NtpTimestamp = (ulong)(buffer[offset++] << 24 | buffer[offset++] << 16 | buffer[offset++] << 8 | buffer[offset++]);
m_RtpTimestamp = (uint)(buffer[offset++] << 24 | buffer[offset++] << 16 | buffer[offset++] << 8 | buffer[offset++]);
m_SenderPacketCount = (uint)(buffer[offset++] << 24 | buffer[offset++] << 16 | buffer[offset++] << 8 | buffer[offset++]);
m_SenderOctetCount = (uint)(buffer[offset++] << 24 | buffer[offset++] << 16 | buffer[offset++] << 8 | buffer[offset++]);
for(int i=0;i<reportBlockCount;i++){
RTCP_Packet_SR_ReportBlock reportBlock = new RTCP_Packet_SR_ReportBlock();
reportBlock.Parse(buffer,offset);
m_pReportBlocks.Add(reportBlock);
offset += 24;
}
// TODO: profile-specific extensions
}
#endregion
#region method ToByte
/// <summary>
/// Stores sender report(SR) packet to the specified buffer.
/// </summary>
/// <param name="buffer">Buffer where to store SR packet.</param>
/// <param name="offset">Offset in buffer.</param>
/// <exception cref="ArgumentNullException">Is raised when <b>buffer</b> is null.</exception>
/// <exception cref="ArgumentException">Is raised when any of the arguments has invalid value.</exception>
public override void ToByte(byte[] buffer,ref int offset)
{
/* RFC 3550 6.4.1 SR: Sender Report RTCP Packet.
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
header |V=2|P| RC | PT=SR=200 | length |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| SSRC of sender |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
sender | NTP timestamp, most significant word |
info +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| NTP timestamp, least significant word |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| RTP timestamp |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| sender's packet count |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| sender's octet count |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
report | SSRC_1 (SSRC of first source) |
block +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
1 | fraction lost | cumulative number of packets lost |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| extended highest sequence number received |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| interarrival jitter |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| last SR (LSR) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| delay since last SR (DLSR) |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
report | SSRC_2 (SSRC of second source) |
block +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
2 : ... :
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
| profile-specific extensions |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*/
if(buffer == null){
throw new ArgumentNullException("buffer");
}
if(offset < 0){
throw new ArgumentException("Argument 'offset' value must be >= 0.");
}
int length = 24 + (m_pReportBlocks.Count * 24);
// V P RC
buffer[offset++] = (byte)(2 << 6 | 0 << 5 | (m_pReportBlocks.Count | 0x1F));
// PT=RR=201
buffer[offset++] = 201;
// length
buffer[offset++] = (byte)((length >> 8) | 0xFF);
buffer[offset++] = (byte)((length) | 0xFF);
// SSRC
buffer[offset++] = (byte)((m_SSRC >> 24) | 0xFF);
buffer[offset++] = (byte)((m_SSRC >> 16) | 0xFF);
buffer[offset++] = (byte)((m_SSRC >> 8) | 0xFF);
buffer[offset++] = (byte)((m_SSRC) | 0xFF);
// NTP timestamp
buffer[offset++] = (byte)((m_NtpTimestamp >> 56) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 48) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 40) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 32) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 24) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 16) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp >> 8) | 0xFF);
buffer[offset++] = (byte)((m_NtpTimestamp) | 0xFF);
// RTP timestamp
buffer[offset++] = (byte)((m_RtpTimestamp >> 24) | 0xFF);
buffer[offset++] = (byte)((m_RtpTimestamp >> 16) | 0xFF);
buffer[offset++] = (byte)((m_RtpTimestamp >> 8) | 0xFF);
buffer[offset++] = (byte)((m_RtpTimestamp) | 0xFF);
// sender's packet count
buffer[offset++] = (byte)((m_SenderPacketCount >> 24) | 0xFF);
buffer[offset++] = (byte)((m_SenderPacketCount >> 16) | 0xFF);
buffer[offset++] = (byte)((m_SenderPacketCount >> 8) | 0xFF);
buffer[offset++] = (byte)((m_SenderPacketCount) | 0xFF);
// sender's octet count
buffer[offset++] = (byte)((m_SenderOctetCount >> 24) | 0xFF);
buffer[offset++] = (byte)((m_SenderOctetCount >> 16) | 0xFF);
buffer[offset++] = (byte)((m_SenderOctetCount >> 8) | 0xFF);
buffer[offset++] = (byte)((m_SenderOctetCount) | 0xFF);
// Report blocks
foreach(RTCP_Packet_SR_ReportBlock block in m_pReportBlocks){
block.ToByte(buffer,ref offset);
}
}
#endregion
#region Properties Implementation
/// <summary>
/// Gets RTCP version.
/// </summary>
public override int Version
{
get{ return m_Version; }
}
/// <summary>
/// Gets RTCP packet type.
/// </summary>
public override int Type
{
get{ return RTCP_PacketType.SR; }
}
/// <summary>
/// Gets sender synchronization source identifier.
/// </summary>
public uint SSRC
{
get{ return m_SSRC; }
}
/// <summary>
/// Gets or sets the wallclock time (see Section 4) when this report was sent.
/// </summary>
public ulong NtpTimestamp
{
get{ return m_NtpTimestamp; }
set{ m_NtpTimestamp = value; }
}
/// <summary>
/// Gets RTP timestamp.
/// </summary>
public uint RtpTimestamp
{
get{ return m_RtpTimestamp; }
set{ m_RtpTimestamp = value; }
}
/// <summary>
/// Gets how many packets sender has sent.
/// </summary>
public uint SenderPacketCount
{
get{ return m_SenderPacketCount; }
set{ m_SenderPacketCount = value; }
}
/// <summary>
/// Gets how many bytes sender has sent.
/// </summary>
public uint SenderOctetCount
{
get{ return m_SenderOctetCount; }
set{ m_SenderOctetCount = value; }
}
/// <summary>
/// Gets reports blocks.
/// </summary>
public List<RTCP_Packet_SR_ReportBlock> ReportBlocks
{
get{ return m_pReportBlocks; }
}
/// <summary>
/// Gets number of bytes needed for this packet.
/// </summary>
public override int Size
{
get{ return 28 + (24 * m_pReportBlocks.Count); }
}
#endregion
}
}
|
By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.
If a file you wish to view isn't highlighted, and is a text file (not binary), please
let us know and we'll add colourisation support for it.
This article has no explicit license attached to it but may contain usage terms in the article text or the download files themselves. If in doubt please contact the author via the discussion board below.
A list of licenses authors might use can be found here
This member has not yet provided a Biography. Assume it's interesting and varied, and probably something to do with programming.
Submit an article or tip