OpenDDS::Federator::InfoRepoMulticastResponder Class Reference

Event Handler that services multicast requests for IOR of a bootstrappable service. More...

#include <InfoRepoMulticastResponder.h>

List of all members.

Public Member Functions
	InfoRepoMulticastResponder ()
	Constructor.
virtual	~InfoRepoMulticastResponder ()
	Destructor.
int	init (CORBA::ORB_ptr orb, u_short port, const char *mcast_addr)
	Initialization method.
int	init (CORBA::ORB_ptr orb, const char *mcast_addr)
virtual int	handle_input (ACE_HANDLE n)
	Callback when input is received on the handle.
virtual int	handle_timeout (const ACE_Time_Value &tv, const void *arg)
	Callback when a timeout has occurred.
virtual ACE_HANDLE	get_handle () const
	Returns the internal handle used to receive multicast.
Private Member Functions
int	common_init (CORBA::ORB_ptr orb)
	Factor common functionality from the two init functions.
Private Attributes
bool	initialized_
	Are we initialized?
CORBA::ORB_var	orb_
	The ORB.
ACE_SOCK_Dgram_Mcast	mcast_dgram_
	multicast endpoint of communication
ACE_INET_Addr	mcast_addr_
	multicast address
ACE_INET_Addr	response_addr_
	address of response.
ACE_SOCK_Dgram	response_
	socket for response to the multicast
ACE_CString	mcast_nic_

---

Detailed Description

Event Handler that services multicast requests for IOR of a bootstrappable service.

This class uses the ACE_SOCK_Dgram_Mcast class and should be registered with a reactor and should be initialized with the ior of the service to be multicasted.

Definition at line 38 of file InfoRepoMulticastResponder.h.

---

Constructor & Destructor Documentation

OpenDDS::Federator::InfoRepoMulticastResponder::InfoRepoMulticastResponder

(

)

Constructor.

Definition at line 23 of file InfoRepoMulticastResponder.cpp.

  : initialized_(false)
{
}

OpenDDS::Federator::InfoRepoMulticastResponder::~InfoRepoMulticastResponder

(

)

[virtual]

Destructor.

Definition at line 28 of file InfoRepoMulticastResponder.cpp.

{
  if (
    this->initialized_ &&
    (this->mcast_dgram_.leave(this->mcast_addr_) == -1)) {
    ACE_ERROR((LM_ERROR, "%p\n", ACE_TEXT("~InfoRepoMulticastResponder()")));
  }
}

---

Member Function Documentation

int OpenDDS::Federator::InfoRepoMulticastResponder::common_init

(

CORBA::ORB_ptr

orb

)

[private]

Factor common functionality from the two init functions.

Definition at line 105 of file InfoRepoMulticastResponder.cpp.

References initialized_, mcast_dgram_, and orb_.

Referenced by init().

{
  orb_ = CORBA::ORB::_duplicate(orb);

  if (this->response_addr_.set((u_short) 0) == -1)
    ACE_ERROR_RETURN((LM_ERROR,
                      "InfoRepoMulticastResponder::common_init() %p\n",
                      ACE_TEXT("set")),
                     -1);

  else if (this->response_.open(this->response_addr_) == -1) {
    ACE_ERROR_RETURN((LM_ERROR,
                      "%p\n",
                      ACE_TEXT("set")),
                     -1);
  }

  // Use ACE_SOCK_Dgram_Mcast factory to subscribe to multicast group.
#ifdef ACE_HAS_MAC_OSX
  mcast_dgram_.opts(ACE_SOCK_Dgram_Mcast::OPT_BINDADDR_NO |
                    ACE_SOCK_Dgram_Mcast::DEFOPT_NULLIFACE);
#endif
  if (this->mcast_nic_.length() != 0) {
    if (this->mcast_dgram_.join(this->mcast_addr_,
                                1,
                                ACE_TEXT_CHAR_TO_TCHAR(this->mcast_nic_.c_str())) == -1)
      ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::common_init() %p\n",
                        ACE_TEXT("subscribe")), -1);

  } else {
    if (this->mcast_dgram_.join(this->mcast_addr_) == -1)
      ACE_ERROR_RETURN((LM_ERROR,
                        "InfoRepoMulticastResponder::common_init() %p\n",
                        ACE_TEXT("subscribe")),
                       -1);
  }

  this->initialized_ = true;
  return 0;
}

ACE_HANDLE OpenDDS::Federator::InfoRepoMulticastResponder::get_handle

(

)

const [virtual]

Returns the internal handle used to receive multicast.

Definition at line 38 of file InfoRepoMulticastResponder.cpp.

References mcast_dgram_.

{
  return this->mcast_dgram_.get_handle();
}

int OpenDDS::Federator::InfoRepoMulticastResponder::handle_input

(

ACE_HANDLE

n

)

[virtual]

Callback when input is received on the handle.

Definition at line 155 of file InfoRepoMulticastResponder.cpp.

