TAO/tests/Bug_3068_Regression/test_i.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file   test_i.h
   6  *
   7  *  @author Balachandran Natarajan <bala@cs.wustl.edu>
   8  */
   9 //=============================================================================
  10
  11
  12 #ifndef TAO_BIDIRECTIONAL_TEST_I_H
  13 #define TAO_BIDIRECTIONAL_TEST_I_H
  14
  15 #include "testS.h"
  16 #include "ace/Task.h"
  17 #include "ace/Synch.h"
  18 #include "ace/Condition_T.h"
  19
  20 class Caller : public ACE_Task_Base
  21 {
  22 public:
  23   Caller (Callback_ptr cb, CORBA::ORB_ptr orb);
  24   void go ();
  25
  26   int svc ();
  27
  28 private:
  29   Callback_var cbobj_;
  30   CORBA::ORB_var orb_;
  31   TAO_SYNCH_MUTEX lock_;
  32   ACE_Condition<TAO_SYNCH_MUTEX> cond_;
  33   bool going_;
  34   CORBA::OctetSeq payload_;
  35 };
  36
  37
  38 /**
  39  * @class Callback_i
  40  *
  41  * @brief A callback object to the "client"
  42  *
  43  * To test that the server can call the client on the same
  44  * connection that was established by the client
  45  */
  46 class Callback_i : public POA_Callback
  47 {
  48 public:
  49   /// ctor
  50   Callback_i (CORBA::ORB_ptr orb);
  51
  52   /// Safe way to shutdown
  53   void shutdown ();
  54
  55   /// The callback method
  56   void callback_method (const CORBA::OctetSeq& payload);
  57
  58 private:
  59   /// The orb
  60   CORBA::ORB_var orb_;
  61 };
  62
  63 /**
  64  * @class Simple_Server_i
  65  *
  66  * @brief Simpler Server implementation
  67  *
  68  * Implements the Simple_Server interface in test.idl
  69  * for (int loop = 0; loop < 10; loop++)
  70  */
  71 class Simple_Server_i : public POA_Simple_Server
  72 {
  73 public:
  74   /// ctor
  75   Simple_Server_i (CORBA::ORB_ptr orb);
  76
  77   // = The Simple_Server methods.
  78   void ow_test ();
  79
  80   CORBA::Long test_method (CORBA::Boolean do_callback);
  81
  82   void callback_object (Callback_ptr callback);
  83
  84   void shutdown ();
  85
  86 private:
  87   /// The ORB
  88   CORBA::ORB_var orb_;
  89
  90   /// Callback Object
  91   Caller *caller_;
  92
  93   /// Number of times the callback needs to be called
  94   int ow_count_;
  95 };
  96
  97 #if defined(__ACE_INLINE__)
  98 #include "test_i.inl"
  99 #endif /* __ACE_INLINE__ */
 100
 101 #endif /* TAO_BIDIRECTIONAL_TEST_I_H */