OpenDDS::DCPS::FailoverListener

OpenDDS::DCPS::FailoverListener Class Reference

#include <FailoverListener.h>

Inheritance diagram for OpenDDS::DCPS::FailoverListener:

Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::FailoverListener:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 FailoverListener (Discovery::RepoKey key)
 Only construct with a repository key value.
virtual ~FailoverListener ()
 Virtual destructor.
virtual void on_requested_deadline_missed (DDS::DataReader_ptr reader, const DDS::RequestedDeadlineMissedStatus &status)
virtual void on_requested_incompatible_qos (DDS::DataReader_ptr reader, const DDS::RequestedIncompatibleQosStatus &status)
virtual void on_liveliness_changed (DDS::DataReader_ptr reader, const DDS::LivelinessChangedStatus &status)
virtual void on_subscription_matched (DDS::DataReader_ptr reader, const DDS::SubscriptionMatchedStatus &status)
virtual void on_sample_rejected (DDS::DataReader_ptr reader, const DDS::SampleRejectedStatus &status)
virtual void on_data_available (DDS::DataReader_ptr reader)
virtual void on_sample_lost (DDS::DataReader_ptr reader, const DDS::SampleLostStatus &status)
virtual void on_subscription_disconnected (DDS::DataReader_ptr reader, const OpenDDS::DCPS::SubscriptionDisconnectedStatus &status)
virtual void on_subscription_reconnected (DDS::DataReader_ptr reader, const OpenDDS::DCPS::SubscriptionReconnectedStatus &status)
virtual void on_subscription_lost (DDS::DataReader_ptr reader, const OpenDDS::DCPS::SubscriptionLostStatus &status)
virtual void on_connection_deleted (DDS::DataReader_ptr reader)
virtual void on_budget_exceeded (DDS::DataReader_ptr reader, const OpenDDS::DCPS::BudgetExceededStatus &status)

Private Attributes

Discovery::RepoKey key_

Detailed Description

Definition at line 24 of file FailoverListener.h.

Constructor & Destructor Documentation

OpenDDS::DCPS::FailoverListener::FailoverListener ( Discovery::RepoKey  key  ) 

Only construct with a repository key value.

Definition at line 15 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00016   : key_(key)
00017 {
00018   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00019     ACE_DEBUG((LM_DEBUG,
00020                ACE_TEXT("(%P|%t) FailoverListener::FailoverListener( key==%C)\n"),
00021                key.c_str()));
00022   }
00023 }

OpenDDS::DCPS::FailoverListener::~FailoverListener (  )  [virtual]

Virtual destructor.

Definition at line 25 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00026 {
00027   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00028     ACE_DEBUG((LM_DEBUG,
00029                ACE_TEXT("(%P|%t) FailoverListener::~FailoverListener\n")));
00030   }
00031 }

Member Function Documentation

void OpenDDS::DCPS::FailoverListener::on_budget_exceeded ( DDS::DataReader_ptr  reader,
const OpenDDS::DCPS::BudgetExceededStatus &  status 
) [virtual]

Definition at line 159 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00162 {
00163   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00164     ACE_DEBUG((LM_DEBUG,
00165                ACE_TEXT("(%P|%t) FailoverListener::on_budget_exceeded\n")));
00166   }
00167 }

void OpenDDS::DCPS::FailoverListener::on_connection_deleted ( DDS::DataReader_ptr  reader  )  [virtual]

Definition at line 149 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00151 {
00152   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00153     ACE_DEBUG((LM_DEBUG,
00154                ACE_TEXT("(%P|%t) FailoverListener::on_connection_deleted\n")));
00155   }
00156 }

void OpenDDS::DCPS::FailoverListener::on_data_available ( DDS::DataReader_ptr  reader  )  [virtual]

Definition at line 34 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00036 {
00037   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00038     ACE_DEBUG((LM_DEBUG,
00039                ACE_TEXT("(%P|%t) FailoverListener::on_data_available\n")));
00040   }
00041 }

void OpenDDS::DCPS::FailoverListener::on_liveliness_changed ( DDS::DataReader_ptr  reader,
const DDS::LivelinessChangedStatus &  status 
) [virtual]

Definition at line 68 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00071 {
00072   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00073     ACE_DEBUG((LM_DEBUG,
00074                ACE_TEXT("(%P|%t) FailoverListener::on_liveliness_changed\n")));
00075   }
00076 }

