summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp117
1 files changed, 0 insertions, 117 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp
deleted file mode 100644
index 98a28ba0cd9..00000000000
--- a/TAO/orbsvcs/orbsvcs/Event/EC_Trivial_Supplier_Filter.cpp
+++ /dev/null
@@ -1,117 +0,0 @@
-// $Id$
-
-#include "EC_Trivial_Supplier_Filter.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_Trivial_Supplier_Filter.i"
-#endif /* __ACE_INLINE__ */
-
-ACE_RCSID(Event, EC_Trivial_Supplier_Filter, "$Id$")
-
-// ****************************************************************
-
-TAO_EC_Trivial_Supplier_Filter::
- TAO_EC_Trivial_Supplier_Filter (TAO_EC_Event_Channel* ec)
- : event_channel_ (ec)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::bind (TAO_EC_ProxyPushConsumer*)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::unbind (TAO_EC_ProxyPushConsumer*)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::connected (TAO_EC_ProxyPushSupplier*,
- CORBA::Environment &)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::disconnected (TAO_EC_ProxyPushSupplier*,
- CORBA::Environment &)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::shutdown (CORBA::Environment &)
-{
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter::push (const RtecEventComm::EventSet& event,
- CORBA::Environment &ACE_TRY_ENV)
-{
- TAO_EC_ConsumerAdmin* consumer_admin =
- this->event_channel_->consumer_admin ();
-
- 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_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 (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;
- }
- }
-}
-
-CORBA::ULong
-TAO_EC_Trivial_Supplier_Filter::_incr_refcnt (void)
-{
- return 1;
-}
-
-CORBA::ULong
-TAO_EC_Trivial_Supplier_Filter::_decr_refcnt (void)
-{
- return 1;
-}
-
-// ****************************************************************
-
-TAO_EC_Trivial_Supplier_Filter_Builder::
- TAO_EC_Trivial_Supplier_Filter_Builder (TAO_EC_Event_Channel *ec)
- : filter_ (ec)
-{
-}
-
-TAO_EC_SupplierFiltering*
-TAO_EC_Trivial_Supplier_Filter_Builder::create (
- RtecEventChannelAdmin::SupplierQOS&)
-{
- return &this->filter_;
-}
-
-void
-TAO_EC_Trivial_Supplier_Filter_Builder::destroy (
- TAO_EC_SupplierFiltering*)
-{
-}