New Zealand
If I've understood correctly then the answer is yes.
New Zealand
publicRtspStatusCode SendRequest(RtspRequest request, out RtspResponse response)
{
response = null;
lock (_lockObject)
{
NetworkStream stream = null;
int retryCount = 0;
while (true)
{
try
{
if (_client == null)
{
_client = newTcpClient(_serverHost, _serverPort);
}
}
catch (Exception ex)
{
//this.LogError(ex, "RTSP: failed to connect to server");
returnRtspStatusCode.RequestTimeOut;
}
try
{
//this is new
if ((_client!= null)&&(!_client.Connected))
{
_client.Connect(IPAddress.Parse(_serverHost), _serverPort);
}
stream = _client.GetStream();
if (stream == null)
{
thrownewException();
}
break;
}
catch (Exception ex)
{
_client.Close();
_client = null;
if (retryCount == 1)
{
// this.LogError(ex, "RTSP: failed to open stream to server");
returnRtspStatusCode.RequestTimeOut;
}
retryCount++;
}
}
try
{
// Send the request and get the response.
request.Headers.Add("CSeq", _cseq.ToString());
_cseq++;
byte[] requestBytes = request.Serialise();
stream.Write(requestBytes, 0, requestBytes.Length);
byte[] responseBytes = newbyte[_client.ReceiveBufferSize];
int byteCount = stream.Read(responseBytes, 0, responseBytes.Length);
response = RtspResponse.Deserialise(responseBytes, byteCount);
// Did we get the whole response?
string contentLengthString;
int contentLength = 0;
if (response.Headers.TryGetValue("Content-Length", out contentLengthString))
{
contentLength = int.Parse(contentLengthString);
if ((string.IsNullOrEmpty(response.Body) && contentLength > 0) || response.Body.Length < contentLength)
{
if (response.Body == null)
{
response.Body = string.Empty;
}
while (byteCount > 0 && response.Body.Length < contentLength)
{
byteCount = stream.Read(responseBytes, 0, responseBytes.Length);
response.Body += System.Text.Encoding.UTF8.GetString(responseBytes, 0, byteCount);
}
}
}
return response.StatusCode;
}
finally
{
stream.Close();
}
}
}privatevoid Connect()
{
_rtspSocket = newSocket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
var ip = IPAddress.Parse(RtspDevice.Address);
var rtspEndpoint = newIPEndPoint(ip, 554);
_rtspSocket.Connect(rtspEndpoint);
}
privatevoid Disconnect()
{
if (_rtspSocket != null && _rtspSocket.Connected)
{
_rtspSocket.Shutdown(SocketShutdown.Both);
_rtspSocket.Close();
}
}
privatevoid SendRequest(RtspRequest request)
{
if (_rtspSocket == null)
{
}
try
{
request.Headers.Add("CSeq", _rtspSequenceNum.ToString());
_rtspSequenceNum++;
byte[] requestBytes = request.Serialise();
var requestBytesCount = _rtspSocket.Send(requestBytes, requestBytes.Length, SocketFlags.None);
if (requestBytesCount < 1)
{
}
}
catch (Exception e)
{
}
}
privatevoid ReceiveResponse(outRtspResponse response)
{
response = null;
var responseBytesCount = 0;
byte[] responseBytes = newbyte[1024];
try
{
responseBytesCount = _rtspSocket.Receive(responseBytes, responseBytes.Length, SocketFlags.None);
response = RtspResponse.Deserialise(responseBytes, responseBytesCount);
string contentLengthString;
int contentLength = 0;
if (response.Headers.TryGetValue("Content-Length", out contentLengthString))
{
contentLength = int.Parse(contentLengthString);
if ((string.IsNullOrEmpty(response.Body) && contentLength > 0) || response.Body.Length < contentLength)
{
if (response.Body == null)
{
response.Body = string.Empty;
}
while (responseBytesCount > 0 && response.Body.Length < contentLength)
{
responseBytesCount = _rtspSocket.Receive(responseBytes, responseBytes.Length, SocketFlags.None);
response.Body += System.Text.Encoding.UTF8.GetString(responseBytes, 0, responseBytesCount);
}
}
}
}
catch (SocketException)
{
}
}response._headers = new Dictionary<string, string>();
foreach (var headerInfo in headers.Select(header => header.Split( ':' )))
{
response._headers.Add(headerInfo[0], headerInfo[1].Trim());
}response._headers = new Dictionary<string, string>();
foreach (var headerInfo in headers.Select(header => header.Split(new char[] { ':' }, 2)))
{
response._headers.Add(headerInfo[0], headerInfo[1].Trim());
}