TAO/orbsvcs/tests/FT_App/ReplicationManagerFaultConsumerAdapter.h

   1 // -*- C++ -*-
   2 #ifndef REPLICATION_MANAGER_FAULT_CONSUMER_ADAPTER_H
   3 #define REPLICATION_MANAGER_FAULT_CONSUMER_ADAPTER_H
   4 #include /**/ <ace/pre.h>
   5 #include <ace/ACE.h>
   6 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   7 #pragma once
   8 #endif /* ACE_LACKS_PRAGMA_ONCE */
   9
  10 #include <orbsvcs/FT_ReplicationManager/FT_FaultConsumer.h>
  11 #include <orbsvcs/FT_NotifierC.h>
  12 #include <orbsvcs/FT_FaultDetectorFactoryC.h>
  13 #include <ace/Vector_T.h>
  14 #include <ace/SString.h>
  15
  16 /////////////////////
  17 // Class declarations
  18
  19 /**
  20  * An adapter to the Replication Manager's fault consumer
  21  * for use in unit testing Fault Notifier and Fault Consumer.
  22  */
  23 class ReplicationManagerFaultConsumerAdapter
  24 {
  25 public:
  26   /**
  27    * Default constructor.
  28    */
  29   ReplicationManagerFaultConsumerAdapter ();
  30
  31   /**
  32    * virtual destructor.
  33    */
  34   virtual ~ReplicationManagerFaultConsumerAdapter ();
  35
  36   /**
  37    * Parse command line arguments.
  38    */
  39   int parse_args (int argc, ACE_TCHAR * argv[]);
  40
  41   /**
  42    * Initialize this object
  43    */
  44   int init (CORBA::ORB_ptr orb);
  45
  46   /**
  47    * Return a string to identify this object for logging/console message purposes.
  48    */
  49   const char * identity () const;
  50
  51   /**
  52    * idle time activity.
  53    * @param result [out] status code to return from process
  54    * @returns 0 to continue; nonzero to quit
  55    */
  56   int idle(int &result);
  57
  58   /**
  59    * Clean house for process shut down.
  60    */
  61   int fini ();
  62
  63
  64   size_t notifications() const;
  65
  66   /////////////////
  67   // Implementation
  68 private:
  69   ////////////////////
  70   // Forbidden methods
  71 private:
  72   ReplicationManagerFaultConsumerAdapter (
  73     const ReplicationManagerFaultConsumerAdapter & rhs);
  74   ReplicationManagerFaultConsumerAdapter & operator =
  75     (const ReplicationManagerFaultConsumerAdapter & rhs);
  76
  77   /////////////////////////
  78   // Implementation methods
  79 private:
  80   ///////////////
  81   // Data Members
  82 private:
  83   /**
  84    * The orb
  85    */
  86   CORBA::ORB_var orb_;
  87
  88   /**
  89    * A human-readable string to distinguish this from other FaultConsumers.
  90    */
  91   ACE_CString identity_;
  92
  93   /**
  94    * boolean: request quit
  95    */
  96   int quit_;
  97
  98   /**
  99    * a file to write to to signal "ready"
 100    */
 101   const ACE_TCHAR * readyFile_;
 102
 103   /**
 104    * Detector's IOR
 105    */
 106   const ACE_TCHAR * detector_ior_;
 107
 108   /**
 109    * The FaultDetectorFactory object reference.
 110    */
 111   ::FT::FaultDetectorFactory_var factory_;
 112
 113   /**
 114    * A collection of replica IORs
 115    */
 116   ACE_Vector < const char * > replica_iors_;
 117
 118   /**
 119    * A collection of replica references.
 120    */
 121   ACE_Vector < FT::PullMonitorable_var > replicas_;
 122
 123   /**
 124    * A file from which the notifier's IOR should be read.
 125    */
 126   const ACE_TCHAR * notifier_ior_;
 127
 128   /**
 129    * the fault notifier
 130    */
 131   ::FT::FaultNotifier_var notifier_;
 132
 133   /**
 134    * consumer id assigned by the notifier
 135    */
 136   ::FT::FaultNotifier::ConsumerId consumerId_;
 137
 138   /**
 139    * the real fault consumer
 140    */
 141   TAO::FT_FaultConsumer* p_fault_consumer_;
 142   PortableServer::ServantBase_var consumer_servant_;
 143 };
 144 #include /**/ <ace/post.h>
 145
 146 #endif /* REPLICATION_MANAGER_FAULT_CONSUMER_ADAPTER_H  */