diff options
Diffstat (limited to 'ACE/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_Dispatching.cpp')
-rw-r--r-- | ACE/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_Dispatching.cpp | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_Dispatching.cpp b/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_Dispatching.cpp new file mode 100644 index 00000000000..bffad152a77 --- /dev/null +++ b/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_Dispatching.cpp @@ -0,0 +1,43 @@ +// $Id$ + +#include "orbsvcs/Event/EC_Reactive_Dispatching.h" +#include "orbsvcs/Event/EC_ProxySupplier.h" + +ACE_RCSID(Event, EC_Reactive_Dispatching, "$Id$") + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO_EC_Reactive_Dispatching::TAO_EC_Reactive_Dispatching (void) + : TAO_EC_Dispatching () +{ +} + +void +TAO_EC_Reactive_Dispatching::activate (void) +{ +} + +void +TAO_EC_Reactive_Dispatching::shutdown (void) +{ +} + +void +TAO_EC_Reactive_Dispatching::push (TAO_EC_ProxyPushSupplier* proxy, + RtecEventComm::PushConsumer_ptr consumer, + const RtecEventComm::EventSet& event, + TAO_EC_QOS_Info&) +{ + proxy->reactive_push_to_consumer (consumer, event); +} + +void +TAO_EC_Reactive_Dispatching::push_nocopy (TAO_EC_ProxyPushSupplier* proxy, + RtecEventComm::PushConsumer_ptr consumer, + RtecEventComm::EventSet& event, + TAO_EC_QOS_Info&) +{ + proxy->reactive_push_to_consumer (consumer, event); +} + +TAO_END_VERSIONED_NAMESPACE_DECL |