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

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Consumer.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_CONSUMER_H
   9 #define TAO_Notify_CONSUMER_H
  10
  11 #include /**/ "ace/pre.h"
  12
  13 #include "ORB_Objects.h"
  14 #include "tao/RTCORBA/RTCORBA.h"
  15 #include "orbsvcs/CosNotifyChannelAdminS.h"
  16 #include "orbsvcs/CosNotifyCommC.h"
  17 #include "ace/SString.h"
  18 #include "ace/OS_NS_time.h"
  19
  20 /**
  21  * @class TAO_Notify_ThreadPool_Consumer
  22  *
  23  * @brief Consumer
  24  */
  25
  26 class TAO_Notify_ThreadPool_Consumer
  27   : public POA_CosNotifyComm::StructuredPushConsumer
  28 {
  29 public:
  30   /// Constructor
  31   TAO_Notify_ThreadPool_Consumer (TAO_Notify_ORB_Objects& orb_objects);
  32
  33   /// Init
  34   void init (PortableServer::POA_var& poa, CosNotifyChannelAdmin::ConsumerAdmin_var& admin, int proxy_supplier_thread_count, int max_events, long delay);
  35
  36   /// Run
  37   void run (void);
  38
  39   /// Print the consumer throughput
  40   void dump_throughput (void);
  41
  42 protected:
  43   // = Methods
  44   /// Destructor
  45   virtual ~TAO_Notify_ThreadPool_Consumer (void);
  46
  47   /// Connect the Consumer to the EventChannel.
  48   /// Creates a new proxy supplier and connects to it.
  49   void connect (void);
  50
  51   /// Disconnect the supplier.
  52   void disconnect (void);
  53
  54   /// Deactivate.
  55   void deactivate (void);
  56
  57   // = ServantBase operations
  58   virtual PortableServer::POA_ptr _default_POA (void);
  59
  60   // = NotifyPublish method
  61   virtual void offer_change (
  62         const CosNotification::EventTypeSeq & added,
  63         const CosNotification::EventTypeSeq & removed);
  64
  65   // = StructuredPushSupplier methods
  66   virtual void push_structured_event (
  67         const CosNotification::StructuredEvent & notification);
  68
  69   virtual void disconnect_structured_push_consumer ();
  70
  71   // = Data members
  72
  73   /// Lock
  74   TAO_SYNCH_MUTEX lock_;
  75
  76   /// ORB Objects.
  77   TAO_Notify_ORB_Objects orb_objects_;
  78
  79   // POA.
  80   PortableServer::POA_var default_POA_;
  81
  82   /// The proxy that we are connected to.
  83   CosNotifyChannelAdmin::StructuredProxyPushSupplier_var proxy_supplier_;
  84
  85   /// The proxy_supplier id.
  86   CosNotifyChannelAdmin::ProxyID proxy_supplier_id_;
  87
  88   // The Consumer Admin
  89   CosNotifyChannelAdmin::ConsumerAdmin_var admin_;
  90
  91   /// The Type the Consumer should subscribe to.
  92   ACE_CString event_type_;
  93
  94   /// ProxySupplier thread count.
  95   int proxy_supplier_thread_count_;
  96
  97   /// Max events to receive
  98   int max_events_;
  99
 100   /// Count the number of events received.
 101   int events_received_count_;
 102
 103   /// Time when the first sample was received.
 104   //ACE_UINT64 t_first_;
 105   ACE_hrtime_t t_first_;
 106
 107   /// Time when the last sample was received.
 108   //ACE_UINT64 t_last_;
 109   ACE_hrtime_t t_last_;
 110
 111   /// Delay: Sec of wait in each push.
 112   ACE_Time_Value delay_;
 113 };
 114
 115 #include /**/ "ace/post.h"
 116 #endif /* TAO_Notify_CONSUMER_H */