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)
	Constructor.
virtual	~TcpReconnectTask ()
	Virtual Destructor.
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 38 of file TcpReconnectTask.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::TcpReconnectTask::TcpReconnectTask

(

TcpConnection *

con

)

Constructor.

Definition at line 14 of file TcpReconnectTask.cpp.

References DBG_ENTRY_LVL.

  : connection_(connection)
{
  DBG_ENTRY_LVL("TcpReconnectTask","TcpReconnectTask",6);
}

OpenDDS::DCPS::TcpReconnectTask::~TcpReconnectTask

(

)

[virtual]

Virtual Destructor.

Definition at line 21 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 26 of file TcpReconnectTask.cpp.

References DBG_ENTRY_LVL, and OpenDDS::DCPS::DO_RECONNECT.

{
  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));
}

---

Member Data Documentation

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

The connection that needs be re-established.

Definition at line 53 of file TcpReconnectTask.h.

---

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

• TcpReconnectTask.h
• TcpReconnectTask.cpp

---