1 files changed, 153 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/examples/CosEC/RtEC_Based/lib/CosEvent_Utilities.h b/ACE/TAO/orbsvcs/examples/CosEC/RtEC_Based/lib/CosEvent_Utilities.h
new file mode 100644
index 00000000000..b9dbf4271ea
--- /dev/null
+++ b/ACE/TAO/orbsvcs/examples/CosEC/RtEC_Based/lib/CosEvent_Utilities.h
@@ -0,0 +1,153 @@
+/* -*- C++ -*- */
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    TAO/orbsvcs/orbsvcs
+//
+// = FILENAME
+//     CosEvent_Utilities.h
+//
+// = DESCRIPTION
+//    A few utility classes to make it easier to write EC applications.
+//
+// = AUTHOR
+//    Pradeep Gore <pradeep@cs.wustl.edu>
+//
+// ============================================================================
+
+#ifndef TAO_COSEVENT_UTILITIES_H
+#define TAO_COSEVENT_UTILITIES_H
+#include /**/ "ace/pre.h"
+
+#include "orbsvcs/RtecBaseC.h"
+#include "orbsvcs/RtecEventChannelAdminS.h"
+#include "orbsvcs/CosEventChannelAdminS.h"
+#include "orbsvcs/Event_Utilities.h"
+#include "rtec_cosec_export.h"
+
+class TAO_CosEC_EventChannel_i;
+
+class TAO_RTEC_COSEC_Export CosEC_ServantBase :
+  public virtual POA_CosEventChannelAdmin::EventChannel
+{
+  // = TITLE
+  //   A generic servant base class.
+  // = DESCRIPTION
+  //   This class contains all the member data and methods required to
+  //   create and manage a CosEC servant.
+  //   Clients can derive from this class and create servants.
+ public:
+  // = Initialization method.
+  CosEC_ServantBase (void);
+  // Constructor.
+
+  virtual ~CosEC_ServantBase (void);
+  // Destructor.
+
+  virtual void init (PortableServer::POA_ptr thispoa,
+                     PortableServer::POA_ptr poa,
+                     ACE_TCHAR *eventTypeIds,
+                     ACE_TCHAR *eventSourceIds,
+                     ACE_TCHAR *source_type_pairs);
+  // This method creates a local scheduler, rtec and cosec.
+  // The POA <poa> specified here is used when <activate> is called to
+  // activate the contained servants.
+  // The POA <thispoa> is used to activate this.
+
+  int activate (void);
+  // Activates the CosEC with <thispoa_> and friends with the <poa_>
+
+  int activate (const char* servant_id);
+  // If the servant_id is not nil then it is used to supply the object id
+  // for <this> servant.
+
+  void deactivate (void);
+  // Deactivates the CosEC and friends with the POA.
+
+  // =  POA_CosEventChannelAdmin::EventChannel methods.
+  virtual CosEventChannelAdmin::ConsumerAdmin_ptr for_consumers (void);
+
+  virtual CosEventChannelAdmin::SupplierAdmin_ptr for_suppliers (void);
+
+  virtual void destroy (void);
+  // Destroys this Event Channel object.
+
+ protected:
+  // = RtEC creation, activation and deactivation methods.
+  virtual POA_RtecEventChannelAdmin::EventChannel_ptr
+  create_rtec (void);
+  // Create a local rtec.
+
+  virtual void activate_rtec (void);
+  // Activates the rtec.
+
+  virtual void deactivate_rtec (void);
+  // Deactivates the rtec.
+
+  // = CosEC creation, activation and deactivation methods.
+  TAO_CosEC_EventChannel_i*
+  create_cosec (void);
+  // Create a local cosec.
+
+  int activate_cosec (void);
+  // Activates the cosec.
+
+  void deactivate_cosec (void);
+  // Deactivates the cosec.
+
+  void init_SupplierQOS (RtecBase::handle_t supp_handle,
+                         ACE_SupplierQOS_Factory &supplier_qos,
+                         ACE_TCHAR *source_type_pairs);
+  // Initialize the SupplierQOS Factory.
+
+
+  void init_ConsumerQOS (RtecBase::handle_t cons_handle,
+                         ACE_ConsumerQOS_Factory &consumer_qos,
+                         ACE_TCHAR *eventTypeIds,
+                         ACE_TCHAR *eventSourceIds);
+  // Initialize the ConsumerQOS Factory.
+
+  // = Protected Data members.
+
+  PortableServer::POA_var thispoa_;
+  // The poa that we use to activate ourselves.
+
+  PortableServer::POA_var poa_;
+  // The poa that we use to activate others
+
+  POA_RtecEventChannelAdmin::EventChannel_ptr rtec_servant_;
+  // The Event Channel servant.
+
+  TAO_CosEC_EventChannel_i *cosec_servant_;
+  // The servant object of the COS Event Channel.
+
+  RtecEventChannelAdmin::EventChannel_var rtec_;
+  // Ref to the Rtec.
+
+  CosEventChannelAdmin::EventChannel_var cosec_;
+  // Ref to the cosec.
+
+  ACE_ConsumerQOS_Factory consumer_qos_;
+  // The Consumer QOS.
+
+  ACE_SupplierQOS_Factory supplier_qos_;
+  // The Supplier QOS.
+
+  ACE_TCHAR *eventTypeIds_;
+  // The list of EventTypeIDs (for ConsumerQOS) seperated by spaces.
+  // e.g. "1 2 3 4"
+
+  ACE_TCHAR *eventSourceIds_;
+  // The list of EventSourceIDs (for ConsumerQOS) seperated by spaces.
+  // e.g. "1 2 3 4"
+
+  ACE_TCHAR *source_type_pairs_;
+  // The pairs of Source and EventType Ids (for the SupplierQOS).
+  // e.g "1 4 2 5 3 6" where (1,4) (2,5) and (3,6) from source id,
+  // event id pairs.
+};
+
+#include /**/ "ace/post.h"
+#endif /* TAO_COSEVENT_UTILITIES_H */