void OpenDDS::DCPS::FailoverListener::on_requested_deadline_missed ( DDS::DataReader_ptr  reader,
const DDS::RequestedDeadlineMissedStatus &  status 
) [virtual]

Definition at line 44 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00047 {
00048   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00049     ACE_DEBUG((LM_DEBUG,
00050                ACE_TEXT("(%P|%t) ")
00051                ACE_TEXT("Federatorer::on_requested_deadline_missed\n")));
00052   }
00053 }

void OpenDDS::DCPS::FailoverListener::on_requested_incompatible_qos ( DDS::DataReader_ptr  reader,
const DDS::RequestedIncompatibleQosStatus &  status 
) [virtual]

Definition at line 56 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00059 {
00060   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00061     ACE_DEBUG((LM_DEBUG,
00062                ACE_TEXT("(%P|%t) FailoverListener::")
00063                ACE_TEXT("on_requested_incompatible_qos\n")));
00064   }
00065 }

void OpenDDS::DCPS::FailoverListener::on_sample_lost ( DDS::DataReader_ptr  reader,
const DDS::SampleLostStatus &  status 
) [virtual]

Definition at line 101 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00104 {
00105   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00106     ACE_DEBUG((LM_DEBUG,
00107                ACE_TEXT("(%P|%t) FailoverListener::on_sample_lost\n")));
00108   }
00109 }

void OpenDDS::DCPS::FailoverListener::on_sample_rejected ( DDS::DataReader_ptr  reader,
const DDS::SampleRejectedStatus &  status 
) [virtual]

Definition at line 90 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00093 {
00094   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00095     ACE_DEBUG((LM_DEBUG,
00096                ACE_TEXT("(%P|%t) FailoverListener::on_sample_rejected\n")));
00097   }
00098 }

void OpenDDS::DCPS::FailoverListener::on_subscription_disconnected ( DDS::DataReader_ptr  reader,
const OpenDDS::DCPS::SubscriptionDisconnectedStatus &  status 
) [virtual]

Definition at line 112 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level, and TheServiceParticipant.

00115 {
00116   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00117     ACE_DEBUG((LM_DEBUG,
00118                ACE_TEXT("(%P|%t) FailoverListener::on_subscription_disconnected\n")));
00119   }
00120   TheServiceParticipant->repository_lost(this->key_);
00121 }

void OpenDDS::DCPS::FailoverListener::on_subscription_lost ( DDS::DataReader_ptr  reader,
const OpenDDS::DCPS::SubscriptionLostStatus &  status 
) [virtual]

Definition at line 135 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level, and TheServiceParticipant.

00138 {
00139   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00140     ACE_DEBUG((LM_DEBUG,
00141                ACE_TEXT("(%P|%t) FailoverListener::on_subscription_lost: ")
00142                ACE_TEXT("initiating failover sequencing.\n")));
00143   }
00144 
00145   TheServiceParticipant->repository_lost(this->key_);
00146 }

void OpenDDS::DCPS::FailoverListener::on_subscription_matched ( DDS::DataReader_ptr  reader,
const DDS::SubscriptionMatchedStatus &  status 
) [virtual]

Definition at line 79 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00082 {
00083   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00084     ACE_DEBUG((LM_DEBUG,
00085                ACE_TEXT("(%P|%t) FailoverListener::on_subscription_matched\n")));
00086   }
00087 }

void OpenDDS::DCPS::FailoverListener::on_subscription_reconnected ( DDS::DataReader_ptr  reader,
const OpenDDS::DCPS::SubscriptionReconnectedStatus &  status 
) [virtual]

Definition at line 124 of file FailoverListener.cpp.

References OpenDDS::DCPS::DCPS_debug_level.

00127 {
00128   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00129     ACE_DEBUG((LM_DEBUG,
00130                ACE_TEXT("(%P|%t) FailoverListener::on_subscription_reconnected\n")));
00131   }
00132 }

Member Data Documentation

Discovery::RepoKey OpenDDS::DCPS::FailoverListener::key_ [private]

Our repository key. If we trigger, this is the key to the repository that has been lost.

Definition at line 82 of file FailoverListener.h.

The documentation for this class was generated from the following files:
Generated on Fri Feb 12 20:06:18 2016 for OpenDDS by  doxygen 1.4.7