New Zealand
I'm sorry, I don't understand. I'm not very good with network/socket code stuff.
Yep, it's possible. But your RTSP implementation must create UDP sockets with SO_REUSEADDR option (if not, then filter cannot use your UDP ports). Then you just create UDP url for filter and it should work - in case that stream is in MPEG2 TS format.I'm sorry, I don't understand. I'm not very good with network/socket code stuff.
SAT>IP servers deliver a stream via RTSP + RTP. What I'm saying is that I want to implement the RTSP part in C# and use your filter to receive the RTP/UDP stream. Do you think this is possible?
Hungary
It is as I thought. The stream is not in MPEG2 TS container (one stream with multiplexed audio and video), but you have two streams - one audio (AAC) and one video (H264). I'm working on possibility to support your case, but in current filter state this case is not supported.
Here you are, hopefully I'm using the correct files and formats. In case there's anything else or a different format is needed, pls. educate me.
Thanks a lot for your support!!
I'm sorry, I don't understand. I'm not very good with network/socket code stuff.
SAT>IP servers deliver a stream via RTSP + RTP. What I'm saying is that I want to implement the RTSP part in C# and use your filter to receive the RTP/UDP stream. Do you think this is possible?
public class RtpSession
{
private Thread _listenerThread;
private EndPoint _endPoint;
private MemoryStream _stream;
public MemoryStream Stream
{
get { return _stream; }
set { _stream = value; }
}
private bool _listening;
private Socket _socket;
private int _rcvd;
/// <summary>
/// Initialize a new Instance of<see cref="RtpSession"/> Class.
/// </summary>
public RtpSession(string address,int port )
{
_stream = new MemoryStream();
Connect(address, port);
}
private void Connect(string address,int port )
{
var rtpEndPoint = new IPEndPoint(IPAddress.Parse(address), port);
var endPoint = (EndPoint)rtpEndPoint;
_socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
_socket.SetSocketOption(SocketOptionLevel.Socket,SocketOptionName.ReuseAddress, 1);
_socket.Bind(endPoint);
var sender = new IPEndPoint(IPAddress.Parse(address), port);
_endPoint = (EndPoint)sender;
_listenerThread = new Thread(ReceiveCallback);
_listenerThread.Start();
}
private void ReceiveCallback()
{
_listening = true;
while (_listening)
{
// Receive RTP packet
byte[] packet = new byte[1370];
_rcvd = _socket.ReceiveFrom( packet ,ref _endPoint);
// Decode the header of the packet.
// Each piece of information has a start bit and an end bit.
// The GetRTPHeaderValue takes the packet, the start bit index and the
// end bit index and determines what the header value is. The header values
// are all in Big Endian, which makes things more complicated.
int version = GetRTPHeaderValue(packet, 0, 1);
int padding = GetRTPHeaderValue(packet, 2, 2);
int extension = GetRTPHeaderValue(packet, 3, 3);
int csrcCount = GetRTPHeaderValue(packet, 4, 7);
int marker = GetRTPHeaderValue(packet, 8, 8);
int payloadType = GetRTPHeaderValue(packet, 9, 15);
int sequenceNum = GetRTPHeaderValue(packet, 16, 31);
int timestamp = GetRTPHeaderValue(packet, 32, 63);
int ssrcId = GetRTPHeaderValue(packet, 64, 95);
int csrcid = GetRTPHeaderValue(packet, 96,96);
StringBuilder sb = new StringBuilder();
sb.Append(string.Format(" RtpPacket V:{0}, P:{1}, EX:{2}, CSRC:{3}, M:{4}, PT:{5}, SQ:{6}, TS:{7}, SSRC:{8}, CSRC:{9} \r\n", version, padding, extension, csrcCount, marker, payloadType, sequenceNum, timestamp, ssrcId,csrcid));
Debug.Write(sb.ToString());
//the packet payload starts at Offset 12 and the Payload lenght is packet.lenght without headersize
_stream.Write(packet, 12, packet.Length - 12);
}
}
private int GetRTPHeaderValue(byte[] packet, int startBit, int endBit)
{
int result = 0;
// Number of bits in value
int length = endBit - startBit + 1;
// Values in RTP header are big endian, so need to do these conversions
for (int i = startBit; i <= endBit; i++)
{
int byteIndex = i / 8;
int bitShift = 7 - (i % 8);
result += ((packet[byteIndex] >> bitShift) & 1) * (int)Math.Pow(2, length - i + startBit - 1);
}
return result;
}
public void StopClient()
{
// Tell listener thread that we are done listening.
_listening = false;
}
}
I'm still working on it, but still in testing phase. I hope that on end of week will be available public testing version for RTSP, HTTP, UDP and RTP protocols.
It's planned to be IPTV filter (used by MP TV Service) and OnlineVideos filter. But it can be used by any application using COM (e.g. I'm using GraphStudioNext for testing). Only thing which you MUST follow is URL formatting.
So, read carefully first post for reworked filter. Possibly you will not need to change anything, except deleting previous filter files and copying new filter files. Waiting for your test results