References OpenDDS::DCPS::DCPS_debug_level, header, mcast_dgram_, and orb_.

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0)
    ACE_DEBUG((LM_DEBUG, "Entered InfoRepoMulticastResponder::handle_input\n"));

  // The length of the service name string that follows.
  CORBA::Short header;
  // Port to which to reply.
  ACE_UINT16 remote_port;
  // Name of the service for which the client is looking.
  char object_key[BUFSIZ];

  ACE_INET_Addr remote_addr;

  // Take a peek at the header to find out how long is the service
  // name string we should receive.
  ssize_t n = this->mcast_dgram_.recv(&header,
                                      sizeof(header),
                                      remote_addr,
                                      MSG_PEEK);

  if (n <= 0)
    ACE_ERROR_RETURN((LM_ERROR,
                      "InfoRepoMulticastResponder::handle_input - peek %d\n",
                      n),
                     0);

  else if (ACE_NTOHS(header) <= 0)
    ACE_ERROR_RETURN((LM_ERROR,
                      "InfoRepoMulticastResponder::handle_input() Header value < 1\n"),
                     0);

  // Receive full client multicast request.
  const int iovcnt = 3;
  iovec iov[iovcnt];

  iov[0].iov_base = (char *) &header;
  iov[0].iov_len  = sizeof(header);
  iov[1].iov_base = (char *) &remote_port;
  iov[1].iov_len  = sizeof(ACE_UINT16);
  iov[2].iov_base = (char *) object_key;
  iov[2].iov_len  = ACE_NTOHS(header);

  // Read the iovec.
  n = this->mcast_dgram_.recv(iov,
                              iovcnt,
                              remote_addr);

  if (n <= 0)
    ACE_ERROR_RETURN((LM_ERROR,
                      "InfoRepoMulticastResponder::handle_input recv = %d\n",
                      n),
                     0);

  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_TCHAR addr[64];
    remote_addr.addr_to_string(addr, sizeof(addr));
    ACE_DEBUG((LM_DEBUG,
               "(%P|%t) Received multicast from %s.\n"
               "Service Name received : %C\n"
               "Port received : %u\n",
               addr,
               object_key,
               ACE_NTOHS(remote_port)));
  }

  // Grab the IOR table.
  CORBA::Object_var table_object =
    orb_->resolve_initial_references("IORTable");

  IORTable::Locator_var locator =
    IORTable::Locator::_narrow(table_object.in());

  if (CORBA::is_nil(locator.in())) {
    ACE_ERROR((LM_ERROR, ACE_TEXT("Nil IORTable\n")));

  }

  std::string ior;

  {
    CORBA::String_var ior_result;

    try {
      ior_result = locator->locate(object_key);

    } catch (const IORTable::NotFound&) {
      ACE_ERROR_RETURN((LM_ERROR,
                        "InfoRepoMulticastResponder::handle_input() Object key not found\n"),
                       0);
    }

    ior = ior_result;
  }

  // Reply to the multicast message.
  ACE_SOCK_Connector connector;
  ACE_INET_Addr peer_addr;
  ACE_SOCK_Stream stream;

  peer_addr.set(remote_addr);
  peer_addr.set_port_number(ACE_NTOHS(remote_port));

#if defined (ACE_HAS_IPV6)

  if (peer_addr.is_linklocal()) {
    // If this is one of our local linklocal interfaces this is not going
    // to work.
    // Creating a connection using such interface to the client listening
    // at the IPv6 ANY address is not going to work (I'm not quite sure why
    // but it probably has to do with the rather restrictive routing rules
    // for linklocal interfaces).
    // So we see if this is one of our local interfaces and if so create the
    // connection using the IPv6 loopback address instead.
    ACE_INET_Addr  peer_tmp(peer_addr);
    peer_tmp.set_port_number(static_cast<u_short>(0));
    ACE_INET_Addr* tmp = 0;
    size_t cnt = 0;
    int err = ACE::get_ip_interfaces(cnt, tmp);

    if (err == 0) {
      for (size_t i = 0; i < cnt; ++i) {
        if (peer_tmp == tmp[i]) {
          peer_addr.set(ACE_NTOHS(remote_port),
                        ACE_IPV6_LOCALHOST);
          break;
        }
      }

      delete[] tmp;
    }
  }

#endif /* ACE_HAS_IPV6 */

  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_TCHAR addr[64];
    peer_addr.addr_to_string(addr, sizeof(addr));
    ACE_DEBUG((LM_DEBUG,
               "(%P|%t) Replying to peer %s.\n",
               addr));
  }

  // Connect.
  if (connector.connect(stream, peer_addr) == -1)
    ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::connect failed\n"), 0);

  // Send the IOR back to the client.  (Send iovec, which contains ior
  // length as the first element, and ior itself as the second.)

  // Length of ior to be sent.
  CORBA::Short data_len = ACE_HTONS(static_cast<CORBA::Short>(ior.length()) + 1);

  // Vector to be sent.
  const int cnt = 2;
  iovec iovp[cnt];

  // The length of ior to be sent.
  iovp[0].iov_base = (char *) &data_len;
  iovp[0].iov_len  = sizeof(CORBA::Short);

  // The ior.
  iovp[1].iov_base = const_cast<char*>(ior.c_str());
  iovp[1].iov_len  = static_cast<u_long>(ior.length() + 1);

  ssize_t result = stream.sendv_n(iovp, cnt);
  // Close the stream.
  stream.close();

  // Check for error.
  if (result == -1)
    ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::send failed\n"), 0);

  if (OpenDDS::DCPS::DCPS_debug_level > 0)
    ACE_DEBUG((LM_DEBUG,
               "(%P|%t) InfoRepoMulticastResponder::handle_input() ior: <%C>\n"
               "sent to %C:%u.\n"
               "result from send = %d\n",
               ior.c_str(),
               peer_addr.get_host_name(),
               peer_addr.get_port_number(),
               result));

  return 0;
}

