TAO/orbsvcs/tests/FT_App/StubFaultAnalyzer.h

   1 // -*- C++ -*-
   2 #ifndef STUBFAULTANALYZER_H
   3 #define STUBFAULTANALYZER_H
   4 #include /**/ <ace/pre.h>
   5 #include <ace/ACE.h>
   6
   7 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   8 #pragma once
   9 #endif /* ACE_LACKS_PRAGMA_ONCE */
  10
  11 #include "StubFaultConsumer.h"
  12 #include "StubBatchConsumer.h"
  13 #include <orbsvcs/FT_NotifierC.h>
  14 #include <orbsvcs/FT_FaultDetectorFactoryC.h>
  15
  16 #include "ace/Vector_T.h"
  17 #include "ace/SString.h"
  18
  19 //////////////////////
  20 // Forward references
  21
  22 /////////////////////
  23 // Class declarations
  24
  25 /**
  26  * A stub fault analyzer for use in unit testing.
  27  */
  28 class  StubFaultAnalyzer
  29 {
  30 public:
  31   /**
  32    * Default constructor.
  33    */
  34   StubFaultAnalyzer ();
  35
  36   /**
  37    * destructor.
  38    */
  39   ~StubFaultAnalyzer ();
  40
  41   /**
  42    * Parse command line arguments.
  43    */
  44   int parse_args (int argc, ACE_TCHAR * argv[]);
  45
  46   /**
  47    * Initialize this object
  48    */
  49   int init (CORBA::ORB_ptr orb);
  50
  51   /**
  52    * Return a string to identify this object for logging/console message purposes.
  53    */
  54   const char * identity () const;
  55
  56   /**
  57    * idle time activity.
  58    * @param result [out] status code to return from process
  59    * @returns 0 to continue; nonzero to quit
  60    */
  61   int idle(int &result);
  62
  63   /**
  64    * Prepare to exit.
  65    * @return zero for success; nonzero is process return code for failure.
  66    */
  67   int fini (void);
  68
  69   /////////////////
  70   // Implementation
  71 private:
  72   int readIORFile(const ACE_TCHAR * fileName, CORBA::String_var & ior);
  73
  74   ///////////////
  75   // Data Members
  76 private:
  77   /**
  78    * The orb
  79    */
  80   CORBA::ORB_var orb_;
  81
  82   /**
  83    * The POA used to activate this object.
  84    */
  85   PortableServer::POA_var poa_;
  86
  87   /**
  88    * The CORBA object id assigned to this object.
  89    */
  90   PortableServer::ObjectId_var objectId_;
  91
  92   /**
  93    * A human-readable string to distinguish this from other Notifiers.
  94    */
  95   ACE_CString identity_;
  96
  97   /**
  98    * a file to write to to signal "ready"
  99    */
 100   const ACE_TCHAR * readyFile_;
 101
 102   /**
 103    * The detector's IOR  (-d option)
 104    */
 105   const ACE_TCHAR * detector_ior_;
 106
 107   ::FT::FaultDetectorFactory_var factory_;
 108
 109   /**
 110    * The notifier's IOR (-n option)
 111    */
 112   const ACE_TCHAR * notifier_ior_;
 113
 114   ::FT::FaultNotifier_var notifier_;
 115
 116   /**
 117    * A collection of files containing replica IORs
 118    */
 119   ACE_Vector < const char * > replicaIORs;
 120
 121   ACE_Vector < FT::PullMonitorable_var > replicas_;
 122
 123
 124   StubFaultConsumer faultConsumer_;
 125   StubBatchConsumer batchConsumer_;
 126
 127 };
 128
 129 #include /**/ <ace/post.h>
 130
 131 #endif /* STUBFAULTANALYZER_H  */