diff options
Diffstat (limited to 'ACE/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp')
-rw-r--r-- | ACE/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp b/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp new file mode 100644 index 00000000000..cfec105b9a4 --- /dev/null +++ b/ACE/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp @@ -0,0 +1,35 @@ +// $Id$ + +#include "orbsvcs/Event/EC_Null_Scheduling.h" +#include "orbsvcs/Event/EC_QOS_Info.h" +#include "orbsvcs/Event/EC_Supplier_Filter.h" + +#if ! defined (__ACE_INLINE__) +#include "orbsvcs/Event/EC_Null_Scheduling.inl" +#endif /* __ACE_INLINE__ */ + +ACE_RCSID(Event, EC_Null_Scheduling, "$Id$") + +void +TAO_EC_Null_Scheduling::add_proxy_supplier_dependencies ( + TAO_EC_ProxyPushSupplier *, + TAO_EC_ProxyPushConsumer *) +{ +} + +void +TAO_EC_Null_Scheduling::schedule_event (const RtecEventComm::EventSet &event, + TAO_EC_ProxyPushConsumer *, + TAO_EC_Supplier_Filter *filter) +{ + for (CORBA::ULong j = 0; j < event.length (); ++j) + { + const RtecEventComm::Event& e = event[j]; + RtecEventComm::Event* buffer = + const_cast<RtecEventComm::Event*> (&e); + RtecEventComm::EventSet single_event (1, 1, buffer, 0); + + TAO_EC_QOS_Info event_info; + filter->push_scheduled_event (single_event, event_info); + } +} |