OpenDDS::DCPS::SingleSendBuffer::Proxy Class Reference

#include <TransportSendBuffer.h>

Collaboration diagram for OpenDDS::DCPS::SingleSendBuffer::Proxy:

Public Member Functions
	Proxy (SingleSendBuffer &ssb)
	~Proxy ()
SequenceNumber	low () const
SequenceNumber	high () const
bool	empty () const
bool	contains (SequenceNumber seq) const
bool	contains (SequenceNumber seq, GUID_t &destination) const
SequenceNumber	pre_low () const
SequenceNumber	pre_high () const
bool	pre_empty () const
bool	pre_contains (SequenceNumber sequence) const
bool	resend_i (const SequenceRange &range, DisjointSequence *gaps=0)
bool	resend_i (const SequenceRange &range, DisjointSequence *gaps, const GUID_t &destination)
void	resend_fragments_i (SequenceNumber sequence, const DisjointSequence &fragments, size_t &cumulative_send_count)
bool	has_frags (const SequenceNumber &seq) const

Private Attributes
SingleSendBuffer &	ssb_

Detailed Description

Definition at line 102 of file TransportSendBuffer.h.

Constructor & Destructor Documentation

Proxy()

OpenDDS::DCPS::SingleSendBuffer::Proxy::Proxy ( SingleSendBuffer &  ssb )

inline

Definition at line 104 of file TransportSendBuffer.h.

      : ssb_(ssb)
    {
      ssb_.mutex_.acquire();
    }

~Proxy()

OpenDDS::DCPS::SingleSendBuffer::Proxy::~Proxy ( )

inline

Definition at line 110 of file TransportSendBuffer.h.

    {
      ssb_.mutex_.release();
    }

Member Function Documentation

contains() [1/2]

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::contains ( SequenceNumber  seq ) const

inline

Definition at line 132 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack().

    {
      return ssb_.buffers_.count(seq);
    }

contains() [2/2]

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::contains ( SequenceNumber  seq, GUID_t &  destination  ) const

inline

Definition at line 137 of file TransportSendBuffer.h.

References OpenDDS::DCPS::GUID_UNKNOWN.

    {
      if (ssb_.buffers_.count(seq)) {
        DestinationMap::const_iterator pos = ssb_.destinations_.find(seq);
        destination = pos == ssb_.destinations_.end() ? GUID_UNKNOWN : pos->second;
        return true;
      }
      return false;
    }

empty()

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::empty ( void  ) const

inline

Definition at line 127 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::max_data_seq(), OpenDDS::DCPS::ReliableSession::nak_received(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::non_durable_first_sn().

    {
      return ssb_.buffers_.empty();
    }

has_frags()

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::has_frags ( const SequenceNumber &  seq ) const

inline

Definition at line 188 of file TransportSendBuffer.h.

    {
      return ssb_.has_frags(seq);
    }

high()

SequenceNumber OpenDDS::DCPS::SingleSendBuffer::Proxy::high ( ) const

inline

Definition at line 121 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::max_data_seq().

    {
      if (ssb_.buffers_.empty()) throw std::exception();
      return ssb_.buffers_.rbegin()->first;
    }

low()

SequenceNumber OpenDDS::DCPS::SingleSendBuffer::Proxy::low ( ) const

inline

Definition at line 115 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::ReliableSession::nak_received(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::non_durable_first_sn().

    {
      if (ssb_.buffers_.empty()) throw std::exception();
      return ssb_.buffers_.begin()->first;
    }

pre_contains()

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::pre_contains ( SequenceNumber  sequence ) const

inline

Definition at line 164 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack().

    {
      return ssb_.pre_seq_.count(sequence);
    }

pre_empty()

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::pre_empty ( ) const

inline

Definition at line 159 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::max_data_seq(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::non_durable_first_sn().

    {
      return ssb_.pre_seq_.empty();
    }

pre_high()

SequenceNumber OpenDDS::DCPS::SingleSendBuffer::Proxy::pre_high ( ) const

inline

Definition at line 153 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::max_data_seq().

    {
      if (ssb_.pre_seq_.empty()) throw std::exception();
      return *ssb_.pre_seq_.rbegin();
    }

pre_low()

SequenceNumber OpenDDS::DCPS::SingleSendBuffer::Proxy::pre_low ( ) const

inline

Definition at line 147 of file TransportSendBuffer.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::non_durable_first_sn().

    {
      if (ssb_.pre_seq_.empty()) throw std::exception();
      return *ssb_.pre_seq_.begin();
    }

resend_fragments_i()

void OpenDDS::DCPS::SingleSendBuffer::Proxy::resend_fragments_i ( SequenceNumber  sequence, const DisjointSequence &  fragments, size_t &  cumulative_send_count  )

inline

Definition at line 181 of file TransportSendBuffer.h.

    {
      ssb_.resend_fragments_i(sequence, fragments, cumulative_send_count);
    }

resend_i() [1/2]

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::resend_i ( const SequenceRange &  range, DisjointSequence *  gaps = 0  )

inline

Definition at line 170 of file TransportSendBuffer.h.

    {
      return ssb_.resend_i(range, gaps);
    }

resend_i() [2/2]

bool OpenDDS::DCPS::SingleSendBuffer::Proxy::resend_i ( const SequenceRange &  range, DisjointSequence *  gaps, const GUID_t &  destination  )

inline

Definition at line 175 of file TransportSendBuffer.h.

    {
      return ssb_.resend_i(range, gaps, destination);
    }

Member Data Documentation

ssb_

SingleSendBuffer& OpenDDS::DCPS::SingleSendBuffer::Proxy::ssb_

private

Definition at line 195 of file TransportSendBuffer.h.

---

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

• TransportSendBuffer.h