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 void	sendRTPOverTCP (unsigned char *packet, unsigned packetSize, int socketNum, unsigned char streamChannelId)
static HashTable *	socketHashTable (UsageEnvironment &env)
static SocketDescriptor *	lookupSocketDescriptor (UsageEnvironment &env, int sockNum)
static void	removeSocketDescription (UsageEnvironment &env, int sockNum)
Variables
Boolean	RTPOverTCP_OK = True

---

Function Documentation

static SocketDescriptor* lookupSocketDescriptor	(	UsageEnvironment &	env,
		int	sockNum
	)			[static]

Definition at line 68 of file RTPInterface.cpp.

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

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

                                                             {
  char const* key = (char const*)(long)sockNum;
  return (SocketDescriptor*)(socketHashTable(env)->Lookup(key));
}

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

Definition at line 74 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();
  }
}

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

Definition at line 245 of file RTPInterface.cpp.

References False, and RTPOverTCP_OK.

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;
  } while (0);

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

static HashTable* socketHashTable

(

UsageEnvironment &

env

)

[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 lookupSocketDescriptor(), removeSocketDescription(), and RTPInterface::startNetworkReading().

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

---

Variable Documentation

Boolean RTPOverTCP_OK = True

Definition at line 109 of file RTPInterface.cpp.

Referenced by RTPInterface::addStreamSocket(), RTPInterface::handleRead(), and sendRTPOverTCP().

---