OpenDDS::DCPS::BestEffortSession Class Reference

#include <BestEffortSession.h>

Inheritance diagram for OpenDDS::DCPS::BestEffortSession:

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

[legend]List of all members.

Public Member Functions
	BestEffortSession (ACE_Reactor *reactor, ACE_thread_t owner, MulticastDataLink *link, MulticastPeer remote_peer)
virtual bool	check_header (const TransportHeader &header)
virtual void	record_header_received (const TransportHeader &header)
virtual bool	ready_to_deliver (const TransportHeader &header, const ReceivedDataSample &data)
virtual bool	start (bool active, bool acked)
virtual bool	is_reliable ()
Private Attributes
SequenceNumber	expected_

---

Detailed Description

Definition at line 18 of file BestEffortSession.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::BestEffortSession::BestEffortSession	(	ACE_Reactor *	reactor,
		ACE_thread_t	owner,
		MulticastDataLink *	link,
		MulticastPeer	remote_peer
	)

Definition at line 13 of file BestEffortSession.cpp.

  : MulticastSession(reactor, owner, link, remote_peer)
  , expected_(SequenceNumber::SEQUENCENUMBER_UNKNOWN())
{
}

---

Member Function Documentation

bool OpenDDS::DCPS::BestEffortSession::check_header

(

const TransportHeader &

header

)

[virtual]

Implements OpenDDS::DCPS::MulticastSession.

Definition at line 23 of file BestEffortSession.cpp.

References OpenDDS::DCPS::TransportReassembly::data_unavailable(), expected_, header, OpenDDS::DCPS::MulticastSession::reassembly_, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), and VDBG_LVL.

Referenced by record_header_received().

{
  if (header.sequence_ != this->expected_ &&
      expected_ != SequenceNumber::SEQUENCENUMBER_UNKNOWN()) {
    VDBG_LVL((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: BestEffortSession::check_header ")
               ACE_TEXT("expected %q received %q\n"),
               this->expected_.getValue(), header.sequence_.getValue()), 2);
    if (header.sequence_ > this->expected_) {
      SequenceRange range(this->expected_, header.sequence_.previous());
      this->reassembly_.data_unavailable(range);
    }
  }

  this->expected_ = header.sequence_;
  ++this->expected_;

  // Assume header is valid; this does not prevent duplicate
  // delivery of datagrams:
  return true;
}

virtual bool OpenDDS::DCPS::BestEffortSession::is_reliable

(

)

[inline, virtual]

Reimplemented from OpenDDS::DCPS::MulticastSession.

Definition at line 33 of file BestEffortSession.h.

{ return false;}

bool OpenDDS::DCPS::BestEffortSession::ready_to_deliver	(	const TransportHeader &	header,
		const ReceivedDataSample &	data
	)			[virtual]

Implements OpenDDS::DCPS::MulticastSession.

Definition at line 54 of file BestEffortSession.cpp.

References expected_, header, OpenDDS::DCPS::SequenceNumber::previous(), and OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN().

{
  if (expected_ != SequenceNumber::SEQUENCENUMBER_UNKNOWN()
      && header.sequence_ == expected_.previous()) {
    return true;
  }
  return false;
}

void OpenDDS::DCPS::BestEffortSession::record_header_received

(

const TransportHeader &

header

)

[virtual]

Implements OpenDDS::DCPS::MulticastSession.

Definition at line 46 of file BestEffortSession.cpp.

References check_header(), and header.

{
  if (this->remote_peer_ != header.source_) return;

  check_header(header);
}

bool OpenDDS::DCPS::BestEffortSession::start	(	bool	active,
		bool	acked
	)			[virtual]

Implements OpenDDS::DCPS::MulticastSession.

Definition at line 65 of file BestEffortSession.cpp.

References OpenDDS::DCPS::MulticastSession::active_, and OpenDDS::DCPS::MulticastSession::started_.

{
  ACE_GUARD_RETURN(ACE_SYNCH_MUTEX,
                   guard,
                   this->start_lock_,
                   false);

  if (this->started_) return true;  // already started

  this->active_ = active;

  if (active && !this->start_syn()) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ")
                      ACE_TEXT("BestEffortSession::start: ")
                      ACE_TEXT("failed to schedule SYN watchdog!\n")),
                     false);
  }

  return this->started_ = true;
}

---

Member Data Documentation

SequenceNumber OpenDDS::DCPS::BestEffortSession::expected_ [private]

Definition at line 36 of file BestEffortSession.h.

Referenced by check_header(), and ready_to_deliver().

---

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

• BestEffortSession.h
• BestEffortSession.cpp

---