int OpenDDS::Federator::InfoRepoMulticastResponder::handle_timeout	(	const ACE_Time_Value &	tv,
		const void *	arg
	)			[virtual]

Callback when a timeout has occurred.

Definition at line 148 of file InfoRepoMulticastResponder.cpp.

{
  return 0;
}

int OpenDDS::Federator::InfoRepoMulticastResponder::init	(	CORBA::ORB_ptr	orb,
		const char *	mcast_addr
	)

Initialization method. Takes in "address:port" string as a parameter.

Save for use later.

Definition at line 60 of file InfoRepoMulticastResponder.cpp.

References common_init(), mcast_nic_, and CORBA::string_alloc().

{
  if (this->initialized_) {
    ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::init() already initialized\n"), -1);
  }

  // Look for a '@' incase a nic is specified.
  const char* tmpnic = ACE_OS::strchr(mcast_addr, '@');

  CORBA::String_var actual_mcast_addr;
  CORBA::ULong length_addr;

  if (tmpnic != 0) {
    // i.e. a nic name has been specified
    length_addr = static_cast<CORBA::ULong>(tmpnic - mcast_addr + 1);
    actual_mcast_addr = CORBA::string_alloc(length_addr);

    ACE_OS::strncpy(actual_mcast_addr.inout(),
                    mcast_addr,
                    length_addr - 1);

    actual_mcast_addr[length_addr - 1] = '\0';

    /// Save for use later.
    this->mcast_nic_ = tmpnic + 1;

  } else {
    actual_mcast_addr =
      CORBA::string_alloc(static_cast<CORBA::ULong>(ACE_OS::strlen(mcast_addr)));

    actual_mcast_addr = mcast_addr;
  }

  if (this->mcast_addr_.set(actual_mcast_addr.in()) == -1)
    ACE_ERROR_RETURN((LM_ERROR,
                      "%p\n",
                      ACE_TEXT("set")),
                     -1);

  return common_init(orb);
}

int OpenDDS::Federator::InfoRepoMulticastResponder::init	(	CORBA::ORB_ptr	orb,
		u_short	port,
		const char *	mcast_addr
	)

Initialization method.

Definition at line 44 of file InfoRepoMulticastResponder.cpp.

References common_init().

{
  if (this->initialized_) {
    ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::init() already initialized\n"), -1);
  }

  if (this->mcast_addr_.set(port, mcast_addr) == -1)
    ACE_ERROR_RETURN((LM_ERROR, "InfoRepoMulticastResponder::init() %p\n", ACE_TEXT("set")), -1);

  return common_init(orb);
}

---

Member Data Documentation

bool OpenDDS::Federator::InfoRepoMulticastResponder::initialized_ [private]

Are we initialized?

Definition at line 74 of file InfoRepoMulticastResponder.h.

Referenced by common_init().

ACE_INET_Addr OpenDDS::Federator::InfoRepoMulticastResponder::mcast_addr_ [private]

multicast address

Definition at line 83 of file InfoRepoMulticastResponder.h.

ACE_SOCK_Dgram_Mcast OpenDDS::Federator::InfoRepoMulticastResponder::mcast_dgram_ [private]

multicast endpoint of communication

Definition at line 80 of file InfoRepoMulticastResponder.h.

Referenced by common_init(), get_handle(), and handle_input().

ACE_CString OpenDDS::Federator::InfoRepoMulticastResponder::mcast_nic_ [private]

Definition at line 91 of file InfoRepoMulticastResponder.h.

Referenced by init().

CORBA::ORB_var OpenDDS::Federator::InfoRepoMulticastResponder::orb_ [private]

The ORB.

Definition at line 77 of file InfoRepoMulticastResponder.h.

Referenced by common_init(), and handle_input().

ACE_SOCK_Dgram OpenDDS::Federator::InfoRepoMulticastResponder::response_ [private]

socket for response to the multicast

Definition at line 89 of file InfoRepoMulticastResponder.h.

ACE_INET_Addr OpenDDS::Federator::InfoRepoMulticastResponder::response_addr_ [private]

address of response.

Definition at line 86 of file InfoRepoMulticastResponder.h.

---

The documentation for this class was generated from the following files:

• InfoRepoMulticastResponder.h
• InfoRepoMulticastResponder.cpp

---