TAO_RTEvent: EC_Null_Scheduling.cpp Source File

00001 // $Id: EC_Null_Scheduling.cpp 76589 2007-01-25 18:04:11Z elliott_c $
00002 
00003 #include "orbsvcs/Event/EC_Null_Scheduling.h"
00004 #include "orbsvcs/Event/EC_QOS_Info.h"
00005 #include "orbsvcs/Event/EC_Supplier_Filter.h"
00006 
00007 #if ! defined (__ACE_INLINE__)
00008 #include "orbsvcs/Event/EC_Null_Scheduling.inl"
00009 #endif /* __ACE_INLINE__ */
00010 
00011 ACE_RCSID(Event, EC_Null_Scheduling, "$Id: EC_Null_Scheduling.cpp 76589 2007-01-25 18:04:11Z elliott_c $")
00012 
00013 void
00014 TAO_EC_Null_Scheduling::add_proxy_supplier_dependencies (
00015       TAO_EC_ProxyPushSupplier *,
00016       TAO_EC_ProxyPushConsumer *)
00017 {
00018 }
00019 
00020 void
00021 TAO_EC_Null_Scheduling::schedule_event (const RtecEventComm::EventSet &event,
00022                                         TAO_EC_ProxyPushConsumer *,
00023                                         TAO_EC_Supplier_Filter *filter)
00024 {
00025   for (CORBA::ULong j = 0; j < event.length (); ++j)
00026     {
00027       const RtecEventComm::Event& e = event[j];
00028       RtecEventComm::Event* buffer =
00029         const_cast<RtecEventComm::Event*> (&e);
00030       RtecEventComm::EventSet single_event (1, 1, buffer, 0);
00031 
00032       TAO_EC_QOS_Info event_info;
00033       filter->push_scheduled_event (single_event, event_info);
00034     }
00035 }