OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer Struct Reference

Inheritance diagram for OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer:

[legend]Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer:

[legend]List of all members.

Public Member Functions
	MultiSendBuffer (RtpsUdpDataLink *outer, size_t capacity)
void	retain_all (RepoId pub_id)
void	insert (SequenceNumber sequence, TransportSendStrategy::QueueType *queue, ACE_Message_Block *chain)
Public Attributes
RtpsUdpDataLink *	outer_

---

Detailed Description

Definition at line 165 of file RtpsUdpDataLink.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::MultiSendBuffer	(	RtpsUdpDataLink *	outer,
		size_t	capacity
	)			[inline]

Definition at line 167 of file RtpsUdpDataLink.h.

      : TransportSendBuffer(capacity)
      , outer_(outer)
    {}

---

Member Function Documentation

void OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert	(	SequenceNumber	sequence,
		TransportSendStrategy::QueueType *	queue,
		ACE_Message_Block *	chain
	)			[virtual]

Implements OpenDDS::DCPS::TransportSendBuffer.

Definition at line 550 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::SequenceNumber::getValue(), OpenDDS::DCPS::RcHandle< T >::in(), OpenDDS::DCPS::TransportQueueElement::is_fragment(), OpenDDS::DCPS::RcHandle< T >::is_nil(), OPENDDS_STRING, outer_, OpenDDS::DCPS::BasicQueue< T >::peek(), OpenDDS::DCPS::TransportQueueElement::publication_id(), OpenDDS::DCPS::RtpsUdpDataLink::send_strategy_, OpenDDS::DCPS::TransportQueueElement::sequence(), OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), OpenDDS::DCPS::Transport_debug_level, OpenDDS::DCPS::SingleSendBuffer::UNLIMITED, and OpenDDS::DCPS::RtpsUdpDataLink::writers_.

{
  // Called from TransportSendStrategy::send_packet().
  // RtpsUdpDataLink is already locked.
  const TransportQueueElement* const tqe = q->peek();
  const SequenceNumber seq = tqe->sequence();
  if (seq == SequenceNumber::SEQUENCENUMBER_UNKNOWN()) {
    return;
  }

  const RepoId pub_id = tqe->publication_id();

  const RtpsWriterMap::iterator wi = outer_->writers_.find(pub_id);
  if (wi == outer_->writers_.end()) {
    return; // this datawriter is not reliable
  }

  RcHandle<SingleSendBuffer>& send_buff = wi->second.send_buff_;

  if (send_buff.is_nil()) {
    send_buff = new SingleSendBuffer(SingleSendBuffer::UNLIMITED, 1 /*mspp*/);

    send_buff->bind(outer_->send_strategy_.in());
  }

  if (Transport_debug_level > 5) {
    const GuidConverter pub(pub_id);
    ACE_DEBUG((LM_DEBUG, "(%P|%t) RtpsUdpDataLink::MultiSendBuffer::insert() - "
      "pub_id %C seq %q frag %d\n", OPENDDS_STRING(pub).c_str(), seq.getValue(),
      (int)tqe->is_fragment()));
  }

  if (tqe->is_fragment()) {
    const RtpsCustomizedElement* const rce =
      dynamic_cast<const RtpsCustomizedElement*>(tqe);
    if (rce) {
      send_buff->insert_fragment(seq, rce->last_fragment(), q, chain);
    } else if (Transport_debug_level) {
      const GuidConverter pub(pub_id);
      ACE_ERROR((LM_ERROR, "(%P|%t) RtpsUdpDataLink::MultiSendBuffer::insert()"
        " - ERROR: couldn't get fragment number for pub_id %C seq %q\n",
        OPENDDS_STRING(pub).c_str(), seq.getValue()));
    }
  } else {
    send_buff->insert(seq, q, chain);
  }
}

void OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::retain_all

(

RepoId

pub_id

)

[virtual]

Implements OpenDDS::DCPS::TransportSendBuffer.

Definition at line 540 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::RtpsUdpDataLink::lock_, outer_, and OpenDDS::DCPS::RtpsUdpDataLink::writers_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, outer_->lock_);
  const RtpsWriterMap::iterator wi = outer_->writers_.find(pub_id);
  if (wi != outer_->writers_.end() && !wi->second.send_buff_.is_nil()) {
    wi->second.send_buff_->retain_all(pub_id);
  }
}

---

Member Data Documentation

RtpsUdpDataLink* OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::outer_

Definition at line 177 of file RtpsUdpDataLink.h.

Referenced by insert(), and retain_all().

---

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

• RtpsUdpDataLink.h
• RtpsUdpDataLink.cpp

---