groupsock/Groupsock.cpp File Reference

#include "Groupsock.hh"
#include "GroupsockHelper.hh"
#include "TunnelEncaps.hh"
#include <strstream.h>
#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 538 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);
    if (sockets == NULL) break;

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

  return NULL;
}

static HashTable* getSocketTable

(

UsageEnvironment &

env

)

[static]

Definition at line 470 of file Groupsock.cpp.

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

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

                                                        {
  if (env.groupsockPriv == NULL) { // We need to create it
    env.groupsockPriv = HashTable::create(ONE_WORD_HASH_KEYS);
  }
  return (HashTable*)(env.groupsockPriv);
}

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

Definition at line 451 of file Groupsock.cpp.

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

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

Definition at line 504 of file Groupsock.cpp.

References HashTable::Add(), Socket::env(), False, getSocketTable(), HashTable::Lookup(), NULL, 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);
    if (sockets == NULL) break;

    // Make sure we're not replacing an existing Groupsock
    // 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 477 of file Groupsock.cpp.

References Socket::env(), False, getSocketTable(), HashTable::IsEmpty(), HashTable::Lookup(), NULL, 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());
    if (sockets == NULL) break;

    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;
      (gs->env()).groupsockPriv = NULL;
    }

    return True;
  } while (0);

  return False;
}

---