liveMedia/RTSPServer.cpp File Reference

#include "RTSPServer.hh"
#include "RTSPCommon.hh"
#include "Base64.hh"
#include <GroupsockHelper.hh>
#include <signal.h>

Include dependency graph for RTSPServer.cpp:

Go to the source code of this file.

Defines
#define	USE_SIGNALS   1
#define	LISTEN_BACKLOG_SIZE   20
Enumerations
enum	StreamingMode { RTP_UDP, RTP_TCP, RAW_UDP }
Functions
static void	parseTransportHeader (char const *buf, StreamingMode &streamingMode, char *&streamingModeString, char *&destinationAddressStr, u_int8_t &destinationTTL, portNumBits &clientRTPPortNum, portNumBits &clientRTCPPortNum, unsigned char &rtpChannelId, unsigned char &rtcpChannelId)
static Boolean	parsePlayNowHeader (char const *buf)
static Boolean	parseScaleHeader (char const *buf, float &scale)
static void	lookForHeader (char const *headerName, char const *source, unsigned sourceLen, char *resultStr, unsigned resultMaxSize)
static Boolean	parseAuthorizationHeader (char const *buf, char const *&username, char const *&realm, char const *&nonce, char const *&uri, char const *&response)
Variables
static char const *	allowedCommandNames = "OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE, GET_PARAMETER, SET_PARAMETER"

---

Define Documentation

#define LISTEN_BACKLOG_SIZE   20

Definition at line 150 of file RTSPServer.cpp.

Referenced by RTSPServer::setUpOurSocket().

#define USE_SIGNALS   1

Definition at line 29 of file RTSPServer.cpp.

---

Enumeration Type Documentation

enum StreamingMode

Enumerator:

RTP_UDP
RTP_TCP
RAW_UDP

Definition at line 661 of file RTSPServer.cpp.

                           {
  RTP_UDP,
  RTP_TCP,
  RAW_UDP
} StreamingMode;

---

Function Documentation

static void lookForHeader	(	char const *	headerName,
		char const *	source,
		unsigned	sourceLen,
		char *	resultStr,
		unsigned	resultMaxSize
	)			[static]

Definition at line 1267 of file RTSPServer.cpp.

Referenced by RTSPServer::RTSPClientSession::parseHTTPRequestString().

                                                                                                                                   {
  resultStr[0] = '\0';  // by default, return an empty string
  unsigned headerNameLen = strlen(headerName);
  for (int i = 0; i < (int)(sourceLen-headerNameLen); ++i) {
    if (strncmp(&source[i], headerName, headerNameLen) == 0 && source[i+headerNameLen] == ':') {
      // We found the header.  Skip over any whitespace, then copy the rest of the line to "resultStr":
      for (i += headerNameLen+1; i < (int)sourceLen && (source[i] == ' ' || source[i] == '\t'); ++i) {}
      for (unsigned j = i; j < sourceLen; ++j) {
        if (source[j] == '\r' || source[j] == '\n') {
          // We've found the end of the line.  Copy it to the result (if it will fit):
          if (j-i+1 > resultMaxSize) break;
          char const* resultSource = &source[i];
          char const* resultSourceEnd = &source[j];
          while (resultSource < resultSourceEnd) *resultStr++ = *resultSource++;
          *resultStr = '\0';
          break;
        }
      }
    }
  }
}

static Boolean parseAuthorizationHeader	(	char const *	buf,
		char const *&	username,
		char const *&	realm,
		char const *&	nonce,
		char const *&	uri,
		char const *&	response
	)			[static]

Definition at line 1402 of file RTSPServer.cpp.

References _strncasecmp, False, NULL, strDup(), strDupSize(), and True.

Referenced by RTSPServer::RTSPClientSession::authenticationOK().

                                                               {
  // Initialize the result parameters to default values:
  username = realm = nonce = uri = response = NULL;

  // First, find "Authorization:"
  while (1) {
    if (*buf == '\0') return False; // not found
    if (_strncasecmp(buf, "Authorization: Digest ", 22) == 0) break;
    ++buf;
  }

  // Then, run through each of the fields, looking for ones we handle:
  char const* fields = buf + 22;
  while (*fields == ' ') ++fields;
  char* parameter = strDupSize(fields);
  char* value = strDupSize(fields);
  while (1) {
    value[0] = '\0';
    if (sscanf(fields, "%[^=]=\"%[^\"]\"", parameter, value) != 2 &&
        sscanf(fields, "%[^=]=\"\"", parameter) != 1) {
      break;
    }
    if (strcmp(parameter, "username") == 0) {
      username = strDup(value);
    } else if (strcmp(parameter, "realm") == 0) {
      realm = strDup(value);
    } else if (strcmp(parameter, "nonce") == 0) {
      nonce = strDup(value);
    } else if (strcmp(parameter, "uri") == 0) {
      uri = strDup(value);
    } else if (strcmp(parameter, "response") == 0) {
      response = strDup(value);
    }

    fields += strlen(parameter) + 2 /*="*/ + strlen(value) + 1 /*"*/;
    while (*fields == ',' || *fields == ' ') ++fields;
        // skip over any separating ',' and ' ' chars
    if (*fields == '\0' || *fields == '\r' || *fields == '\n') break;
  }
  delete[] parameter; delete[] value;
  return True;
}

