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 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 160 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 78 of file RTPInterface.cpp.

References HashTable::Add(), env, _Tables::getOurTables(), HashTable::IsEmpty(), 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) {
    if (createIfNotFound) {
      socketDescriptor = new SocketDescriptor(env, sockNum);
      table->Add((char const*)(long)(sockNum), socketDescriptor);
    } else if (table->IsEmpty()) {
      // We can also delete the table (to reclaim space):
      _Tables* ourTables = _Tables::getOurTables(env);
      delete table;
      ourTables->socketTable = NULL;
      ourTables->reclaimIfPossible();
    }
  }

  return socketDescriptor;
}

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

Definition at line 100 of file RTPInterface.cpp.

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

Referenced by SocketDescriptor::~SocketDescriptor().

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

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

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

---