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

   1 /* -*- C++ -*- */
   2 //=============================================================================
   3 /**
   4  *  @file   Sequence.h
   5  *
   6  * Test Sequence support in Notification.
   7  *
   8  *  @author Pradeep Gore <pradeep@cs.wustl.edu>
   9  */
  10 //=============================================================================
  11
  12
  13 #ifndef NOTIFY_TESTS_SEQUENCE_H
  14 #define NOTIFY_TESTS_SEQUENCE_H
  15
  16 #include "Notify_Test_Client.h"
  17 #include "Notify_SequencePushConsumer.h"
  18 #include "Notify_SequencePushSupplier.h"
  19 #include "orbsvcs/TimeBaseC.h"
  20
  21 #if defined(_MSC_VER)
  22 #pragma warning(push)
  23 #pragma warning(disable:4250)
  24 #endif /* _MSC_VER */
  25
  26 class Sequence;
  27
  28 class SequencePushConsumer : public TAO_Notify_Tests_SequencePushConsumer
  29 {
  30 public:
  31   SequencePushConsumer (Sequence* client);
  32
  33   // = SequencePushConsumer methods
  34   virtual void push_structured_events (
  35         const CosNotification::EventBatch & notifications);
  36
  37 protected:
  38   Sequence* test_client_;
  39 };
  40
  41 /***************************************************************************/
  42
  43 class SequencePushSupplier : public TAO_Notify_Tests_SequencePushSupplier
  44 {
  45 public:
  46   /// Constructor.
  47   SequencePushSupplier (Sequence * test_client);
  48
  49   /// Destructor.
  50   virtual ~SequencePushSupplier ();
  51
  52 protected:
  53   Sequence* test_client_;
  54 };
  55
  56 /***************************************************************************/
  57
  58 class Sequence : public Notify_Test_Client
  59 {
  60 public:
  61   // Initialization and termination code.
  62   Sequence ();
  63   virtual ~Sequence ();
  64
  65   int parse_args (int argc,
  66                   ACE_TCHAR *argv[]) ;
  67
  68   /// Initialization.
  69   int init (int argc,
  70             ACE_TCHAR *argv []);
  71
  72   /// Called when an event is received.
  73   void on_event_received ();
  74
  75   /// Run the test.
  76   void run_test ();
  77
  78   /// End the test.
  79   void end_test ();
  80
  81   /// check if we got the expected results.
  82   int check_results ();
  83
  84 protected:
  85   /// Create EC
  86   void create_EC ();
  87
  88   /// Number of events to send
  89   int event_count_;
  90
  91   /// Batch size send by supplier.
  92   CORBA::ULong supplier_batch_size_;
  93
  94   /// Max Batch size expected by consumer.
  95   CORBA::ULong consumer_batch_size_;
  96
  97   TimeBase::TimeT pacing_;
  98
  99   CORBA::Short order_policy_;
 100
 101   /// Count the number of events received by the consumer.
 102   ACE_Atomic_Op <TAO_SYNCH_MUTEX, int> events_received_;
 103
 104   ACE_Time_Value consumer_delay_;
 105
 106   /// The one channel that we create using the factory.
 107   CosNotifyChannelAdmin::EventChannel_var ec_;
 108
 109   /// The consumer admin used by consumers.
 110   CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin_;
 111
 112   /// The supplier admin used by suppliers.
 113   CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
 114
 115   /// Consumer
 116   TAO_Notify_Tests_SequencePushConsumer* consumer_;
 117
 118   /// Supplier
 119   TAO_Notify_Tests_SequencePushSupplier* supplier_;
 120
 121 private:
 122   friend class SequencePushSupplier;
 123   friend class SequencePushConsumer;
 124 };
 125
 126 /***************************************************************************/
 127
 128 #if defined(_MSC_VER)
 129 #pragma warning(pop)
 130 #endif /* _MSC_VER */
 131
 132 #endif /* NOTIFY_TESTS_SEQUENCE_H */