TAO/orbsvcs/Time_Service/Clerk_i.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file    Clerk_i.h
   6  *
   7  *  @author Vishal Kachroo <vishal@cs.wustl.edu>
   8  */
   9 //=============================================================================
  10
  11
  12 #ifndef CLERK_I_H
  13 #define CLERK_I_H
  14
  15 #include "ace/Get_Opt.h"
  16 #include "ace/Log_Msg.h"
  17 #include "tao/Utils/ORB_Manager.h"
  18 #include "orbsvcs/CosNamingC.h"
  19 #include "orbsvcs/Naming/Naming_Client.h"
  20 #include "orbsvcs/Time/TAO_Time_Service_Clerk.h"
  21
  22 /**
  23  * @class Clerk_i
  24  *
  25  * @brief CORBA Time Clerk implementation.
  26  *
  27  * A CORBA server that initializes the TimeService clerk
  28  * implementation and the ORB.
  29  */
  30 class Clerk_i
  31 {
  32 public:
  33
  34   enum {
  35     // Pre-allocate slots for this many servers. The capacity grows on
  36     // demand.
  37     DEFAULT_SERVER_COUNT = 8
  38   };
  39
  40   /// Constructor.
  41   Clerk_i (void);
  42
  43   /// Destructor.
  44   ~Clerk_i (void);
  45
  46   /// Set of available Time servers.
  47   typedef ACE_Array_Base<CosTime::TimeService_var> IORS;
  48
  49   /// Initialize the Clerk state - parsing arguments and waiting.
  50   int init (int argc,
  51             ACE_TCHAR *argv[]);
  52
  53   /// Run the orb.
  54   int run (void);
  55
  56 private:
  57   /// Insert a server in the internal data structure (servers_).
  58   void insert_server (CosTime::TimeService_ptr server);
  59
  60 private:
  61
  62   /// Read the server IORs from a file instead of using a naming
  63   /// service.
  64   int read_ior (const ACE_TCHAR* filename);
  65
  66   /// Parses the commandline arguments.
  67   int parse_args (int argc,
  68                   ACE_TCHAR* argv[]);
  69
  70   /// The ORB manager.
  71   TAO_ORB_Manager orb_manager_;
  72
  73   /// File where the IOR of the Clerk object is stored.
  74   FILE *ior_output_file_;
  75
  76   /// Initialises the name client and registers the <TimeService> Clerk
  77   /// object with it.
  78   int init_naming_service ();
  79
  80   /// Create an instance of the clerk to use.
  81   int create_clerk (void);
  82
  83   /// Bind the clerk in the appropriate context in the Naming Service.
  84   int register_clerk (void);
  85
  86   /// Initialise the Interface Repository and register the clerk
  87   /// implementation with it.
  88   int init_IR (void);
  89
  90   /// Get the reference to the server naming context and the first
  91   /// server IOR.
  92   int get_first_IOR (void);
  93
  94   /// Iterate over the given server context to get the rest of the
  95   /// server IORs.
  96   int next_n_IORs (CosNaming::BindingIterator_var iter,
  97                    CosNaming::NamingContext_var server_context);
  98
  99   /**
 100    * An instance of the name server used for registering the
 101    * <TimeService Clerk> object. The same instance is used by the
 102    * Clerk to periodically iterate through the Server Naming Context
 103    * and get IORs of the available servers.
 104    */
 105   TAO_Naming_Client naming_client_;
 106
 107   /// Implementation of the <TimeService> Clerk object.
 108   TAO_Time_Service_Clerk *time_service_clerk_impl_;
 109
 110   /// Reference of the time service clerk.
 111   CosTime::TimeService_var time_service_clerk_;
 112
 113   /// Naming context for the Naming Service.
 114   CosNaming::NamingContext_var time_service_clerk_context_;
 115
 116   /// My orb.
 117   CORBA::ORB_var orb_;
 118
 119   /// Clerk seeks time periodically after this interval in secs. from the
 120   /// servers in the network.
 121   int timer_value_ ;
 122
 123   /// Continues the precision of timer_value_ in microseconds.
 124   int timer_value_usecs_;
 125
 126   //  IR_Helper *ir_helper_;
 127   // Helper class for using the IR.
 128
 129   /// The unbounded set of server IORS.
 130   IORS server_;
 131
 132   /// Read IORs from a file.
 133   int ior_fp_;
 134 };
 135
 136 #endif /* CLERK_I_H */