TAO/tests/NestedUpcall/MT_Client_Test/client.h

   1
   2 //=============================================================================
   3 /**
   4  *  @file    client.h
   5  *
   6  *  Test for multithreaded client using one global ORB (and Reactor)
   7  *
   8  *  @author Michael Kircher
   9  */
  10 //=============================================================================
  11
  12 #ifndef MT_CLIENT_H
  13 #define MT_CLIENT_H
  14
  15 #include "ace/Get_Opt.h"
  16
  17 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  18 # pragma once
  19 #endif /* ACE_LACKS_PRAGMA_ONCE */
  20
  21 #include "ace/Task.h"
  22 #include "ace/Thread_Manager.h"
  23 #include "tao/ORB.h"
  24 #include "MT_Client_TestC.h"
  25
  26 /**
  27  * @class MT_Client
  28  *
  29  * @brief A simple client talking to one server
  30  *
  31  * It is connecting to a server which holds the Object_A
  32  * or using the "-m" switch to a server holding the MT_Object
  33  */
  34 class MT_Client
  35 {
  36
  37 public:
  38   /// = Constructor and destructor.
  39   MT_Client (void);
  40   ~MT_Client (void);
  41
  42   /// Execute client example code.
  43   int run (void);
  44
  45   /// Initialize the client communication endpoint with server.
  46   int init (int argc,
  47             ACE_TCHAR **argv,
  48             int client_number);
  49
  50 private:
  51   /// reading the IOR of object A in
  52   int read_ior (ACE_TCHAR *filename);
  53
  54   /// Parses the arguments passed on the command line.
  55   int parse_args (void);
  56
  57   /// # of arguments on the command line.
  58   int argc_;
  59
  60   /// arguments from command line.
  61   ACE_TCHAR **argv_;
  62
  63   /// Key of the object
  64   char *object_key_;
  65
  66   /// Flag to tell server to shutdown.
  67   int shutdown_;
  68
  69   /// Remember our orb.
  70   CORBA::ORB_var orb_var_;
  71
  72   /// pointer to the mt Object
  73   MT_Object_var mT_Object_var_;
  74
  75   /// This is used to choose the server...
  76   int client_number_;
  77
  78   /// number of loops
  79   unsigned long iterations_;
  80
  81 };
  82
  83 /**
  84  * @class MT_Client_Task
  85  *
  86  * @brief Wrapper for the MT_Client to be an extra thread
  87  *
  88  * No big purpose, just wrapping
  89  */
  90 class MT_Client_Task : public ACE_Task<ACE_SYNCH>
  91 {
  92 public:
  93   MT_Client_Task (int argc, ACE_TCHAR **argv, int client_number);
  94
  95   virtual int svc (void);
  96
  97 private:
  98   MT_Client mT_Client_;
  99   int argc_;
 100   ACE_TCHAR **argv_;
 101
 102   /// To determine if we use the first or the second server.
 103   int client_number_;
 104 };
 105
 106 #endif /* MT_CLIENT_H */