TAO/orbsvcs/tests/FT_App/StubFaultNotifier.h

   1 // -*- C++ -*-
   2 #ifndef STUBFAULTNOTIFIER_H_
   3 #define STUBFAULTNOTIFIER_H_
   4
   5 #include <ace/ACE.h>
   6
   7 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   8 #pragma once
   9 #endif /* ACE_LACKS_PRAGMA_ONCE */
  10 #include  /**/ <ace/pre.h>
  11
  12 #include <orbsvcs/FT_NotifierS.h>
  13 #include <orbsvcs/FT_FaultDetectorFactoryC.h>
  14 #include <ace/Vector_T.h>
  15 #include <ace/SString.h>
  16
  17 //////////////////////
  18 // Forward references
  19
  20 /////////////////////
  21 // Class declarations
  22
  23 /**
  24  * A stub implementation of the FaultNotifier interface
  25  */
  26 class  StubFaultNotifier : public virtual POA_FT::FaultNotifier
  27 {
  28   //////////////////////
  29   // non-CORBA interface
  30 public:
  31   /**
  32    * Default constructor.
  33    */
  34   StubFaultNotifier ();
  35
  36   /**
  37    * Virtual destructor.
  38    */
  39   virtual ~StubFaultNotifier ();
  40
  41   /**
  42    * Parse command line arguments.
  43    */
  44   int parse_args (int argc, ACE_TCHAR * argv[]);
  45
  46   /**
  47    * Initialize.
  48    */
  49   int init (CORBA::ORB_ptr orb);
  50
  51   /**
  52    * Prepare to exit.
  53    */
  54   int fini (void);
  55
  56   /**
  57    * Return a string to identify this object for logging/console message purposes.
  58    */
  59   const ACE_TCHAR * identity () const;
  60
  61   /**
  62    * idle time activity.
  63    * @param result [out] status code to return from process
  64    * @returns 0 to continue; nonzero to quit
  65    */
  66   int idle(int &result);
  67
  68   // override virtuals
  69 ::PortableServer::POA_ptr _default_POA (void);
  70
  71   PortableServer::ObjectId objectId()const;
  72
  73
  74   /**
  75    * Clean house for process shut down.
  76    */
  77   void shutdown_i (void);
  78
  79   ////////////////////////////////
  80   // CORBA interface FaultNotifier
  81
  82
  83   virtual void push_structured_fault (
  84       const CosNotification::StructuredEvent & event
  85     );
  86
  87   virtual void push_sequence_fault (
  88     const CosNotification::EventBatch & events
  89   );
  90
  91   virtual ::CosNotifyFilter::Filter_ptr create_subscription_filter (
  92     const char * constraint_grammar
  93   );
  94
  95   virtual FT::FaultNotifier::ConsumerId connect_structured_fault_consumer (
  96     CosNotifyComm::StructuredPushConsumer_ptr push_consumer,
  97     CosNotifyFilter::Filter_ptr filter
  98   );
  99
 100   virtual FT::FaultNotifier::ConsumerId connect_sequence_fault_consumer (
 101     CosNotifyComm::SequencePushConsumer_ptr push_consumer,
 102     CosNotifyFilter::Filter_ptr filter
 103   );
 104
 105   virtual void disconnect_consumer (
 106     FT::FaultNotifier::ConsumerId connection
 107   );
 108
 109   //////////////////////////////////////////
 110   // CORBA interface PullMonitorable methods
 111   virtual CORBA::Boolean is_alive (void);
 112
 113   /////////////////
 114   // Implementation
 115 private:
 116   int write_ior_file();
 117
 118   ///////////////
 119   // Data Members
 120 private:
 121   /**
 122    * The orb
 123    */
 124   CORBA::ORB_var orb_;
 125
 126   /**
 127    * The POA used to activate this object.
 128    */
 129   PortableServer::POA_var poa_;
 130
 131   /**
 132    * The CORBA object id assigned to this object.
 133    */
 134   PortableServer::ObjectId_var object_id_;
 135
 136   /**
 137    * IOR of this object as assigned by poa
 138    */
 139   CORBA::String_var ior_;
 140
 141   /**
 142    * A file to which the factory's IOR should be written.
 143    */
 144   const ACE_TCHAR * ior_output_file_;
 145
 146   /**
 147    * A file from which the detector's IOR should be read.
 148    */
 149   const ACE_TCHAR * detector_ior_;
 150
 151   ::FT::FaultDetectorFactory_var factory_;
 152
 153   /**
 154    * A collection of files containing replica IORs
 155    */
 156   ACE_Vector < const char * > iorReplicaFiles_;
 157
 158
 159   ACE_Vector < FT::PullMonitorable_var > replicas_;
 160   /**
 161    * A name to be used to register with the name service.
 162    */
 163   ACE_CString ns_name_;
 164
 165   /**
 166    * A human-readable string to distinguish this from other Notifiers.
 167    */
 168   ACE_TString identity_;
 169 };
 170
 171 #include /**/ <ace/post.h>
 172
 173 #endif /* STUBFAULTNOTIFIER_H_  */