OpenDDS::DCPS::MulticastReceiveStrategy Class Reference

#include <MulticastReceiveStrategy.h>

Inheritance diagram for OpenDDS::DCPS::MulticastReceiveStrategy:

[legend]

Collaboration diagram for OpenDDS::DCPS::MulticastReceiveStrategy:

[legend]

List of all members.

Public Member Functions
	MulticastReceiveStrategy (MulticastDataLink *link)
virtual ACE_HANDLE	get_handle () const
virtual int	handle_input (ACE_HANDLE fd)
Protected Member Functions
virtual ssize_t	receive_bytes (iovec iov[], int n, ACE_INET_Addr &remote_address, ACE_HANDLE fd)
	Only our subclass knows how to do this.
virtual bool	check_header (const TransportHeader &header)
	Check the transport header for suitability.
virtual bool	check_header (const DataSampleHeader &header)
	Check the data sample header for suitability.
virtual void	deliver_sample (ReceivedDataSample &sample, const ACE_INET_Addr &remote_address)
	Called when there is a ReceivedDataSample to be delivered.
virtual int	start_i ()
	Let the subclass start.
virtual void	stop_i ()
	Let the subclass stop.
virtual bool	reassemble (ReceivedDataSample &data)
Private Attributes
MulticastDataLink *	link_

---

Detailed Description

Definition at line 23 of file MulticastReceiveStrategy.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::MulticastReceiveStrategy::MulticastReceiveStrategy

(

MulticastDataLink *

link

)

[explicit]

Definition at line 18 of file MulticastReceiveStrategy.cpp.

  : link_(link)
{
}

---

Member Function Documentation

bool OpenDDS::DCPS::MulticastReceiveStrategy::check_header

(

const DataSampleHeader &

header

)

[protected, virtual]

Check the data sample header for suitability.

Reimplemented from OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 59 of file MulticastReceiveStrategy.cpp.

References OpenDDS::DCPS::MulticastDataLink::check_header(), and link_.

{
  return this->link_->check_header(header);
}

Here is the call graph for this function:

bool OpenDDS::DCPS::MulticastReceiveStrategy::check_header

(

const TransportHeader &

header

)

[protected, virtual]

Check the transport header for suitability.

Reimplemented from OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 53 of file MulticastReceiveStrategy.cpp.

References OpenDDS::DCPS::MulticastDataLink::check_header(), and link_.

{
  return this->link_->check_header(header);
}

Here is the call graph for this function:

void OpenDDS::DCPS::MulticastReceiveStrategy::deliver_sample	(	ReceivedDataSample &	sample,
		const ACE_INET_Addr &	remote_address
	)			[protected, virtual]

Called when there is a ReceivedDataSample to be delivered.

Implements OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 65 of file MulticastReceiveStrategy.cpp.

References link_, and OpenDDS::DCPS::MulticastDataLink::sample_received().

{
  this->link_->sample_received(sample);
}

Here is the call graph for this function:

ACE_HANDLE OpenDDS::DCPS::MulticastReceiveStrategy::get_handle

(

void

)

