liveMedia/RTPInterface.cpp File Reference

#include "RTPInterface.hh"
#include <GroupsockHelper.hh>
#include <stdio.h>

Include dependency graph for RTPInterface.cpp:

Go to the source code of this file.

Data Structures
class	SocketDescriptor
Functions
static Boolean	sendRTPOverTCP (unsigned char *packet, unsigned packetSize, int socketNum, unsigned char streamChannelId)
static HashTable *	socketHashTable (UsageEnvironment &env, Boolean createIfNotPresent=True)
static SocketDescriptor *	lookupSocketDescriptor (UsageEnvironment &env, int sockNum, Boolean createIfNotFound=True)
static void	removeSocketDescription (UsageEnvironment &env, int sockNum)
static void	deregisterSocket (UsageEnvironment &env, int sockNum, unsigned char streamChannelId)

---

Function Documentation

static void deregisterSocket	(	UsageEnvironment &	env,
		int	sockNum,
		unsigned char	streamChannelId
	)			[static]

Definition at line 154 of file RTPInterface.cpp.

References SocketDescriptor::deregisterRTPInterface(), env, False, lookupSocketDescriptor(), and NULL.

Referenced by RTPInterface::removeStreamSocket(), and RTPInterface::stopNetworkReading().

                                                                                                {
  SocketDescriptor* socketDescriptor = lookupSocketDescriptor(env, sockNum, False);
  if (socketDescriptor != NULL) {
    socketDescriptor->deregisterRTPInterface(streamChannelId);
        // Note: This may delete "socketDescriptor",
        // if no more interfaces are using this socket
  }
}

static SocketDescriptor* lookupSocketDescriptor	(	UsageEnvironment &	env,
		int	sockNum,
		Boolean	createIfNotFound = True
	)			[static]

Definition at line 80 of file RTPInterface.cpp.

References HashTable::Add(), env, HashTable::Lookup(), NULL, and socketHashTable().

Referenced by deregisterSocket(), RTPInterface::setServerRequestAlternativeByteHandler(), and RTPInterface::startNetworkReading().

                                                                                                                     {
  HashTable* table = socketHashTable(env, createIfNotFound);
  if (table == NULL) return NULL;

  char const* key = (char const*)(long)sockNum;
  SocketDescriptor* socketDescriptor = (SocketDescriptor*)(table->Lookup(key));
  if (socketDescriptor == NULL && createIfNotFound) {
    socketDescriptor = new SocketDescriptor(env, sockNum);
    table->Add((char const*)(long)(sockNum), socketDescriptor);
  }

  return socketDescriptor;
}

static void removeSocketDescription	(	UsageEnvironment &	env,
		int	sockNum
	)			[static]

Definition at line 94 of file RTPInterface.cpp.

References env, _Tables::getOurTables(), HashTable::IsEmpty(), NULL, HashTable::Remove(), and socketHashTable().

Referenced by SocketDescriptor::deregisterRTPInterface().

                                                                        {
  char const* key = (char const*)(long)sockNum;
  HashTable* table = socketHashTable(env);
  table->Remove(key);

  if (table->IsEmpty()) {
    // We can also delete the table (to reclaim space):
    _Tables* ourTables = _Tables::getOurTables(env);
    delete table;
    ourTables->socketTable = NULL;
    ourTables->reclaimIfPossible();
  }
}

Boolean sendRTPOverTCP	(	unsigned char *	packet,
		unsigned	packetSize,
		int	socketNum,
		unsigned char	streamChannelId
	)			[static]

Definition at line 280 of file RTPInterface.cpp.

References False, and True.

Referenced by RTPInterface::sendPacket().

                                                                  {
#ifdef DEBUG
  fprintf(stderr, "sendRTPOverTCP: %d bytes over channel %d (socket %d)\n",
          packetSize, streamChannelId, socketNum); fflush(stderr);
#endif
  // Send RTP over TCP, using the encoding defined in
  // RFC 2326, section 10.12:
  do {
    char const dollar = '$';
    if (send(socketNum, &dollar, 1, 0) != 1) break;
    if (send(socketNum, (char*)&streamChannelId, 1, 0) != 1) break;

    char netPacketSize[2];
    netPacketSize[0] = (char) ((packetSize&0xFF00)>>8);
    netPacketSize[1] = (char) (packetSize&0xFF);
    if (send(socketNum, netPacketSize, 2, 0) != 2) break;

    if (send(socketNum, (char*)packet, packetSize, 0) != (int)packetSize) break;

#ifdef DEBUG
    fprintf(stderr, "sendRTPOverTCP: completed\n"); fflush(stderr);
#endif

    return True;
  } while (0);

#ifdef DEBUG
  fprintf(stderr, "sendRTPOverTCP: failed!\n"); fflush(stderr);
#endif
  return False;
}

static HashTable* socketHashTable	(	UsageEnvironment &	env,
		Boolean	createIfNotPresent = True
	)			[static]

Definition at line 40 of file RTPInterface.cpp.

References HashTable::create(), env, _Tables::getOurTables(), NULL, ONE_WORD_HASH_KEYS, and _Tables::socketTable.

Referenced by MediaSubsession::initiate(), lookupSocketDescriptor(), and removeSocketDescription().

                                                                                            {
  _Tables* ourTables = _Tables::getOurTables(env, createIfNotPresent);
  if (ourTables == NULL) return NULL;

  if (ourTables->socketTable == NULL) {
    // Create a new socket number -> SocketDescriptor mapping table:
    ourTables->socketTable = HashTable::create(ONE_WORD_HASH_KEYS);
  }
  return (HashTable*)(ourTables->socketTable);
}

---