groupsock/Groupsock.cpp File Reference

#include "Groupsock.hh"
#include "GroupsockHelper.hh"
#include "TunnelEncaps.hh"
#include <sstream>
#include <stdio.h>

Include dependency graph for Groupsock.cpp:

Go to the source code of this file.

Functions
UsageEnvironment &	operator<< (UsageEnvironment &s, const Groupsock &g)
static HashTable *&	getSocketTable (UsageEnvironment &env)
static Boolean	unsetGroupsockBySocket (Groupsock const *groupsock)
static Boolean	setGroupsockBySocket (UsageEnvironment &env, int sock, Groupsock *groupsock)
static Groupsock *	getGroupsockBySocket (UsageEnvironment &env, int sock)

---

Function Documentation

static Groupsock* getGroupsockBySocket	(	UsageEnvironment &	env,
		int	sock
	)			[static]

Definition at line 531 of file Groupsock.cpp.

References Socket::env(), getSocketTable(), HashTable::Lookup(), and NULL.

Referenced by GroupsockLookupTable::Lookup().

                                                                        {
  do {
    // Make sure the "sock" parameter is in bounds:
    if (sock < 0) break;

    HashTable* sockets = getSocketTable(env);
    return (Groupsock*)sockets->Lookup((char*)(long)sock);
  } while (0);

  return NULL;
}

static HashTable*& getSocketTable

(

UsageEnvironment &

env

)

[static]

Definition at line 465 of file Groupsock.cpp.

References HashTable::create(), Socket::env(), groupsockPriv(), NULL, ONE_WORD_HASH_KEYS, and _groupsockPriv::socketTable.

Referenced by getGroupsockBySocket(), setGroupsockBySocket(), and unsetGroupsockBySocket().

                                                         {
  _groupsockPriv* priv = groupsockPriv(env);
  if (priv->socketTable == NULL) { // We need to create it
    priv->socketTable = HashTable::create(ONE_WORD_HASH_KEYS);
  }
  return priv->socketTable;
}

UsageEnvironment& operator<<	(	UsageEnvironment &	s,
		const Groupsock &	g
	)

Definition at line 446 of file Groupsock.cpp.

                                                                      {
  UsageEnvironment& s1 = s << timestampString() << " Groupsock("
                           << g.socketNum() << ": "
                           << AddressString(g.groupAddress()).val()
                           << ", " << g.port() << ", ";
  if (g.isSSM()) {
    return s1 << "SSM source: "
              <<  AddressString(g.sourceFilterAddress()).val() << ")";
  } else {
    return s1 << (unsigned)(g.ttl()) << ")";
  }
}

static Boolean setGroupsockBySocket	(	UsageEnvironment &	env,
		int	sock,
		Groupsock *	groupsock
	)			[static]

Definition at line 499 of file Groupsock.cpp.

References HashTable::Add(), Socket::env(), False, getSocketTable(), HashTable::Lookup(), UsageEnvironment::setResultMsg(), and True.

Referenced by GroupsockLookupTable::AddNew().

                                                          {
  do {
    // Make sure the "sock" parameter is in bounds:
    if (sock < 0) {
      char buf[100];
      sprintf(buf, "trying to use bad socket (%d)", sock);
      env.setResultMsg(buf);
      break;
    }

    HashTable* sockets = getSocketTable(env);

    // Make sure we're not replacing an existing Groupsock (although that shouldn't happen)
    Boolean alreadyExists
      = (sockets->Lookup((char*)(long)sock) != 0);
    if (alreadyExists) {
      char buf[100];
      sprintf(buf,
              "Attempting to replace an existing socket (%d",
              sock);
      env.setResultMsg(buf);
      break;
    }

    sockets->Add((char*)(long)sock, groupsock);
    return True;
  } while (0);

  return False;
}

static Boolean unsetGroupsockBySocket

(

Groupsock const *

groupsock

)

[static]

Definition at line 473 of file Groupsock.cpp.

References Socket::env(), False, getSocketTable(), HashTable::IsEmpty(), HashTable::Lookup(), NULL, reclaimGroupsockPriv(), HashTable::Remove(), Socket::socketNum(), and True.

Referenced by GroupsockLookupTable::Remove().

                                                                  {
  do {
    if (groupsock == NULL) break;

    int sock = groupsock->socketNum();
    // Make sure "sock" is in bounds:
    if (sock < 0) break;

    HashTable*& sockets = getSocketTable(groupsock->env());

    Groupsock* gs = (Groupsock*)sockets->Lookup((char*)(long)sock);
    if (gs == NULL || gs != groupsock) break;
    sockets->Remove((char*)(long)sock);

    if (sockets->IsEmpty()) {
      // We can also delete the table (to reclaim space):
      delete sockets; sockets = NULL;
      reclaimGroupsockPriv(gs->env());
    }

    return True;
  } while (0);

  return False;
}

---