1 files changed, 81 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.inl b/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.inl
new file mode 100644
index 00000000000..231db3f9417
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.inl
@@ -0,0 +1,81 @@
+// -*- C++ -*-
+//
+// $Id$
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+ACE_INLINE
+TAO_EC_Null_ObserverStrategy::TAO_EC_Null_ObserverStrategy (void)
+{
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Basic_ObserverStrategy::Observer_Entry::Observer_Entry (void)
+  :  handle (0)
+{
+}
+
+ACE_INLINE
+TAO_EC_Basic_ObserverStrategy::Observer_Entry::
+      Observer_Entry (RtecEventChannelAdmin::Observer_Handle h,
+                      RtecEventChannelAdmin::Observer_ptr o)
+  :  handle (h),
+     observer (o)
+{
+}
+
+// ****************************************************************
+
+ACE_INLINE int
+TAO_EC_Basic_ObserverStrategy::Header_Compare::
+    operator () (const RtecEventComm::EventHeader& lhs,
+                 const RtecEventComm::EventHeader& rhs) const
+{
+  if (lhs.source == rhs.source)
+    return lhs.type < rhs.type;
+  return lhs.source < rhs.source;
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Basic_ObserverStrategy::
+      TAO_EC_Basic_ObserverStrategy (TAO_EC_Event_Channel_Base* ec,
+                                     ACE_Lock* lock)
+  :  event_channel_ (ec),
+     lock_ (lock),
+     handle_generator_ (1)
+{
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Reactive_ObserverStrategy::
+      TAO_EC_Reactive_ObserverStrategy (TAO_EC_Event_Channel_Base* ec,
+                                     ACE_Lock* lock)
+  :  TAO_EC_Basic_ObserverStrategy (ec, lock)
+{
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Accumulate_Supplier_Headers::
+    TAO_EC_Accumulate_Supplier_Headers (TAO_EC_Basic_ObserverStrategy::Headers &h)
+  : headers_ (h)
+{
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Accumulate_Consumer_Headers::
+    TAO_EC_Accumulate_Consumer_Headers (TAO_EC_Basic_ObserverStrategy::Headers &h)
+  : headers_ (h)
+{
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL