TAO/tests/AMI_Timeouts/timeout_client.h

   1 //=============================================================================
   2 /**
   3  *  @file    timeout_client.h
   4  *
   5  *  Tests timeouts with AMI.
   6  *
   7  *  @author Michael Kircher <Michael.Kircher@mchp.siemens.de>
   8  */
   9 //=============================================================================
  10
  11 #include "ace/Task.h"
  12 #include "timeout_i.h"
  13
  14 class TimeoutClient : public ACE_Task_Base
  15 {
  16 public:
  17   TimeoutClient (CORBA::ORB_ptr orb,
  18                  TimeoutObj_ptr timeoutObject,
  19                  AMI_TimeoutObjHandler_ptr replyHandlerObject,
  20                  TimeoutHandler_i *timeoutHandler_i,
  21                  unsigned long timeToWait);
  22
  23   ~TimeoutClient ();
  24
  25 private:
  26   // Initialize the context of this class.
  27   int initialize ();
  28
  29   // Run in a separate thread.
  30   virtual int svc ();
  31
  32   // Wrapps complex invocations logic.
  33   void send (CORBA::Boolean async,
  34              unsigned long local_timeout,
  35              unsigned long remote_sleep);
  36
  37   // Test if the synchronous timeouts still work.
  38   int synch_test ();
  39
  40   // Test the accuracy of the timeouts.
  41   int accuracy_test ();
  42
  43   // Test if the timeout functionality disturbs non-timeout invocations
  44   int none_test ();
  45
  46 private:
  47   CORBA::ORB_var orb_;
  48
  49   // A CORBA object reference to the target object.
  50   TimeoutObj_var timeoutObject_;
  51
  52   // A CORBA object reference to the reply handler
  53   AMI_TimeoutObjHandler_var replyHandlerObject_;
  54
  55   // A pointer to the actual C++ reply handler implementation
  56   TimeoutHandler_i *timeoutHandler_i_;
  57
  58   // Remember the policy manager.
  59   CORBA::PolicyManager_var policy_manager_;
  60
  61   // Count test local exceptions
  62   unsigned short local_reply_excep_counter_;
  63
  64   const CORBA::Boolean INVOKE_SYNCH;
  65
  66   const CORBA::Boolean INVOKE_ASYNCH;
  67
  68   unsigned long timeToWait_;
  69 };