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_budget_exceeded (DDS::DataReader_ptr reader, const OpenDDS::DCPS::BudgetExceededStatus &status)

Private Attributes

Discovery::RepoKey key_

Detailed Description

Definition at line 26 of file FailoverListener.h.

Constructor & Destructor Documentation

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

Only construct with a repository key value.

Definition at line 17 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Virtual destructor.

Definition at line 27 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

Member Function Documentation

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

Definition at line 152 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

00155 {
00156   if (OpenDDS::DCPS::DCPS_debug_level > 0) {
00157     ACE_DEBUG((LM_DEBUG,
00158                ACE_TEXT("(%P|%t) FailoverListener::on_budget_exceeded\n")));
00159   }
00160 }

Here is the call graph for this function:

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

Definition at line 36 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 70 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 46 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 58 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 103 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 92 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 114 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, key_, LM_DEBUG, and TheServiceParticipant.

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

Here is the call graph for this function:

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

Definition at line 137 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, key_, LM_DEBUG, and TheServiceParticipant.

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

Here is the call graph for this function:

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

Definition at line 81 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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

Definition at line 126 of file FailoverListener.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

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

Here is the call graph for this function:

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 81 of file FailoverListener.h.

Referenced by on_subscription_disconnected(), and on_subscription_lost().

The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines
Generated on 10 Aug 2018 for OpenDDS by  doxygen 1.6.1