OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver Class Reference

#include <ReactivePacketReceiver.h>

Inheritance diagram for OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver:

[legend]Collaboration diagram for OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver:

[legend]List of all members.

Public Member Functions
	ReactivePacketReceiver (const ACE_INET_Addr &multicast_group_address, PacketReceiverCallback &callback, size_t receiver_buffer_size)
virtual	~ReactivePacketReceiver ()
bool	open ()
virtual void	close ()
virtual void	receive_packet_from (const Packet &packet, const ACE_INET_Addr &peer)
int	handle_timeout (const ACE_Time_Value &current_time, const void *=0)
Private Types
typedef ACE_Strong_Bound_Ptr< ReceiverLogic, ACE_Null_Mutex >	ReceiverLogicPtr
typedef std::map< ACE_INET_Addr, std::vector< Packet > >	PeerToPacketVectorMap
Private Attributes
PacketReceiverCallback &	callback_
ACE_INET_Addr	multicast_group_address_
size_t	receiver_buffer_size_
ACE_Thread_Mutex	nack_mutex_
std::map< ACE_INET_Addr, ReceiverLogicPtr >	receiver_logics_
PeerToPacketVectorMap	nacks_

---

Member Typedef Documentation

typedef std::map<ACE_INET_Addr, std::vector<Packet> > OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::PeerToPacketVectorMap [private]

typedef ACE_Strong_Bound_Ptr<ReceiverLogic, ACE_Null_Mutex> OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::ReceiverLogicPtr [private]

---

Constructor & Destructor Documentation

OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::ReactivePacketReceiver	(	const ACE_INET_Addr &	multicast_group_address,
		PacketReceiverCallback &	callback,
		size_t	receiver_buffer_size
	)

ACE_INLINE OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::~ReactivePacketReceiver

(

)

[virtual]

---

Member Function Documentation

void OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::close

(

)

[virtual]

Reimplemented from OpenDDS::DCPS::ReliableMulticast::detail::EventHandler.

int OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::handle_timeout	(	const ACE_Time_Value &	current_time,
		const void *	= 0
	)

bool OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::open

(

)

void OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::receive_packet_from	(	const Packet &	packet,
		const ACE_INET_Addr &	peer
	)			[virtual]

Implements OpenDDS::DCPS::ReliableMulticast::detail::PacketHandler.

---

Member Data Documentation

PacketReceiverCallback& OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::callback_ [private]

ACE_INET_Addr OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::multicast_group_address_ [private]

ACE_Thread_Mutex OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::nack_mutex_ [private]

PeerToPacketVectorMap OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::nacks_ [private]

size_t OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::receiver_buffer_size_ [private]

std::map<ACE_INET_Addr, ReceiverLogicPtr> OpenDDS::DCPS::ReliableMulticast::detail::ReactivePacketReceiver::receiver_logics_ [private]

---

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

• ReactivePacketReceiver.h
• ReactivePacketReceiver.cpp
• ReactivePacketReceiver.inl

---