diff options
Diffstat (limited to 'CIAO/ciaosvcs/Events/CIAO_RTEC/CIAO_RTEvent.cpp')
| -rw-r--r-- | CIAO/ciaosvcs/Events/CIAO_RTEC/CIAO_RTEvent.cpp | 624 |
1 files changed, 0 insertions, 624 deletions
diff --git a/CIAO/ciaosvcs/Events/CIAO_RTEC/CIAO_RTEvent.cpp b/CIAO/ciaosvcs/Events/CIAO_RTEC/CIAO_RTEvent.cpp deleted file mode 100644 index e85c8f0ee4f..00000000000 --- a/CIAO/ciaosvcs/Events/CIAO_RTEC/CIAO_RTEvent.cpp +++ /dev/null @@ -1,624 +0,0 @@ -// -*- C++ -*- - -//============================================================================= -/** - * @file CIAO_RTEvent.cpp - * - * $Id$ - * - * @author Gan Deng <dengg@dre.vanderbilt.edu> - * @author George Edwards <g.edwards@vanderbilt.edu> - */ -//============================================================================= - -#include "CIAO_RTEvent.h" -#include "ciao/CIAO_common.h" - -namespace CIAO -{ - - RTEventService::RTEventService (CORBA::ORB_ptr orb, - PortableServer::POA_ptr poa) : - orb_ (CORBA::ORB::_duplicate (orb)), - root_poa_ (PortableServer::POA::_duplicate (poa)), - type_id_ (ACE_ES_EVENT_ANY), - source_id_ (ACE_ES_EVENT_SOURCE_ANY) - { - this->create_rt_event_channel (); - } - - - RTEventService::~RTEventService (void) - { - } - - - Supplier_Config_ptr - RTEventService::create_supplier_config (void) - ACE_THROW_SPEC ((CORBA::SystemException)) - { - RTEvent_Supplier_Config_impl * supplier_config = 0; - ACE_NEW_RETURN (supplier_config, - RTEvent_Supplier_Config_impl (this->root_poa_.in ()), - Supplier_Config::_nil ()); - RTEvent_Supplier_Config_var return_rtec = - supplier_config->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - return return_rtec._retn (); - } - - - Consumer_Config_ptr - RTEventService::create_consumer_config (void) - ACE_THROW_SPEC ((CORBA::SystemException)) - { - RTEvent_Consumer_Config_impl * consumer_config = 0; - ACE_NEW_RETURN (consumer_config, - RTEvent_Consumer_Config_impl (this->root_poa_.in ()), - Consumer_Config::_nil ()); - RTEvent_Consumer_Config_var return_rtec = - consumer_config->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - return return_rtec._retn (); - } - - - void - RTEventService::connect_event_supplier ( - Supplier_Config_ptr supplier_config - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 9) - { - ACE_DEBUG ((LM_DEBUG, "CIAO::RTEventService::connect_event_supplier\n")); - } - - RTEvent_Supplier_Config_ptr rt_config = - RTEvent_Supplier_Config::_narrow (supplier_config - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - - if (CORBA::is_nil (rt_config)) - { - ACE_THROW (CORBA::BAD_PARAM ()); - } - - ACE_Hash<ACE_CString> hasher; - this->source_id_ = hasher (supplier_config->supplier_id (ACE_ENV_SINGLE_ARG_PARAMETER)); - ACE_CHECK; - this->type_id_ = this->source_id_; - - if (CIAO::debug_level () > 11) - { - ACE_DEBUG ((LM_DEBUG, "connect source id: %i\n", this->source_id_)); - } - - RtecEventChannelAdmin::SupplierAdmin_var supplier_admin = - this->rt_event_channel_->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - this->proxy_consumer_ = - supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - // Create and register supplier servant - RTEventServiceSupplier_impl * supplier_servant = 0; - ACE_NEW (supplier_servant, - RTEventServiceSupplier_impl (root_poa_.in ())); - RtecEventComm::PushSupplier_var push_supplier = - supplier_servant->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - RtecEventChannelAdmin::SupplierQOS_var qos = - rt_config->rt_event_qos (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - this->proxy_consumer_->connect_push_supplier (push_supplier.in (), - qos.in () - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - void - RTEventService::connect_event_consumer ( - Consumer_Config_ptr consumer_config - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 9) - { - ACE_DEBUG ((LM_DEBUG, "CIAO::RTEventService::connect_event_consumer\n")); - } - - RTEvent_Consumer_Config_ptr rt_config = - RTEvent_Consumer_Config::_narrow (consumer_config - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - - if (CORBA::is_nil (rt_config)) - { - ACE_THROW (CORBA::BAD_PARAM ()); - } - - Components::EventConsumerBase_var consumer = - consumer_config->consumer (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - if (CORBA::is_nil (consumer.in ())) - ACE_DEBUG ((LM_DEBUG, "nil event consumer\n")); - - RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin = - this->rt_event_channel_->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - RtecEventChannelAdmin::ProxyPushSupplier_var proxy_supplier = - consumer_admin->obtain_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - // Create and register consumer servant - RTEventServiceConsumer_impl * consumer_servant = 0; - ACE_NEW (consumer_servant, - RTEventServiceConsumer_impl ( - root_poa_.in (), - consumer.in ())); - RtecEventComm::PushConsumer_var push_consumer = - consumer_servant->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - //@@@ - rt_config->start_disjunction_group (1); - - rt_config->insert_type (ACE_ES_EVENT_ANY); - - RtecEventChannelAdmin::ConsumerQOS_var qos = - rt_config->rt_event_qos (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - proxy_supplier->connect_push_consumer (push_consumer.in (), - qos.in () - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - - ACE_CString consumer_id = - consumer_config->consumer_id (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - this->proxy_supplier_map_.bind (consumer_id.c_str (), proxy_supplier._retn ()); - } - - void - RTEventService::disconnect_event_supplier ( - const char * connection_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException, - Components::InvalidConnection)) - { - ACE_UNUSED_ARG (connection_id); - - this->proxy_consumer_->disconnect_push_consumer ( - ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - - // What to do with the consumers?! - } - - void - RTEventService::disconnect_event_consumer ( - const char * connection_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException, - Components::InvalidConnection)) - { - RtecEventChannelAdmin::ProxyPushSupplier_var proxy_supplier; - - this->proxy_supplier_map_.unbind (connection_id, proxy_supplier); - - proxy_supplier->disconnect_push_supplier ( - ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - } - - void - RTEventService::push_event ( - Components::EventBase * ev - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "------CIAO::RTEventService::push_event------\n")); - } - - RtecEventComm::EventSet events (1); - events.length (1); - events[0].header.source = ACE_ES_EVENT_SOURCE_ANY; //this->source_id_; - events[0].header.type = ACE_ES_EVENT_ANY; //this->type_id_; - events[0].data.any_value <<= ev; - - this->proxy_consumer_->push (events ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - } - - void - RTEventService::create_rt_event_channel ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "CIAO::EventService_Factory_impl::create_rt_event_channel\n")); - } - - // @@ (GD) Anything else to do to get the svc.conf file options? - TAO_EC_Default_Factory::init_svcs (); - - TAO_EC_Event_Channel_Attributes attributes (this->root_poa_.in (), - this->root_poa_.in ()); - TAO_EC_Event_Channel * ec_servant = 0; - ACE_NEW (ec_servant, TAO_EC_Event_Channel (attributes)); - ec_servant->activate (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - this->rt_event_channel_ = ec_servant->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - } - - - ////////////////////////////////////////////////////////////////////// - /// Supplier Servant Implementation - ////////////////////////////////////////////////////////////////////// - - RTEventServiceSupplier_impl::RTEventServiceSupplier_impl ( - PortableServer::POA_ptr poa) : - poa_ (PortableServer::POA::_duplicate (poa)) - { - } - - void - RTEventServiceSupplier_impl::disconnect_push_supplier (void) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - PortableServer::ObjectId_var oid = this->poa_->servant_to_id (this); - this->poa_->deactivate_object (oid); - this->_remove_ref (); - } - - ////////////////////////////////////////////////////////////////////// - /// Consumer Servant Implementation - ////////////////////////////////////////////////////////////////////// - - RTEventServiceConsumer_impl::RTEventServiceConsumer_impl ( - PortableServer::POA_ptr poa, - Components::EventConsumerBase_ptr consumer) : - poa_ (PortableServer::POA::_duplicate (poa)), - event_consumer_ (Components::EventConsumerBase::_duplicate (consumer)) - { - } - - void - RTEventServiceConsumer_impl::push (const RtecEventComm::EventSet& events) - ACE_THROW_SPEC ((CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "CIAO::RTEventServiceConsumer_impl::push\n")); - } - - for (size_t i = 0; i < events.length (); ++i) - { - Components::EventBase * ev = 0; - if (events[i].data.any_value >>= ev) - { - ev->_add_ref (); - this->event_consumer_->push_event (ev - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - } - } - - } - - void - RTEventServiceConsumer_impl::disconnect_push_consumer (void) - ACE_THROW_SPEC ((CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "CIAO::RTEventServiceConsumer_impl::disconnect_push_consumer\n")); - } - - PortableServer::ObjectId_var oid = this->poa_->servant_to_id (this); - this->poa_->deactivate_object (oid); - this->_remove_ref (); - } - - - ////////////////////////////////////////////////////////////////////// - /// Supplier Config Implementation - ////////////////////////////////////////////////////////////////////// - - RTEvent_Supplier_Config_impl::RTEvent_Supplier_Config_impl (PortableServer::POA_ptr poa) : - service_type_ (RTEC), - poa_ (PortableServer::POA::_duplicate (poa)) - { - } - - RTEvent_Supplier_Config_impl::~RTEvent_Supplier_Config_impl (void) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG - ((LM_DEBUG, "RTEvent_Supplier_Config_impl::~RTEvent_Supplier_Config_impl\n")); - } - } - - void - RTEvent_Supplier_Config_impl::supplier_id ( - const char * supplier_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 11) - { - ACE_DEBUG ((LM_DEBUG, "supplier's id: %s\n", supplier_id)); - - } - - this->supplier_id_ = supplier_id; - - ACE_Hash<ACE_CString> hasher; - RtecEventComm::EventSourceID source_id = - hasher (this->supplier_id_.c_str ()); - - this->qos_.insert (source_id, - source_id, - 0, - 1); - } - - CONNECTION_ID - RTEvent_Supplier_Config_impl::supplier_id ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - return CORBA::string_dup (this->supplier_id_.c_str ()); - } - - EventServiceType - RTEvent_Supplier_Config_impl::service_type ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - return this->service_type_; - } - - RtecEventChannelAdmin::SupplierQOS * - RTEvent_Supplier_Config_impl::rt_event_qos ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - RtecEventChannelAdmin::SupplierQOS * supplier_qos = 0; - ACE_NEW_RETURN (supplier_qos, - RtecEventChannelAdmin::SupplierQOS (this->qos_.get_SupplierQOS ()), - 0); - return supplier_qos; - } - - void - RTEvent_Supplier_Config_impl::destroy ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - PortableServer::ObjectId_var oid = this->poa_->servant_to_id (this); - this->poa_->deactivate_object (oid); - this->_remove_ref (); - } - - ////////////////////////////////////////////////////////////////////// - /// Consumer Config Implementation - ////////////////////////////////////////////////////////////////////// - - RTEvent_Consumer_Config_impl::RTEvent_Consumer_Config_impl (PortableServer::POA_ptr poa) : - service_type_ (RTEC), - poa_ (PortableServer::POA::_duplicate (poa)) - { - } - - RTEvent_Consumer_Config_impl::~RTEvent_Consumer_Config_impl (void) - { - ACE_DEBUG - ((LM_DEBUG, "RTEvent_Consumer_Config_impl::~RTEvent_Consumer_Config_impl\n")); - } - - void - RTEvent_Consumer_Config_impl::start_conjunction_group ( - CORBA::Long size ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - this->qos_.start_conjunction_group (size); - } - - void - RTEvent_Consumer_Config_impl::start_disjunction_group ( - CORBA::Long size - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - this->qos_.start_disjunction_group (size); - } - - void - RTEvent_Consumer_Config_impl::insert_source ( - const char * source_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - - ACE_Hash<ACE_CString> hasher; - RtecEventComm::EventSourceID int_source_id = - hasher (source_id); - - this->qos_.insert_source (int_source_id, - 0); - } - - void - RTEvent_Consumer_Config_impl::insert_type ( - ::CORBA::Long event_type - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC ((::CORBA::SystemException)) - { - this->qos_.insert_type (event_type, - 0); - } - - void - RTEvent_Consumer_Config_impl::consumer_id ( - const char * consumer_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, - "RTEvent_Consumer_Config_impl::set_consumer_id:%s\n", - consumer_id)); - } - - this->consumer_id_ = consumer_id; - } - - void - RTEvent_Consumer_Config_impl::supplier_id ( - const char * supplier_id - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, - "RTEvent_Consumer_Config_impl::set_supplier_id:%s\n", - supplier_id)); - } - - this->supplier_id_ = supplier_id; - - ACE_Hash<ACE_CString> hasher; - RtecEventComm::EventSourceID source_id = - hasher (this->supplier_id_.c_str ()); - - this->qos_.start_disjunction_group (1); - this->qos_.insert (source_id, - source_id, - 0); - } - - void - RTEvent_Consumer_Config_impl::consumer ( - Components::EventConsumerBase_ptr consumer - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - this->consumer_ = Components::EventConsumerBase::_duplicate (consumer); - } - - CONNECTION_ID - RTEvent_Consumer_Config_impl::consumer_id ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - return CORBA::string_dup (this->consumer_id_.c_str ()); - } - - CONNECTION_ID - RTEvent_Consumer_Config_impl::supplier_id ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "RTEvent_Consumer_Config_impl::get_supplier_id\n")); - } - - return CORBA::string_dup (this->supplier_id_.c_str ()); - } - - EventServiceType - RTEvent_Consumer_Config_impl::service_type ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - return this->service_type_; - } - - Components::EventConsumerBase_ptr - RTEvent_Consumer_Config_impl::consumer ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG ((LM_DEBUG, "RTEvent_Consumer_Config_impl::get_consumer\n")); - } - - return Components::EventConsumerBase::_duplicate (this->consumer_.in ()); - } - - RtecEventChannelAdmin::ConsumerQOS * - RTEvent_Consumer_Config_impl::rt_event_qos ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - RtecEventChannelAdmin::ConsumerQOS * consumer_qos = 0; - ACE_NEW_RETURN (consumer_qos, - RtecEventChannelAdmin::ConsumerQOS (this->qos_.get_ConsumerQOS ()), - 0); - - - // @@@ Hard coded - this->qos_.start_disjunction_group (1); - this->qos_.insert_type (ACE_ES_EVENT_ANY, 0); - - return consumer_qos; - } - - void - RTEvent_Consumer_Config_impl::destroy ( - ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException)) - { - if (CIAO::debug_level () > 10) - { - ACE_DEBUG - ((LM_DEBUG, "RTEvent_Consumer_Config_impl::destroy\n")); - } - - PortableServer::ObjectId_var oid = this->poa_->servant_to_id (this); - this->poa_->deactivate_object (oid); - this->_remove_ref (); - } -} |