static Boolean parsePlayNowHeader

(

char const *

buf

)

[static]

Definition at line 729 of file RTSPServer.cpp.

References _strncasecmp, False, and True.

Referenced by RTSPServer::RTSPClientSession::handleCmd_SETUP().

                                                   {
  // Find "x-playNow:" header, if present
  while (1) {
    if (*buf == '\0') return False; // not found
    if (_strncasecmp(buf, "x-playNow:", 10) == 0) break;
    ++buf;
  }

  return True;
}

static Boolean parseScaleHeader	(	char const *	buf,
		float &	scale
	)			[static]

Definition at line 1046 of file RTSPServer.cpp.

References _strncasecmp, False, and True.

Referenced by RTSPServer::RTSPClientSession::handleCmd_PLAY().

                                                               {
  // Initialize the result parameter to a default value:
  scale = 1.0;

  // First, find "Scale:"
  while (1) {
    if (*buf == '\0') return False; // not found
    if (_strncasecmp(buf, "Scale: ", 7) == 0) break;
    ++buf;
  }

  // Then, run through each of the fields, looking for ones we handle:
  char const* fields = buf + 7;
  while (*fields == ' ') ++fields;
  float sc;
  if (sscanf(fields, "%f", &sc) == 1) {
    scale = sc;
  } else {
    return False; // The header is malformed
  }

  return True;
}

static void parseTransportHeader	(	char const *	buf,
		StreamingMode &	streamingMode,
		char *&	streamingModeString,
		char *&	destinationAddressStr,
		u_int8_t &	destinationTTL,
		portNumBits &	clientRTPPortNum,
		portNumBits &	clientRTCPPortNum,
		unsigned char &	rtpChannelId,
		unsigned char &	rtcpChannelId
	)			[static]

Definition at line 667 of file RTSPServer.cpp.

References _strncasecmp, NULL, RAW_UDP, RTP_TCP, RTP_UDP, strDup(), and strDupSize().

Referenced by RTSPServer::RTSPClientSession::handleCmd_SETUP().

                                   {
  // Initialize the result parameters to default values:
  streamingMode = RTP_UDP;
  streamingModeString = NULL;
  destinationAddressStr = NULL;
  destinationTTL = 255;
  clientRTPPortNum = 0;
  clientRTCPPortNum = 1;
  rtpChannelId = rtcpChannelId = 0xFF;

  portNumBits p1, p2;
  unsigned ttl, rtpCid, rtcpCid;

  // First, find "Transport:"
  while (1) {
    if (*buf == '\0') return; // not found
    if (_strncasecmp(buf, "Transport: ", 11) == 0) break;
    ++buf;
  }

  // Then, run through each of the fields, looking for ones we handle:
  char const* fields = buf + 11;
  char* field = strDupSize(fields);
  while (sscanf(fields, "%[^;]", field) == 1) {
    if (strcmp(field, "RTP/AVP/TCP") == 0) {
      streamingMode = RTP_TCP;
    } else if (strcmp(field, "RAW/RAW/UDP") == 0 ||
               strcmp(field, "MP2T/H2221/UDP") == 0) {
      streamingMode = RAW_UDP;
      streamingModeString = strDup(field);
    } else if (_strncasecmp(field, "destination=", 12) == 0) {
      delete[] destinationAddressStr;
      destinationAddressStr = strDup(field+12);
    } else if (sscanf(field, "ttl%u", &ttl) == 1) {
      destinationTTL = (u_int8_t)ttl;
    } else if (sscanf(field, "client_port=%hu-%hu", &p1, &p2) == 2) {
        clientRTPPortNum = p1;
        clientRTCPPortNum = streamingMode == RAW_UDP ? 0 : p2; // ignore the second port number if the client asked for raw UDP
    } else if (sscanf(field, "client_port=%hu", &p1) == 1) {
        clientRTPPortNum = p1;
        clientRTCPPortNum = streamingMode == RAW_UDP ? 0 : p1 + 1;
    } else if (sscanf(field, "interleaved=%u-%u", &rtpCid, &rtcpCid) == 2) {
      rtpChannelId = (unsigned char)rtpCid;
      rtcpChannelId = (unsigned char)rtcpCid;
    }

    fields += strlen(field);
    while (*fields == ';') ++fields; // skip over separating ';' chars
    if (*fields == '\0' || *fields == '\r' || *fields == '\n') break;
  }
  delete[] field;
}

---

Variable Documentation

char const* allowedCommandNames = "OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE, GET_PARAMETER, SET_PARAMETER" [static]

Definition at line 557 of file RTSPServer.cpp.

Referenced by RTSPServer::RTSPClientSession::handleCmd_bad(), RTSPServer::RTSPClientSession::handleCmd_notSupported(), and RTSPServer::RTSPClientSession::handleCmd_OPTIONS().

---