TAO_RTEvent: EC_Null_Scheduling.cpp Source File

00001 // EC_Null_Scheduling.cpp,v 1.7 2006/03/14 06:14:25 jtc Exp
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.i"
00009 #endif /* __ACE_INLINE__ */
00010 
00011 ACE_RCSID(Event, EC_Null_Scheduling, "EC_Null_Scheduling.cpp,v 1.7 2006/03/14 06:14:25 jtc Exp")
00012 
00013 void
00014 TAO_EC_Null_Scheduling::add_proxy_supplier_dependencies (
00015       TAO_EC_ProxyPushSupplier *,
00016       TAO_EC_ProxyPushConsumer *
00017       ACE_ENV_ARG_DECL_NOT_USED)
00018 {
00019 }
00020 
00021 void
00022 TAO_EC_Null_Scheduling::schedule_event (const RtecEventComm::EventSet &event,
00023                                         TAO_EC_ProxyPushConsumer *,
00024                                         TAO_EC_Supplier_Filter *filter
00025                                         ACE_ENV_ARG_DECL)
00026 {
00027   for (CORBA::ULong j = 0; j < event.length (); ++j)
00028     {
00029       const RtecEventComm::Event& e = event[j];
00030       RtecEventComm::Event* buffer =
00031         const_cast<RtecEventComm::Event*> (&e);
00032       RtecEventComm::EventSet single_event (1, 1, buffer, 0);
00033 
00034       TAO_EC_QOS_Info event_info;
00035       filter->push_scheduled_event (single_event, event_info
00036                                     ACE_ENV_ARG_PARAMETER);
00037       ACE_CHECK;
00038     }
00039 }