1 files changed, 152 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/Event_Utilities.inl b/ACE/TAO/orbsvcs/orbsvcs/Event_Utilities.inl
new file mode 100644
index 00000000000..20c09b0a0fe
--- /dev/null
+++ b/ACE/TAO/orbsvcs/orbsvcs/Event_Utilities.inl
@@ -0,0 +1,152 @@
+// -*- C++ -*-
+//
+// $Id$
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert (RtecEventComm::EventSourceID source,
+                                 RtecEventComm::EventType type,
+                                 RtecBase::handle_t rt_info)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.source = source;
+  dependency.event.header.type = type;
+  //dependency.event.header.creation_time = 0;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.rt_info = rt_info;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_bitmasked_value (CORBA::ULong source_mask,
+                                                 CORBA::ULong type_mask,
+                                                 CORBA::ULong source_value,
+                                                 CORBA::ULong type_value)
+
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.type = ACE_ES_MASKED_TYPE_DESIGNATOR;
+  dependency.event.header.source = 0;
+  //dependency.event.header.creation_time = 0;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.rt_info = 0;
+  this->insert (dependency);
+
+  dependency.event.header.source = source_mask;
+  dependency.event.header.type = type_mask;
+  this->insert (dependency);
+
+  dependency.event.header.source = source_value;
+  dependency.event.header.type = type_value;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_null_terminator (void)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.type = ACE_ES_NULL_DESIGNATOR;
+  dependency.event.header.source = 0;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_type (RtecEventComm::EventType type,
+                                      RtecBase::handle_t rt_info)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.source = ACE_ES_EVENT_SOURCE_ANY;
+  dependency.event.header.type = type;
+  //dependency.event.header.creation_time = 0;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.rt_info = rt_info;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_source (RtecEventComm::EventSourceID source,
+                                        RtecBase::handle_t rt_info)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.source = source;
+  dependency.event.header.type = ACE_ES_EVENT_ANY;
+  //dependency.event.header.creation_time = 0;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.rt_info = rt_info;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_time (RtecEventComm::EventType type,
+                                      RtecEventComm::Time interval,
+                                      RtecBase::handle_t rt_info)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.source = ACE_ES_EVENT_SOURCE_ANY;
+  dependency.event.header.type = type;
+  dependency.event.header.creation_time = interval;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.rt_info = rt_info;
+  return this->insert (dependency);
+}
+
+ACE_INLINE int
+ACE_ConsumerQOS_Factory::insert_act (RtecEventComm::EventData act)
+{
+  RtecEventChannelAdmin::Dependency dependency;
+  if (this->event_initializer_ != 0)
+    (*this->event_initializer_) (dependency.event);
+  dependency.event.header.source = 0;
+  dependency.event.header.type = ACE_ES_EVENT_ACT;
+  //dependency.event.header.creation_time = 0;
+  //dependency.event.header.ec_recv_time = 0;
+  //dependency.event.header.ec_send_time = 0;
+  dependency.event.data = act;
+  return this->insert (dependency);
+}
+
+ACE_INLINE const RtecEventChannelAdmin::ConsumerQOS&
+ACE_ConsumerQOS_Factory::get_ConsumerQOS (void)
+{
+  return qos_;
+}
+
+ACE_INLINE
+ACE_ConsumerQOS_Factory::operator const RtecEventChannelAdmin::ConsumerQOS& (void)
+{
+  return qos_;
+}
+
+// ************************************************************
+
+ACE_INLINE const RtecEventChannelAdmin::SupplierQOS&
+ACE_SupplierQOS_Factory::get_SupplierQOS (void)
+{
+  return qos_;
+}
+
+ACE_INLINE
+ACE_SupplierQOS_Factory::operator const RtecEventChannelAdmin::SupplierQOS& (void)
+{
+  return qos_;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL