OpenDDS::DCPS::SimpleTcpReceiveStrategy Class Reference

#include <SimpleTcpReceiveStrategy.h>

Inheritance diagram for OpenDDS::DCPS::SimpleTcpReceiveStrategy:

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

[legend]List of all members.

Public Member Functions
	SimpleTcpReceiveStrategy (SimpleTcpDataLink *link, SimpleTcpConnection *connection, TransportReactorTask *task)
virtual	~SimpleTcpReceiveStrategy ()
int	reset (SimpleTcpConnection *connection)
ACE_Reactor *	get_reactor ()
bool	gracefully_disconnected ()
Protected Member Functions
virtual ssize_t	receive_bytes (iovec iov[], int n, ACE_INET_Addr &remote_address)
	Only our subclass knows how to do this.
virtual void	deliver_sample (ReceivedDataSample &sample, const ACE_INET_Addr &remote_address)
	Called when there is a ReceivedDataSample to be delivered.
virtual int	start_i ()
	Let the subclass start.
virtual void	stop_i ()
	Let the subclass stop.
virtual void	relink (bool do_suspend=true)
Private Attributes
SimpleTcpDataLink_rch	link_
SimpleTcpConnection_rch	connection_
TransportReactorTask_rch	reactor_task_

---

Constructor & Destructor Documentation

OpenDDS::DCPS::SimpleTcpReceiveStrategy::SimpleTcpReceiveStrategy	(	SimpleTcpDataLink *	link,
		SimpleTcpConnection *	connection,
		TransportReactorTask *	task
	)

OpenDDS::DCPS::SimpleTcpReceiveStrategy::~SimpleTcpReceiveStrategy

(

)

[virtual]

---

Member Function Documentation

void OpenDDS::DCPS::SimpleTcpReceiveStrategy::deliver_sample	(	ReceivedDataSample &	sample,
		const ACE_INET_Addr &	remote_address
	)			[protected, virtual]

Called when there is a ReceivedDataSample to be delivered.

Implements OpenDDS::DCPS::TransportReceiveStrategy.

ACE_INLINE ACE_Reactor * OpenDDS::DCPS::SimpleTcpReceiveStrategy::get_reactor

(

)

ACE_INLINE bool OpenDDS::DCPS::SimpleTcpReceiveStrategy::gracefully_disconnected

(

)

ssize_t OpenDDS::DCPS::SimpleTcpReceiveStrategy::receive_bytes	(	iovec	iov[],
		int	n,
		ACE_INET_Addr &	remote_address
	)			[protected, virtual]

Only our subclass knows how to do this.

Implements OpenDDS::DCPS::TransportReceiveStrategy.

void OpenDDS::DCPS::SimpleTcpReceiveStrategy::relink

(

bool

do_suspend = true

)

[protected, virtual]

The subclass needs to provide the implementation for re-establishing the datalink. This is called when recv returns an error.

Reimplemented from OpenDDS::DCPS::TransportReceiveStrategy.

int OpenDDS::DCPS::SimpleTcpReceiveStrategy::reset

(

SimpleTcpConnection *

connection

)

int OpenDDS::DCPS::SimpleTcpReceiveStrategy::start_i

(

)

[protected, virtual]

Let the subclass start.

Implements OpenDDS::DCPS::TransportReceiveStrategy.

void OpenDDS::DCPS::SimpleTcpReceiveStrategy::stop_i

(

)

[protected, virtual]

Let the subclass stop.

Implements OpenDDS::DCPS::TransportReceiveStrategy.

---

Member Data Documentation

SimpleTcpConnection_rch OpenDDS::DCPS::SimpleTcpReceiveStrategy::connection_ [private]

SimpleTcpDataLink_rch OpenDDS::DCPS::SimpleTcpReceiveStrategy::link_ [private]

TransportReactorTask_rch OpenDDS::DCPS::SimpleTcpReceiveStrategy::reactor_task_ [private]

---

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

• SimpleTcpReceiveStrategy.h
• SimpleTcpReceiveStrategy.cpp
• SimpleTcpReceiveStrategy.inl

---