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
  38 protected:
  39   Sequence* test_client_;
  40 };
  41
  42 /***************************************************************************/
  43
  44 class SequencePushSupplier : public TAO_Notify_Tests_SequencePushSupplier
  45 {
  46 public:
  47   /// Constructor.
  48   SequencePushSupplier (Sequence * test_client);
  49
  50   /// Destructor.
  51   virtual ~SequencePushSupplier (void);
  52
  53 protected:
  54   Sequence* test_client_;
  55 };
  56
  57 /***************************************************************************/
  58
  59 class Sequence : public Notify_Test_Client
  60 {
  61 public:
  62   // Initialization and termination code.
  63   Sequence (void);
  64   virtual ~Sequence (void);
  65
  66   int parse_args (int argc,
  67                   ACE_TCHAR *argv[]) ;
  68
  69   /// Initialization.
  70   int init (int argc,
  71             ACE_TCHAR *argv []);
  72
  73   /// Called when an event is received.
  74   void on_event_received (void);
  75
  76   /// Run the test.
  77   void run_test (void);
  78
  79   /// End the test.
  80   void end_test (void);
  81
  82   /// check if we got the expected results.
  83   int check_results (void);
  84
  85 protected:
  86   /// Create EC
  87   void create_EC (void);
  88
  89   /// Number of events to send
  90   int event_count_;
  91
  92   /// Batch size send by supplier.
  93   CORBA::ULong supplier_batch_size_;
  94
  95   /// Max Batch size expected by consumer.
  96   CORBA::ULong consumer_batch_size_;
  97
  98   TimeBase::TimeT pacing_;
  99
 100   CORBA::Short order_policy_;
 101
 102   /// Count the number of events received by the consumer.
 103   ACE_Atomic_Op <TAO_SYNCH_MUTEX, int> events_received_;
 104
 105   ACE_Time_Value consumer_delay_;
 106
 107   /// The one channel that we create using the factory.
 108   CosNotifyChannelAdmin::EventChannel_var ec_;
 109
 110   /// The consumer admin used by consumers.
 111   CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin_;
 112
 113   /// The supplier admin used by suppliers.
 114   CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
 115
 116   /// Consumer
 117   TAO_Notify_Tests_SequencePushConsumer* consumer_;
 118
 119   /// Supplier
 120   TAO_Notify_Tests_SequencePushSupplier* supplier_;
 121
 122 private:
 123   friend class SequencePushSupplier;
 124   friend class SequencePushConsumer;
 125 };
 126
 127 /***************************************************************************/
 128
 129 #if defined(_MSC_VER)
 130 #pragma warning(pop)
 131 #endif /* _MSC_VER */
 132
 133 #endif /* NOTIFY_TESTS_SEQUENCE_H */