1 files changed, 69 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_SupplierFiltering.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_SupplierFiltering.cpp
index 6bb56e89909..15a1f6a03cf 100644
--- a/TAO/orbsvcs/orbsvcs/Event/EC_SupplierFiltering.cpp
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_SupplierFiltering.cpp
@@ -1,6 +1,10 @@
 // $Id$
 
 #include "EC_SupplierFiltering.h"
+#include "EC_Event_Channel.h"
+#include "EC_ConsumerAdmin.h"
+#include "EC_ProxySupplier.h"
+#include "EC_QOS_Info.h"
 
 #if ! defined (__ACE_INLINE__)
 #include "EC_SupplierFiltering.i"
@@ -11,3 +15,68 @@ ACE_RCSID(Event, EC_SupplierFiltering, "$Id$")
 TAO_EC_SupplierFiltering::~TAO_EC_SupplierFiltering (void)
 {
 }
+
+// ****************************************************************
+
+TAO_EC_Null_SupplierFiltering::
+    TAO_EC_Null_SupplierFiltering (TAO_EC_Event_Channel* ec)
+  :  event_channel_ (ec)
+{
+}
+
+void
+TAO_EC_Null_SupplierFiltering::bind (TAO_EC_ProxyPushConsumer*)
+{
+}
+
+void
+TAO_EC_Null_SupplierFiltering::unbind (TAO_EC_ProxyPushConsumer*)
+{
+}
+
+void
+TAO_EC_Null_SupplierFiltering::connected (TAO_EC_ProxyPushSupplier*,
+                                          CORBA::Environment &)
+{
+}
+
+void
+TAO_EC_Null_SupplierFiltering::disconnected (TAO_EC_ProxyPushSupplier*,
+                                             CORBA::Environment &)
+{
+}
+
+void
+TAO_EC_Null_SupplierFiltering::push (const RtecEventComm::EventSet& event,
+                                     CORBA::Environment &ACE_TRY_ENV)
+{
+  TAO_EC_ConsumerAdmin* consumer_admin =
+    this->event_channel_->consumer_admin ();
+
+  ACE_GUARD_THROW_EX (TAO_EC_ConsumerAdmin::Busy_Lock,
+      ace_mon, consumer_admin->busy_lock (),
+      RtecEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
+  ACE_CHECK;
+
+  TAO_EC_ConsumerAdmin::SupplierSetIterator end =
+    consumer_admin->end ();
+
+  for (CORBA::ULong j = 0; j < event.length (); ++j)
+    {
+      const RtecEventComm::Event& e = event[j];
+      RtecEventComm::Event* buffer =
+        ACE_const_cast(RtecEventComm::Event*, &e);
+      RtecEventComm::EventSet single_event (1, 1, buffer, 0);
+
+      for (TAO_EC_ConsumerAdmin::SupplierSetIterator i =
+             consumer_admin->begin ();
+           i != end;
+           ++i)
+        {
+          TAO_EC_QOS_Info qos_info;
+
+          (*i)->filter (single_event, qos_info, ACE_TRY_ENV);
+          ACE_CHECK;
+        }
+    }
+}