diff options
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h')
| -rw-r--r-- | TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h b/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h index c106eab7c5e..be8f47fca4e 100644 --- a/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h +++ b/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/dynamic_topology_test/Kokyu_EC.h @@ -31,10 +31,12 @@ public: int init(const char* schedule_discipline, PortableServer::POA_ptr poa); + //Problems with the EC don't let you register multiple types for the same RT_Info, + //so you have to call register_consumer() for each type. virtual RtEventChannelAdmin::handle_t register_consumer ( const char * entry_point, const RtEventChannelAdmin::SchedInfo & info, - EventType_Vector& cons_types, //RtecEventComm::EventType type, + RtecEventComm::EventType cons_type, RtecEventComm::PushConsumer_ptr consumer, RtecEventChannelAdmin::ProxyPushSupplier_out proxy_supplier ACE_ENV_ARG_DECL @@ -49,7 +51,7 @@ public: virtual RtEventChannelAdmin::handle_t register_supplier ( const char * entry_point, RtecEventComm::EventSourceID source, - EventType_Vector& supp_types, //RtecEventComm::EventType type, + const EventType_Vector& supp_types, RtecEventComm::PushSupplier_ptr supplier, RtecEventChannelAdmin::ProxyPushConsumer_out proxy_consumer ACE_ENV_ARG_DECL @@ -93,7 +95,7 @@ public: void add_supplier_with_timeout( Supplier * supplier_impl, const char * supp_entry_point, - EventType_Vector& supp_types, //RtecEventComm::EventType supp_type, + const EventType_Vector& supp_types, Timeout_Consumer * timeout_consumer_impl, const char * timeout_entry_point, ACE_Time_Value period, @@ -129,7 +131,7 @@ public: void add_supplier( Supplier * supplier_impl, const char * entry_point, - EventType_Vector& supp_types //RtecEventComm::EventType type + const EventType_Vector& supp_types ACE_ENV_ARG_DECL ) ACE_THROW_SPEC (( @@ -144,12 +146,12 @@ public: Consumer * consumer_impl, const char * cons_entry_point, ACE_Time_Value cons_period, - EventType_Vector& cons_types, //RtecEventComm::EventType cons_type, + const EventType_Vector& cons_types, RtecScheduler::Criticality_t cons_crit, RtecScheduler::Importance_t cons_imp, Supplier * supplier_impl, const char * supp_entry_point, - EventType_Vector& supp_types //RtecEventComm::EventType supp_type + const EventType_Vector& supp_types ACE_ENV_ARG_DECL ) ACE_THROW_SPEC (( @@ -164,7 +166,7 @@ public: Consumer * consumer_impl, const char * entry_point, ACE_Time_Value period, - EventType_Vector& cons_types, //RtecEventComm::EventType cons_type, + const EventType_Vector& cons_types, RtecScheduler::Criticality_t crit, RtecScheduler::Importance_t imp ACE_ENV_ARG_DECL @@ -176,7 +178,7 @@ public: , RtecScheduler::SYNCHRONIZATION_FAILURE )); - void add_dummy_supplier(EventType_Vector& supp_types + void add_dummy_supplier(const EventType_Vector& supp_types ACE_ENV_ARG_DECL ) ACE_THROW_SPEC (( |