OpenDDS::DCPS::MulticastSendStrategy Class Reference

#include <MulticastSendStrategy.h>

Inheritance diagram for OpenDDS::DCPS::MulticastSendStrategy:

[legend]Collaboration diagram for OpenDDS::DCPS::MulticastSendStrategy:

[legend]List of all members.

Public Member Functions
	MulticastSendStrategy (MulticastDataLink *link)
virtual void	stop_i ()
	Let the subclass stop.
Protected Member Functions
virtual void	prepare_header_i ()
	Specific implementation processing of prepared packet header.
virtual ssize_t	send_bytes_i (const iovec iov[], int n)
ssize_t	sync_send (const iovec iov[], int n)
ssize_t	async_send (const iovec iov[], int n)
virtual size_t	max_message_size () const
Private Attributes
MulticastDataLink *	link_

---

Detailed Description

Definition at line 21 of file MulticastSendStrategy.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::MulticastSendStrategy::MulticastSendStrategy

(

MulticastDataLink *

link

)

[explicit]

Definition at line 16 of file MulticastSendStrategy.cpp.

References OpenDDS::DCPS::TransportSendStrategy::link_released().

  : TransportSendStrategy(0, TransportInst_rch(link->config(), false),
                          0,  // synch_resource
                          link->transport_priority(),
                          new NullSynchStrategy),
    link_(link)
#if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS)
  , async_init_(false)
#endif
{
  // Multicast will send a SYN (TRANSPORT_CONTROL) before any reservations
  // are made on the DataLink, if the link is "release" it will be dropped.
  this->link_released(false);
}

---

Member Function Documentation

ssize_t OpenDDS::DCPS::MulticastSendStrategy::async_send	(	const iovec	iov[],
		int	n
	)			[protected]

Definition at line 64 of file MulticastSendStrategy.cpp.

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

Referenced by send_bytes_i().

{
#if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS)
  if (!async_init_) {
    if (-1 == async_writer_.open(*this, link_->socket().get_handle(), 0 /*completion_key*/,
                                 link_->get_proactor())) {
        return -1;
    }
    async_init_ = true;
  }

  ACE_Message_Block* mb = 0;
  size_t total_length = 0;

  for (int i = n - 1; i >= 0; --i) {
    ACE_Message_Block* next =
      new ACE_Message_Block(static_cast<const char*>(iov[i].iov_base),
                            iov[i].iov_len);
    next->wr_ptr(iov[i].iov_len);
    total_length += iov[i].iov_len;
    next->cont(mb);
    mb = next;
  }

  size_t bytes_sent = 0;
  ssize_t result = async_writer_.send(mb, bytes_sent, 0 /*flags*/,
                                      this->link_->config()->group_address_);

  if (result < 0) {
    mb->release();
    return result;
  }

  // framework needs to think we sent the entire datagram
  return total_length;
#else
  ACE_UNUSED_ARG(iov);
  ACE_UNUSED_ARG(n);
  return -1;
#endif
}

virtual size_t OpenDDS::DCPS::MulticastSendStrategy::max_message_size

(

)

const [inline, protected, virtual]

The maximum size of a message allowed by the this TransportImpl, or 0 if there is no such limit. This is expected to be a constant, for example UDP/IPv4 can send messages of up to 65466 bytes. The transport framework will use the returned value (if > 0) to fragment larger messages. This fragmentation and reassembly will be transparent to the user.

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 40 of file MulticastSendStrategy.h.

  {
    return UDP_MAX_MESSAGE_SIZE;
  }

void OpenDDS::DCPS::MulticastSendStrategy::prepare_header_i

(

)

[protected, virtual]

Specific implementation processing of prepared packet header.

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 32 of file MulticastSendStrategy.cpp.

References OpenDDS::DCPS::TransportSendStrategy::header_, link_, OpenDDS::DCPS::MulticastDataLink::local_peer(), and OpenDDS::DCPS::TransportHeader::source_.

{
  // Tag outgoing packets with our peer ID:
  this->header_.source_ = this->link_->local_peer();
}

ssize_t OpenDDS::DCPS::MulticastSendStrategy::send_bytes_i	(	const iovec	iov[],
		int	n
	)			[protected, virtual]

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 39 of file MulticastSendStrategy.cpp.

References async_send(), and sync_send().

{
  return (this->link_->config()->async_send() ? async_send(iov, n) : sync_send(iov, n));
}

void OpenDDS::DCPS::MulticastSendStrategy::stop_i

(

)

[virtual]

Let the subclass stop.

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 107 of file MulticastSendStrategy.cpp.

{
#if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS)
  if (async_init_) {
    async_writer_.cancel();
  }
#endif
}

ssize_t OpenDDS::DCPS::MulticastSendStrategy::sync_send	(	const iovec	iov[],
		int	n
	)			[protected]

Definition at line 45 of file MulticastSendStrategy.cpp.

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

Referenced by send_bytes_i().

{
  ACE_SOCK_Dgram_Mcast& socket = this->link_->socket();

  const ssize_t result = socket.send(iov, n);

  if (result == -1 && errno == ENOBUFS) {
    // Make the framework think this was a successful send to avoid
    // putting the send strategy in suspended mode.  If reliability
    // is enabled, the data may be resent later in response to a NAK.
    ssize_t b = 0;
    for (int i = 0; i < n; ++i) b += iov[i].iov_len;
    return b;
  }

  return result;
}

---

Member Data Documentation

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

Definition at line 51 of file MulticastSendStrategy.h.

Referenced by async_send(), prepare_header_i(), and sync_send().

---

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

• MulticastSendStrategy.h
• MulticastSendStrategy.cpp

---