OpenDDS::DCPS::TcpSendStrategy Class Reference

#include <TcpSendStrategy.h>

Inheritance diagram for OpenDDS::DCPS::TcpSendStrategy:

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

[legend]List of all members.

Public Member Functions
	TcpSendStrategy (std::size_t id, const TcpDataLink_rch &link, const TcpInst_rch &config, const TcpConnection_rch &connection, TcpSynchResource *synch_resource, const TransportReactorTask_rch &task, Priority priority)
virtual	~TcpSendStrategy ()
int	reset (TcpConnection *connection, bool reset_mode=false)
virtual void	schedule_output ()
	Enable or disable output processing by the reactor according to mode.
Protected Member Functions
virtual ssize_t	send_bytes (const iovec iov[], int n, int &bp)
virtual ACE_HANDLE	get_handle ()
virtual ssize_t	send_bytes_i (const iovec iov[], int n)
virtual void	relink (bool do_suspend=true)
virtual void	stop_i ()
	Let the subclass stop.
Private Attributes
TcpConnection_rch	connection_
TcpDataLink_rch	link_
TransportReactorTask_rch	reactor_task_

---

Detailed Description

Definition at line 23 of file TcpSendStrategy.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::TcpSendStrategy::TcpSendStrategy	(	std::size_t	id,
		const TcpDataLink_rch &	link,
		const TcpInst_rch &	config,
		const TcpConnection_rch &	connection,
		TcpSynchResource *	synch_resource,
		const TransportReactorTask_rch &	task,
		Priority	priority
	)

Definition at line 20 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

  : TransportSendStrategy(id, static_rchandle_cast<TransportInst>(config),
                          synch_resource, priority,
                          new ReactorSynchStrategy(
                                this,
                                task->get_reactor()))
  , connection_(connection)
  , link_(link)
  , reactor_task_(task)
{
  DBG_ENTRY_LVL("TcpSendStrategy","TcpSendStrategy",6);

  connection->set_send_strategy(this);
}

OpenDDS::DCPS::TcpSendStrategy::~TcpSendStrategy

(

)

[virtual]

Definition at line 42 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TcpSendStrategy","~TcpSendStrategy",6);
}

---

Member Function Documentation

ACE_HANDLE OpenDDS::DCPS::TcpSendStrategy::get_handle

(

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 125 of file TcpSendStrategy.cpp.

References connection_, and OpenDDS::DCPS::RcHandle< T >::is_nil().

Referenced by schedule_output().

{
  TcpConnection_rch connection = this->connection_;

  if (connection.is_nil())
    return ACE_INVALID_HANDLE;

  return connection->peer().get_handle();
}

void OpenDDS::DCPS::TcpSendStrategy::relink

(

bool

do_suspend = true

)

[protected, virtual]

Delegate to the connection object to re-establish the connection.

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 150 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TcpSendStrategy","relink",6);

  if (!this->connection_.is_nil()) {
    this->connection_->relink_from_send(do_suspend);
  }
}

int OpenDDS::DCPS::TcpSendStrategy::reset	(	TcpConnection *	connection,
		bool	reset_mode = false
	)

This is called by the datalink object to associate with the "new" connection object. The "old" connection object is unregistered with the reactor and the "new" connection object is registered for sending. The implementation of this method is borrowed from the ReceiveStrategy.

Definition at line 71 of file TcpSendStrategy.cpp.

References OpenDDS::DCPS::RcObject< T >::_add_ref(), OpenDDS::DCPS::TransportSendStrategy::clear(), connection_, DBG_ENTRY_LVL, OpenDDS::DCPS::TransportSendStrategy::MODE_DIRECT, and OpenDDS::DCPS::TransportSendStrategy::set_graceful_disconnecting().

