1 files changed, 109 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Per_Supplier_Filter.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Per_Supplier_Filter.cpp
new file mode 100644
index 00000000000..69fa337e346
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_Per_Supplier_Filter.cpp
@@ -0,0 +1,109 @@
+// $Id$
+
+#include "EC_Per_Supplier_Filter.h"
+#include "EC_Event_Channel.h"
+#include "EC_ProxyPushSupplier_Set.h"
+#include "EC_ProxySupplier.h"
+#include "EC_ProxyConsumer.h"
+#include "EC_QOS_Info.h"
+#include "orbsvcs/Event_Service_Constants.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "EC_Per_Supplier_Filter.i"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(Event, EC_Per_Supplier_Filter, "$Id$")
+
+TAO_EC_Per_Supplier_Filter::
+    TAO_EC_Per_Supplier_Filter (TAO_EC_Event_Channel* ec)
+  :  event_channel_ (ec)
+{
+  this->supplier_set_ =
+    this->event_channel_->create_proxy_push_supplier_set ();
+}
+
+TAO_EC_Per_Supplier_Filter::~TAO_EC_Per_Supplier_Filter (void)
+{
+  this->event_channel_->destroy_proxy_push_supplier_set (this->supplier_set_);
+  this->supplier_set_ = 0;
+}
+
+void
+TAO_EC_Per_Supplier_Filter::bind (TAO_EC_ProxyPushConsumer* consumer)
+{
+  this->consumer_ = consumer;
+}
+
+void
+TAO_EC_Per_Supplier_Filter::unbind (TAO_EC_ProxyPushConsumer* consumer)
+{
+  if (this->consumer_ != 0 && this->consumer_ != consumer)
+    return;
+
+  this->consumer_ = 0;
+  delete this;
+}
+
+void
+TAO_EC_Per_Supplier_Filter::connected (TAO_EC_ProxyPushSupplier* supplier,
+                                       CORBA::Environment &ACE_TRY_ENV)
+{
+  if (this->consumer_ == 0)
+    return;
+
+  const RtecEventChannelAdmin::SupplierQOS& pub =
+    this->consumer_->publications ();
+
+  for (CORBA::ULong j = 0; j < pub.publications.length (); ++j)
+    {
+      const RtecEventComm::Event& event =
+        pub.publications[j].event;
+      RtecEventComm::EventType type = event.header.type;
+
+      if (0 <= type && type <= ACE_ES_EVENT_UNDEFINED)
+        continue;
+      if (supplier->can_match (event.header))
+        {
+          this->supplier_set_->connected (supplier, ACE_TRY_ENV);
+          return;
+        }
+    }
+}
+
+void
+TAO_EC_Per_Supplier_Filter::disconnected (TAO_EC_ProxyPushSupplier* supplier,
+                                          CORBA::Environment &ACE_TRY_ENV)
+{
+  this->supplier_set_->disconnected (supplier, ACE_TRY_ENV);
+}
+
+void
+TAO_EC_Per_Supplier_Filter::push (const RtecEventComm::EventSet& event,
+                                     CORBA::Environment &ACE_TRY_ENV)
+{
+  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);
+
+      ACE_GUARD_THROW (TAO_EC_ProxyPushSupplier_Set::Busy_Lock,
+          ace_mon, this->supplier_set_->busy_lock (),
+          RtecEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
+
+      TAO_EC_ProxyPushSupplier_Set::SupplierSetIterator end =
+        this->supplier_set_->end ();
+
+      for (TAO_EC_ProxyPushSupplier_Set::SupplierSetIterator i =
+             this->supplier_set_->begin ();
+           i != end;
+           ++i)
+        {
+          TAO_EC_QOS_Info qos_info;
+
+          (*i)->filter (single_event, qos_info, ACE_TRY_ENV);
+          ACE_CHECK;
+        }
+    }
+}