const [virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 24 of file MulticastReceiveStrategy.cpp.

References ACE_IPC_SAP::get_handle(), link_, OpenDDS::DCPS::MulticastDataLink::socket(), and socket().

{
  ACE_SOCK_Dgram_Mcast& socket = this->link_->socket();
  return socket.get_handle();
}

Here is the call graph for this function:

int OpenDDS::DCPS::MulticastReceiveStrategy::handle_input

(

ACE_HANDLE

fd

)

[virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 31 of file MulticastReceiveStrategy.cpp.

References OpenDDS::DCPS::TransportReceiveStrategy<>::handle_dds_input(), LM_DEBUG, OpenDDS::DCPS::TransportReceiveStrategy<>::pdu_remaining(), OpenDDS::DCPS::TransportReceiveStrategy<>::reset(), and VDBG_LVL.

{
  const int result = this->handle_dds_input(fd);
  if (result >= 0 && this->pdu_remaining()) {
    VDBG_LVL((LM_DEBUG, "(%P|%t) MulticastReceiveStrategy[%@]::handle_input "
      "resetting with %B bytes remaining\n", this, this->pdu_remaining()), 4);
    this->reset();
  }
  return result;
}

Here is the call graph for this function:

bool OpenDDS::DCPS::MulticastReceiveStrategy::reassemble

(

ReceivedDataSample &

data

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 72 of file MulticastReceiveStrategy.cpp.

References link_, OpenDDS::DCPS::MulticastDataLink::reassemble(), and OpenDDS::DCPS::TransportReceiveStrategy<>::received_header().

{
  return this->link_->reassemble(data, received_header());
}

Here is the call graph for this function:

ssize_t OpenDDS::DCPS::MulticastReceiveStrategy::receive_bytes	(	iovec	iov[],
		int	n,
		ACE_INET_Addr &	remote_address,
		ACE_HANDLE	fd
	)			[protected, virtual]

Only our subclass knows how to do this.

Implements OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 43 of file MulticastReceiveStrategy.cpp.

References link_, ACE_SOCK_Dgram::recv(), OpenDDS::DCPS::MulticastDataLink::socket(), and socket().

{
  ACE_SOCK_Dgram_Mcast& socket = this->link_->socket();
  return socket.recv(iov, n, remote_address);
}

Here is the call graph for this function:

int OpenDDS::DCPS::MulticastReceiveStrategy::start_i

(

)

[protected, virtual]

Let the subclass start.

Implements OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 78 of file MulticastReceiveStrategy.cpp.

References ACE_TEXT(), OpenDDS::DCPS::MulticastDataLink::get_reactor(), link_, LM_ERROR, ACE_Event_Handler::reactor(), ACE_Event_Handler::READ_MASK, and ACE_Reactor::register_handler().

{
  ACE_Reactor* reactor = this->link_->get_reactor();
  if (reactor == 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ")
                      ACE_TEXT("MulticastReceiveStrategy::start_i: ")
                      ACE_TEXT("NULL reactor reference!\n")),
                     -1);
  }

  if (reactor->register_handler(this, ACE_Event_Handler::READ_MASK) != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ")
                      ACE_TEXT("MulticastReceiveStrategy::start_i: ")
                      ACE_TEXT("failed to register handler for DataLink!\n")),
                     -1);
  }

  return 0;
}

Here is the call graph for this function:

void OpenDDS::DCPS::MulticastReceiveStrategy::stop_i

(

)

[protected, virtual]

Let the subclass stop.

Implements OpenDDS::DCPS::TransportReceiveStrategy<>.

Definition at line 101 of file MulticastReceiveStrategy.cpp.

References ACE_TEXT(), OpenDDS::DCPS::MulticastDataLink::get_reactor(), link_, LM_ERROR, ACE_Event_Handler::reactor(), ACE_Event_Handler::READ_MASK, and ACE_Reactor::remove_handler().

{
  ACE_Reactor* reactor = this->link_->get_reactor();
  if (reactor == 0) {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: ")
               ACE_TEXT("MulticastReceiveStrategy::stop_i: ")
               ACE_TEXT("NULL reactor reference!\n")));
    return;
  }

  reactor->remove_handler(this, ACE_Event_Handler::READ_MASK);
}

Here is the call graph for this function:

---

Member Data Documentation

MulticastDataLink* OpenDDS::DCPS::MulticastReceiveStrategy::link_ [private]

Definition at line 51 of file MulticastReceiveStrategy.h.

Referenced by check_header(), deliver_sample(), get_handle(), reassemble(), receive_bytes(), start_i(), and stop_i().

---

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

• MulticastReceiveStrategy.h
• MulticastReceiveStrategy.cpp