{
  DBG_ENTRY_LVL("TcpSendStrategy","reset",6);

  // Sanity check - this connection is passed in from the constructor and
  // it should not be nil.
  if (this->connection_.is_nil()) {
    ACE_ERROR_RETURN((LM_ERROR,
                      "(%P|%t) ERROR: TcpSendStrategy::reset  previous connection "
                      "should not be nil.\n"),
                     -1);
  }

  if (this->connection_.in() == connection) {
    ACE_ERROR_RETURN((LM_ERROR,
                      "(%P|%t) ERROR: TcpSendStrategy::reset should not be called"
                      " to replace the same connection.\n"),
                     -1);
  }

  // This will cause the connection_ object to drop its reference to this
  // TransportSendStrategy object.
  this->connection_->remove_send_strategy();

  // Replace with a new connection.
  connection->_add_ref();
  this->connection_ = connection;

  // Tell the TcpConnection that we are the object that it should
  // call when it receives a handle_input() "event", and we will carry
  // it out.  The TcpConnection object will make a "copy" of the
  // reference (to this object) that we pass-in here.
  this->connection_->set_send_strategy(this);

  //For the case of a send_strategy being reused for a new connection (not reconnect)
  //need to reset the state
  if (reset_mode) {
    //Need to make sure that the send mode is set back to MODE_DIRECT in case
    //it was terminated prior to being reused/reset.
    this->clear(MODE_DIRECT);
    //reset graceful_disconnecting_ to initial state
    this->set_graceful_disconnecting(false);
  }
  return 0;
}

void OpenDDS::DCPS::TcpSendStrategy::schedule_output

(

)

[virtual]

Enable or disable output processing by the reactor according to mode.

Reimplemented from OpenDDS::DCPS::ThreadSynchWorker.

Definition at line 48 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::DCPS_debug_level, get_handle(), OpenDDS::DCPS::TransportSendStrategy::mode(), OpenDDS::DCPS::TransportSendStrategy::MODE_DIRECT, OpenDDS::DCPS::TransportSendStrategy::MODE_QUEUE, OpenDDS::DCPS::TransportSendStrategy::MODE_SUSPEND, OpenDDS::DCPS::TransportSendStrategy::synch(), and OpenDDS::DCPS::ThreadSynch::work_available().

{
  DBG_ENTRY_LVL("TcpSendStrategy","schedule_output",6);

  // Notify the reactor to adjust its processing policy according to mode_.
  synch()->work_available();

  if (DCPS_debug_level > 4) {
    const char* action = "";
    if( mode() == MODE_DIRECT) {
      action = "canceling";
    } else if( (mode() == MODE_QUEUE)
            || (mode() == MODE_SUSPEND)) {
      action = "starting";
    }
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) TcpSendStrategy::schedule_output() [%d] - ")
               ACE_TEXT("%C data queueing for handle %d.\n"),
               id(),action,get_handle()));
  }
}

ssize_t OpenDDS::DCPS::TcpSendStrategy::send_bytes	(	const iovec	iov[],
		int	n,
		int &	bp
	)			[protected, virtual]

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 118 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL, and OpenDDS::DCPS::TransportSendStrategy::non_blocking_send().

{
  DBG_ENTRY_LVL("TcpSendStrategy","send_bytes",6);
  return this->non_blocking_send(iov, n, bp);
}

ssize_t OpenDDS::DCPS::TcpSendStrategy::send_bytes_i	(	const iovec	iov[],
		int	n
	)			[protected, virtual]

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 136 of file TcpSendStrategy.cpp.

References connection_, OpenDDS::DCPS::DCPS_debug_level, and OpenDDS::DCPS::RcHandle< T >::is_nil().

{
  TcpConnection_rch connection = this->connection_;

  if (connection.is_nil())
    return -1;
  ssize_t result = connection->peer().sendv(iov, n);
  if (DCPS_debug_level > 4)
    ACE_DEBUG((LM_DEBUG, "(%P|%t) TcpSendStrategy::send_bytes_i sent %d bytes \n", result));

  return result;
}

void OpenDDS::DCPS::TcpSendStrategy::stop_i

(

)

[protected, virtual]

Let the subclass stop.

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 160 of file TcpSendStrategy.cpp.

References connection_, and DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TcpSendStrategy","stop_i",6);

  // This will cause the connection_ object to drop its reference to this
  // TransportSendStrategy object.
  this->connection_->remove_send_strategy();

  // Take back the "copy" of connection object given. (see constructor).
  this->connection_ = 0;
}

---

Member Data Documentation

TcpConnection_rch OpenDDS::DCPS::TcpSendStrategy::connection_ [private]

Definition at line 57 of file TcpSendStrategy.h.

Referenced by get_handle(), reset(), send_bytes_i(), and stop_i().

TcpDataLink_rch OpenDDS::DCPS::TcpSendStrategy::link_ [private]

Definition at line 58 of file TcpSendStrategy.h.

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

Definition at line 59 of file TcpSendStrategy.h.

---

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

• TcpSendStrategy.h
• TcpSendStrategy.cpp

---