diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp | 22 |
1 files changed, 17 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp index 10260d6fbc0..5c78bc13fbf 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/EC_Null_Scheduling.cpp @@ -2,6 +2,7 @@ #include "EC_Null_Scheduling.h" #include "EC_QOS_Info.h" +#include "EC_Supplier_Filter.h" #if ! defined (__ACE_INLINE__) #include "EC_Null_Scheduling.i" @@ -18,10 +19,21 @@ TAO_EC_Null_Scheduling::add_proxy_supplier_dependencies ( } void -TAO_EC_Null_Scheduling::init_event_qos ( - const RtecEventComm::EventHeader&, - TAO_EC_ProxyPushConsumer *, - TAO_EC_QOS_Info& - TAO_ENV_ARG_DECL_NOT_USED) +TAO_EC_Null_Scheduling::schedule_event (const RtecEventComm::EventSet &event, + TAO_EC_ProxyPushConsumer *, + TAO_EC_Supplier_Filter *filter + TAO_ENV_ARG_DECL) { + 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); + + TAO_EC_QOS_Info event_info; + filter->push_scheduled_event (single_event, event_info + TAO_ENV_ARG_PARAMETER); + ACE_CHECK; + } } |