OpenDDS::DCPS::TcpReconnectTask Class Reference

Active Object managing a queue of reconnecting request. More...

#include <TcpReconnectTask.h>

Inheritance diagram for OpenDDS::DCPS::TcpReconnectTask:

[legend]

Collaboration diagram for OpenDDS::DCPS::TcpReconnectTask:

[legend]

List of all members.

Public Member Functions
	TcpReconnectTask (TcpConnection *con)
virtual	~TcpReconnectTask ()
virtual void	execute (ReconnectOpType &op)
	Handle reconnect requests.
Private Attributes
TcpConnection *	connection_
	The connection that needs be re-established.

---

Detailed Description

Active Object managing a queue of reconnecting request.

This task handles request to reconnect to the remotes to avoid the the caller threads (thread to send or reactor thread) block on reconnecting. This reconnect task has lifetime as TcpConnection object. One reconnect task just dedicates to a single connection.

Definition at line 40 of file TcpReconnectTask.h.

---

Constructor & Destructor Documentation

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS::DCPS::TcpReconnectTask::TcpReconnectTask

(

TcpConnection *

con

)

Definition at line 16 of file TcpReconnectTask.cpp.

References ACE_TEXT(), DBG_ENTRY_LVL, LM_ERROR, and OpenDDS::DCPS::QueueTaskBase< ReconnectOpType >::open().

  : connection_(connection)
{
  DBG_ENTRY_LVL("TcpReconnectTask","TcpReconnectTask",6);
  if (open()) {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Reconnect task failed to open : %p\n"),
               ACE_TEXT("open")));
  }
}

Here is the call graph for this function:

OpenDDS::DCPS::TcpReconnectTask::~TcpReconnectTask

(

)

[virtual]

Definition at line 28 of file TcpReconnectTask.cpp.

References DBG_ENTRY_LVL.

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

---

Member Function Documentation

void OpenDDS::DCPS::TcpReconnectTask::execute

(

ReconnectOpType &

op

)

[virtual]

Handle reconnect requests.

Implements OpenDDS::DCPS::QueueTaskBase< ReconnectOpType >.

Definition at line 33 of file TcpReconnectTask.cpp.

References connection_, DBG_ENTRY_LVL, OpenDDS::DCPS::DO_RECONNECT, LM_ERROR, OpenDDS::DCPS::TcpConnection::reconnect(), SIG_SETMASK, ACE_OS::sigfillset(), sigset_t, OpenDDS::DCPS::TcpConnection::tear_link(), and ACE_OS::thr_sigsetmask().

{
  DBG_ENTRY_LVL("TcpReconnectTask","execute",6);

  // Ignore all signals to avoid
  //     ERROR: <something descriptive> Interrupted system call
  // The main thread will handle signals.
  sigset_t set;
  ACE_OS::sigfillset(&set);
  ACE_OS::thr_sigsetmask(SIG_SETMASK, &set, NULL);

  if (op == DO_RECONNECT) {
    if (this->connection_->reconnect() == -1) {
      this->connection_->tear_link();
    }

  } else
    ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: TcpReconnectTask::svc unknown operation %d\n", op));
}

Here is the call graph for this function:

---

Member Data Documentation

TcpConnection* OpenDDS::DCPS::TcpReconnectTask::connection_ [private]

The connection that needs be re-established.

Definition at line 52 of file TcpReconnectTask.h.

Referenced by execute().

---

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

• TcpReconnectTask.h
• TcpReconnectTask.cpp