diff options
Diffstat (limited to 'TAO/orbsvcs/Event_Service/Event_Service.cpp')
| -rw-r--r-- | TAO/orbsvcs/Event_Service/Event_Service.cpp | 387 |
1 files changed, 132 insertions, 255 deletions
diff --git a/TAO/orbsvcs/Event_Service/Event_Service.cpp b/TAO/orbsvcs/Event_Service/Event_Service.cpp index 93118609611..3e6614c5d7f 100644 --- a/TAO/orbsvcs/Event_Service/Event_Service.cpp +++ b/TAO/orbsvcs/Event_Service/Event_Service.cpp @@ -1,337 +1,214 @@ // $Id$ -#include "Event_Service.h" - #include "ace/Get_Opt.h" #include "ace/Auto_Ptr.h" +#include "tao/corba.h" #include "orbsvcs/CosNamingC.h" +#include "orbsvcs/Scheduler_Factory.h" #include "orbsvcs/Event_Utilities.h" #include "orbsvcs/Sched/Config_Scheduler.h" #include "orbsvcs/Event/Module_Factory.h" #include "orbsvcs/Event/Event_Channel.h" -#include "orbsvcs/Event/EC_Default_Factory.h" -#include "orbsvcs/Event/EC_Event_Channel.h" - ACE_RCSID(Event_Service, Event_Service, "$Id$") -int main (int argc, char *argv[]) -{ - TAO_EC_Default_Factory::init_svcs (); +const char* service_name = "EventService"; +// The name we use to register with the Naming Service. - Event_Service event_service; - return event_service.run (argc, argv); -} +int global_scheduler = 0; +// If 0 we instantiante a local Scheduling Service and register it +// with the Naming Service. +// Otherwise we just resolve the Scheduling Service using the Naming +// Service (i.e. we assume there is a global scheduling service running. -// **************************************************************** - -Event_Service::Event_Service (void) - : module_factory_ (0), - sched_impl_ (0), - ec_impl_ (0), - service_name_ (0), - ior_file_name_ (0), - pid_file_name_ (0), - event_service_type_ (ES_OLD_MT), - global_scheduler_ (0) -{ -} +int reactive = 0; +// If 1 we use the reactive EC. -Event_Service::~Event_Service (void) +int +parse_args (int argc, char *argv []) { - delete this->ec_impl_; - this->ec_impl_ = 0; - delete this->sched_impl_; - this->sched_impl_ = 0; - delete this->module_factory_; - this->module_factory_ = 0; + ACE_Get_Opt get_opt (argc, argv, "n:s:r"); + int opt; + + while ((opt = get_opt ()) != EOF) + { + switch (opt) + { + case 'n': + service_name = get_opt.optarg; + break; + + case 's': + // It could be just a flag (i.e. no "global" or "local" + // argument, but this is consistent with the EC_Multiple + // test and also allows for a runtime scheduling service. + + if (ACE_OS::strcasecmp (get_opt.optarg, "global") == 0) + { + global_scheduler = 1; + } + else if (ACE_OS::strcasecmp (get_opt.optarg, "local") == 0) + { + global_scheduler = 0; + } + else + { + ACE_DEBUG ((LM_DEBUG, + "Unknown scheduling type <%s> " + "defaulting to local\n", + get_opt.optarg)); + global_scheduler = 0; + } + break; + + case 'r': + reactive = 1; + break; + + case '?': + default: + ACE_DEBUG ((LM_DEBUG, + "Usage: %s " + "-n service_name " + "-s <global|local> " + "-r " + "\n", + argv[0])); + return -1; + } + } + + return 0; } -int -Event_Service::run (int argc, char* argv[]) + +int main (int argc, char *argv[]) { - ACE_TRY_NEW_ENV + TAO_TRY { // Initialize ORB. - this->orb_ = - CORBA::ORB_init (argc, argv, "", ACE_TRY_ENV); - ACE_TRY_CHECK; + CORBA::ORB_var orb = + CORBA::ORB_init (argc, argv, "internet", TAO_TRY_ENV); + TAO_CHECK_ENV; - if (this->parse_args (argc, argv) == -1) + if (parse_args (argc, argv) == -1) return 1; CORBA::Object_var poa_object = - this->orb_->resolve_initial_references("RootPOA"); + orb->resolve_initial_references("RootPOA"); if (CORBA::is_nil (poa_object.in ())) ACE_ERROR_RETURN ((LM_ERROR, " (%P|%t) Unable to initialize the POA.\n"), 1); PortableServer::POA_var root_poa = - PortableServer::POA::_narrow (poa_object.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; + PortableServer::POA::_narrow (poa_object.in (), TAO_TRY_ENV); + TAO_CHECK_ENV; PortableServer::POAManager_var poa_manager = - root_poa->the_POAManager (ACE_TRY_ENV); - ACE_TRY_CHECK; + root_poa->the_POAManager (TAO_TRY_ENV); + TAO_CHECK_ENV; CORBA::Object_var naming_obj = - this->orb_->resolve_initial_references ("NameService"); + orb->resolve_initial_references ("NameService"); if (CORBA::is_nil (naming_obj.in ())) ACE_ERROR_RETURN ((LM_ERROR, " (%P|%t) Unable to initialize the Naming Service.\n"), 1); CosNaming::NamingContext_var naming_context = - CosNaming::NamingContext::_narrow (naming_obj.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; + CosNaming::NamingContext::_narrow (naming_obj.in (), TAO_TRY_ENV); + TAO_CHECK_ENV; + auto_ptr<POA_RtecScheduler::Scheduler> scheduler_impl; RtecScheduler::Scheduler_var scheduler; + // This is the name we (potentially) register the Scheduling // Service in the Naming Service. CosNaming::Name schedule_name (1); schedule_name.length (1); schedule_name[0].id = CORBA::string_dup ("ScheduleService"); - - if (1) // this->event_service_type_ == ES_OLD_REACTIVE - // || this->event_service_type_ == ES_OLD_MT) + if (global_scheduler == 0) { - // We must find the scheduler object reference... - - if (this->global_scheduler_ == 0) - { - ACE_NEW_RETURN (this->sched_impl_, - ACE_Config_Scheduler, - 1); - - scheduler = this->sched_impl_->_this (ACE_TRY_ENV); - ACE_TRY_CHECK; - - // Register the servant with the Naming Context.... - naming_context->rebind (schedule_name, scheduler.in (), - ACE_TRY_ENV); - ACE_TRY_CHECK; - } - else - { - CORBA::Object_var tmp = - naming_context->resolve (schedule_name, ACE_TRY_ENV); - ACE_TRY_CHECK; - - scheduler = RtecScheduler::Scheduler::_narrow (tmp.in (), - ACE_TRY_ENV); - ACE_TRY_CHECK; - } + scheduler_impl = + auto_ptr<POA_RtecScheduler::Scheduler>(new ACE_Config_Scheduler); + if (scheduler_impl.get () == 0) + return 1; + scheduler = scheduler_impl->_this (TAO_TRY_ENV); + TAO_CHECK_ENV; + + CORBA::String_var str = + orb->object_to_string (scheduler.in (), TAO_TRY_ENV); + TAO_CHECK_ENV; + ACE_DEBUG ((LM_DEBUG, "The (local) scheduler IOR is <%s>\n", + str.in ())); + + // Register the servant with the Naming Context.... + naming_context->bind (schedule_name, scheduler.in (), TAO_TRY_ENV); + TAO_CHECK_ENV; } - switch (this->event_service_type_) - { - case ES_NEW: - { - TAO_EC_Event_Channel_Attributes attr (root_poa.in (), - root_poa.in ()); - TAO_EC_Event_Channel* ec; - ACE_NEW_RETURN (ec, - TAO_EC_Event_Channel (attr), - 1); - this->ec_impl_ = ec; - ec->activate (ACE_TRY_ENV); - ACE_TRY_CHECK; - } - break; + ACE_Scheduler_Factory::use_config (naming_context.in ()); - case ES_OLD_REACTIVE: - { - ACE_NEW_RETURN (this->module_factory_, - TAO_Reactive_Module_Factory, - 1); - ACE_NEW_RETURN (this->ec_impl_, - ACE_EventChannel (scheduler.in (), - 1, - ACE_DEFAULT_EVENT_CHANNEL_TYPE, - this->module_factory_), - 1); - } - break; - case ES_OLD_MT: - { - ACE_NEW_RETURN (this->module_factory_, - TAO_Default_Module_Factory, - 1); - - ACE_NEW_RETURN (this->ec_impl_, - ACE_EventChannel (scheduler.in (), - 1, - ACE_DEFAULT_EVENT_CHANNEL_TYPE, - this->module_factory_), - 1); - } + // We pick the right module factory according to the command + // line options + TAO_Default_Module_Factory default_module_factory; + TAO_Reactive_Module_Factory reactive_module_factory; - break; - } + TAO_Module_Factory* module_factory = &default_module_factory; + if (reactive) + module_factory = &reactive_module_factory; + + // Register Event_Service with Naming Service. + ACE_EventChannel ec_impl (1, + ACE_DEFAULT_EVENT_CHANNEL_TYPE, + module_factory); - // Notice that we activate *this* object with the POA, but we - // forward all the requests to the underlying EC - // implementation. RtecEventChannelAdmin::EventChannel_var ec = - this->_this (ACE_TRY_ENV); - ACE_TRY_CHECK; + ec_impl._this (TAO_TRY_ENV); + TAO_CHECK_ENV; CORBA::String_var str = - this->orb_->object_to_string (ec.in (), ACE_TRY_ENV); + orb->object_to_string (ec.in (), TAO_TRY_ENV); ACE_DEBUG ((LM_DEBUG, - "The EC IOR is <%s>\n", str.in ())); + "The EC IOR is <%s>\n", str.in ())); CosNaming::Name channel_name (1); channel_name.length (1); - channel_name[0].id = CORBA::string_dup (this->service_name_); - naming_context->rebind (channel_name, ec.in (), ACE_TRY_ENV); - ACE_TRY_CHECK; + channel_name[0].id = CORBA::string_dup (service_name); + naming_context->bind (channel_name, ec.in (), TAO_TRY_ENV); + TAO_CHECK_ENV; - poa_manager->activate (ACE_TRY_ENV); - ACE_TRY_CHECK; + poa_manager->activate (TAO_TRY_ENV); + TAO_CHECK_ENV; ACE_DEBUG ((LM_DEBUG, "%s; running event service\n", __FILE__)); - if (this->orb_->run () == -1) + if (orb->run () == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "run"), 1); - naming_context->unbind (channel_name, ACE_TRY_ENV); - ACE_TRY_CHECK; + naming_context->unbind (channel_name, TAO_TRY_ENV); + TAO_CHECK_ENV; - if (!CORBA::is_nil (scheduler.in ())) - { - naming_context->unbind (schedule_name, ACE_TRY_ENV); - ACE_TRY_CHECK; - } + if (global_scheduler == 0) + { + naming_context->unbind (schedule_name, TAO_TRY_ENV); + TAO_CHECK_ENV; + } } - ACE_CATCHANY + TAO_CATCHANY { - ACE_TRY_ENV.print_exception ("EC"); + TAO_TRY_ENV.print_exception ("EC"); } - ACE_ENDTRY; + TAO_ENDTRY; return 0; } -int -Event_Service::parse_args (int argc, char *argv []) -{ - // default values... - this->service_name_ = "EventService"; - - ACE_Get_Opt get_opt (argc, argv, "n:s:t:"); - int opt; - - while ((opt = get_opt ()) != EOF) - { - switch (opt) - { - case 'n': - this->service_name_ = get_opt.optarg; - break; - - case 's': - // It could be just a flag (i.e. no "global" or "local" - // argument, but this is consistent with the EC_Multiple - // test and also allows for a runtime scheduling service. - - if (ACE_OS::strcasecmp (get_opt.optarg, "global") == 0) - { - this->global_scheduler_ = 1; - } - else if (ACE_OS::strcasecmp (get_opt.optarg, "local") == 0) - { - this->global_scheduler_ = 0; - } - else - { - ACE_DEBUG ((LM_DEBUG, - "Unknown scheduling type <%s> " - "defaulting to local\n", - get_opt.optarg)); - this->global_scheduler_ = 0; - } - break; - - case 't': - if (ACE_OS::strcasecmp (get_opt.optarg, "NEW") == 0) - { - this->event_service_type_ = ES_NEW; - } - else if (ACE_OS::strcasecmp (get_opt.optarg, "OLD_REACTIVE") == 0) - { - this->event_service_type_ = ES_OLD_REACTIVE; - } - else if (ACE_OS::strcasecmp (get_opt.optarg, "OLD_MT") == 0) - { - this->event_service_type_ = ES_OLD_MT; - } - else - { - ACE_DEBUG ((LM_DEBUG, - "Unknown event service type <%s> " - "defaulting to REACTIVE\n", - get_opt.optarg)); - this->event_service_type_ = ES_NEW; - } - break; - - case '?': - default: - ACE_DEBUG ((LM_DEBUG, - "Usage: %s " - "-n service_name " - "-s <global|local> " - "-t <new|old_reactive|old_mt> " - "\n", - argv[0])); - return -1; - } - } - - return 0; -} - - -RtecEventChannelAdmin::ConsumerAdmin_ptr -Event_Service::for_consumers (CORBA::Environment &ACE_TRY_ENV) -{ - return this->ec_impl_->for_consumers (ACE_TRY_ENV); -} - -RtecEventChannelAdmin::SupplierAdmin_ptr -Event_Service::for_suppliers (CORBA::Environment &ACE_TRY_ENV) -{ - return this->ec_impl_->for_suppliers (ACE_TRY_ENV); -} - -void -Event_Service::destroy (CORBA::Environment &ACE_TRY_ENV) -{ - this->ec_impl_->destroy (ACE_TRY_ENV); - ACE_CHECK; - this->orb_->shutdown (); -} - -RtecEventChannelAdmin::Observer_Handle -Event_Service::append_observer (RtecEventChannelAdmin::Observer_ptr observer, - CORBA::Environment &ACE_TRY_ENV) -{ - return this->ec_impl_->append_observer (observer, ACE_TRY_ENV); -} - -void -Event_Service::remove_observer (RtecEventChannelAdmin::Observer_Handle handle, - CORBA::Environment &ACE_TRY_ENV) -{ - this->ec_impl_->remove_observer (handle, ACE_TRY_ENV); -} - #if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) template class ACE_Auto_Basic_Ptr<POA_RtecScheduler::Scheduler>; template class auto_ptr<POA_RtecScheduler::Scheduler>; |