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, TcpDataLink &link, TcpSynchResource *synch_resource, const TransportReactorTask_rch &task, Priority priority)
virtual	~TcpSendStrategy ()
int	reset (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.
virtual void	add_delayed_notification (TransportQueueElement *element)
Private Attributes
TcpDataLink &	link_
TransportReactorTask_rch	reactor_task_

---

Detailed Description

Definition at line 25 of file TcpSendStrategy.h.

---

Constructor & Destructor Documentation

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS::DCPS::TcpSendStrategy::TcpSendStrategy	(	std::size_t	id,
		TcpDataLink &	link,
		TcpSynchResource *	synch_resource,
		const TransportReactorTask_rch &	task,
		Priority	priority
	)

Definition at line 22 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

  : TransportSendStrategy(id, link.impl(),
                          synch_resource, priority,
                          make_rch<ReactorSynchStrategy>(this,task->get_reactor()))
  , link_(link)
  , reactor_task_(task)
{
  DBG_ENTRY_LVL("TcpSendStrategy","TcpSendStrategy",6);

}

OpenDDS::DCPS::TcpSendStrategy::~TcpSendStrategy

(

)

[virtual]

Definition at line 38 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

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

---

Member Function Documentation

void OpenDDS::DCPS::TcpSendStrategy::add_delayed_notification

(

TransportQueueElement *

element

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 132 of file TcpSendStrategy.cpp.

References OpenDDS::DCPS::TransportQueueElement::is_request_ack().

{
  if (!element->is_request_ack()) {
    // only add the notification when we are not sending REQUEST_ACK message
    TransportSendStrategy::add_delayed_notification(element);
  }
}

Here is the call graph for this function:

ACE_HANDLE OpenDDS::DCPS::TcpSendStrategy::get_handle

(

void

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 90 of file TcpSendStrategy.cpp.

References OpenDDS::DCPS::TcpDataLink::get_connection(), and link_.

Referenced by schedule_output().

{
  TcpConnection_rch connection = link_.get_connection();

  if (!connection)
    return ACE_INVALID_HANDLE;

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

Here is the call graph for this function:

Here is the caller graph for this function:

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 115 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::TcpDataLink::get_connection(), and link_.

{
  DBG_ENTRY_LVL("TcpSendStrategy","relink",6);
  TcpConnection_rch connection = link_.get_connection();

  if (connection) {
    connection->relink_from_send(do_suspend);
  }
}

Here is the call graph for this function:

int OpenDDS::DCPS::TcpSendStrategy::reset

(

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 67 of file TcpSendStrategy.cpp.

References OpenDDS::DCPS::TransportSendStrategy::clear(), DBG_ENTRY_LVL, OpenDDS::DCPS::TransportSendStrategy::MODE_DIRECT, and OpenDDS::DCPS::TransportSendStrategy::set_graceful_disconnecting().

Referenced by OpenDDS::DCPS::TcpDataLink::reconnect(), and OpenDDS::DCPS::TcpDataLink::reuse_existing_connection().

{
  DBG_ENTRY_LVL("TcpSendStrategy","reset",6);
  //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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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 44 of file TcpSendStrategy.cpp.

References ACE_TEXT(), DBG_ENTRY_LVL, OpenDDS::DCPS::DCPS_debug_level, get_handle(), LM_DEBUG, 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()));
  }
}

Here is the call graph for this function:

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

Reimplemented from OpenDDS::DCPS::TransportSendStrategy.

Definition at line 83 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);
}

Here is the call graph for this function:

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

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 101 of file TcpSendStrategy.cpp.

References OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TcpDataLink::get_connection(), link_, and LM_DEBUG.

{
  TcpConnection_rch connection = link_.get_connection();

  if (!connection)
    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;
}

Here is the call graph for this function:

void OpenDDS::DCPS::TcpSendStrategy::stop_i

(

)

[protected, virtual]

Let the subclass stop.

Implements OpenDDS::DCPS::TransportSendStrategy.

Definition at line 126 of file TcpSendStrategy.cpp.

References DBG_ENTRY_LVL.

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

---

Member Data Documentation

TcpDataLink& OpenDDS::DCPS::TcpSendStrategy::link_ [private]

Definition at line 57 of file TcpSendStrategy.h.

Referenced by get_handle(), relink(), and send_bytes_i().

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

Definition at line 58 of file TcpSendStrategy.h.

---

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

• TcpSendStrategy.h
• TcpSendStrategy.cpp