TAO/orbsvcs/examples/Notify/ThreadPool/Supplier.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Supplier.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_SUPPLIER_H
   9 #define TAO_Notify_SUPPLIER_H
  10 #include /**/ "ace/pre.h"
  11
  12 #include "ORB_Objects.h"
  13 #include "tao/RTCORBA/RTCORBA.h"
  14 #include "orbsvcs/CosNotifyChannelAdminS.h"
  15 #include "orbsvcs/CosNotifyCommC.h"
  16 #include "ace/Condition_Thread_Mutex.h"
  17
  18 #define TEST_MAX_CONSUMERS 10
  19
  20 /**
  21  * @class TAO_Notify_ThreadPool_Supplier
  22  *
  23  * @brief Implement a Structured Supplier.
  24  */
  25 class TAO_Notify_ThreadPool_Supplier
  26   : public POA_CosNotifyComm::StructuredPushSupplier
  27 {
  28 public:
  29   /// Constructor.
  30   TAO_Notify_ThreadPool_Supplier (TAO_Notify_ORB_Objects& orb_objects);
  31
  32   /// Init
  33   void init (CosNotifyChannelAdmin::SupplierAdmin_var& admin, int expected_consumer_count, int max_events,
  34              int proxy_consumer_thread_count);
  35
  36   /// Run
  37   void run ();
  38
  39 protected:
  40   // = Protected Methods
  41
  42   /// Connect the Supplier to the EventChannel.
  43   /// Creates a new proxy consumer and connects to it.
  44   void connect ();
  45
  46   /// Disconnect the supplier.
  47   void disconnect ();
  48
  49   /// Deactivate.
  50   void deactivate ();
  51
  52   /// Send one event.
  53   virtual void send_event (const CosNotification::StructuredEvent& event);
  54
  55   /// Destructor
  56   virtual ~TAO_Notify_ThreadPool_Supplier ();
  57
  58   // = NotifySubscribe
  59   virtual void subscription_change (
  60         const CosNotification::EventTypeSeq & added,
  61         const CosNotification::EventTypeSeq & removed);
  62
  63   // = StructuredPushSupplier method
  64   virtual void disconnect_structured_push_supplier ();
  65   /// = Data members
  66
  67   /// ORB Objects.
  68   TAO_Notify_ORB_Objects orb_objects_;
  69
  70   /// The proxy that we are connected to.
  71   CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxy_consumer_;
  72
  73   /// This supplier's id.
  74   CosNotifyChannelAdmin::ProxyID proxy_consumer_id_;
  75
  76   /// Number of Consumers expected to connect.
  77   int expected_consumer_count_;
  78
  79   // The ORB that we use.
  80   CORBA::ORB_var orb_;
  81
  82   // The Supplier Admin
  83   CosNotifyChannelAdmin::SupplierAdmin_var admin_;
  84
  85   /// Lock to serialize internal state.
  86   TAO_SYNCH_MUTEX lock_;
  87
  88   /// Condition that consumers are connected.
  89   TAO_SYNCH_CONDITION consumers_connected_;
  90
  91   /// Number of consumers connected.
  92   int consumer_count_;
  93
  94   /// Number of events to send.
  95   int max_events_;
  96
  97   /// Number of Threads at the ProxyConsumer.
  98   int proxy_consumer_thread_count_;
  99
 100   /// Array of events to send.
 101   CosNotification::StructuredEvent event_[TEST_MAX_CONSUMERS];
 102 };
 103
 104 #include /**/ "ace/post.h"
 105 #endif /* TAO_Notify_SUPPLIER_H */