TAO/orbsvcs/tests/Notify/Basic/AdminProperties.h

   1 /* -*- C++ -*- */
   2 //=============================================================================
   3 /**
   4  *  @file   AdminProperties.h
   5  *
   6  * Test for EC Admin QoS properties.
   7  *
   8  *  @author Pradeep Gore <pradeep@cs.wustl.edu>
   9  */
  10 //=============================================================================
  11
  12
  13 #ifndef ADMINPROPERTIES
  14 #define ADMINPROPERTIES
  15
  16 #include "ace/Task.h"
  17 #include "Notify_Test_Client.h"
  18 #include "Notify_StructuredPushConsumer.h"
  19 #include "Notify_StructuredPushSupplier.h"
  20
  21 class AdminProperties;
  22 /***************************************************************************/
  23
  24 class AdminProperties_StructuredPushConsumer : public TAO_Notify_Tests_StructuredPushConsumer
  25 {
  26   friend class AdminProperties;
  27 public:
  28   AdminProperties_StructuredPushConsumer (AdminProperties* client);
  29
  30   // = StructuredPushSupplier methods
  31   virtual void push_structured_event (const CosNotification::StructuredEvent & notification
  32                                       );
  33
  34 protected:
  35   AdminProperties* client_;
  36
  37   ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::Long> events_received_;
  38 };
  39
  40
  41 /**
  42  * @class AdminProperties_Task
  43  *
  44  * @brief Run a thread to dispatch events.
  45  *
  46  * Use the ACE_Task_Base class.
  47  */
  48 class AdminProperties_Task : public ACE_Task_Base
  49 {
  50
  51 public:
  52   /// Constructor.
  53   AdminProperties_Task (void);
  54
  55   /// Init this object.
  56   void init (TAO_Notify_Tests_StructuredPushSupplier *supplier, AdminProperties* client);
  57
  58   virtual int init (int argc, ACE_TCHAR *argv []);
  59
  60   /// The thread entry point.
  61   virtual int svc (void);
  62
  63 private:
  64   /// Supplier
  65   TAO_Notify_Tests_StructuredPushSupplier *supplier_;
  66
  67   /// Client Object.
  68   AdminProperties* client_;
  69 };
  70
  71 /***************************************************************************/
  72
  73 /**
  74  * @class AdminProperties
  75  *
  76  * @brief AdminProperties
  77  *
  78  * Test for Notify EC properties -
  79  * max_queue_length
  80  * max_consumers
  81  * max_suppliers
  82  * reject_new_events
  83  */
  84 class AdminProperties : public Notify_Test_Client
  85 {
  86
  87   friend class AdminProperties_StructuredPushConsumer;
  88   friend class AdminProperties_Task;
  89
  90 public:
  91   AdminProperties (void);
  92   ~AdminProperties (void);
  93
  94   int parse_args (int argc, ACE_TCHAR *argv[]) ;
  95
  96   // Initialization.
  97
  98   /// Run the test.
  99   void run_test (void);
 100
 101 private:
 102   void create_suppliers (void);
 103   void create_consumers (void);
 104   void create_channel(bool reject);
 105
 106   /// Test MaxSuppliers and MaxConsumers
 107   void test_max_clients (void);
 108
 109   /// Test MaxQueueLength properties
 110   void test_max_queue_length (bool reject);
 111
 112   // Data Members
 113   /// The one channel that we create using the factory.
 114   CosNotifyChannelAdmin::EventChannel_var ec_;
 115
 116   /// The consumer admin used by consumers.
 117   CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin_;
 118
 119   /// The supplier admin used by suppliers.
 120   CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
 121
 122   /// Values for Admin Properties supplied by user.
 123   CORBA::Long max_queue_length_;
 124   CORBA::Long max_consumers_;
 125   CORBA::Long max_suppliers_;
 126   CORBA::Boolean reject_new_events_;
 127
 128   /// Number of consumers to connect to check MaxConsumers property.
 129   CORBA::Long consumers_;
 130
 131   /// Number of suppliers to connect to check MaxSuppliers property.
 132   CORBA::Long suppliers_;
 133
 134   /// Number of events to send to the channel.
 135   CORBA::Long event_count_;
 136
 137   /// Count of consumers successfully connect to the EC.
 138   int suppliers_connected_count_;
 139
 140   /// Count of consumers successfully connect to the EC.
 141   int consumers_connected_count_;
 142
 143   // Number of supplier pushes that resulted in an IMP_LIMIT exception
 144   int rejections_;
 145 };
 146
 147 #endif /* ADMINPROPERTIES */