TAO_END_VERSIONED_NAMESPACE_DECL Namespace Reference

Functions
int	open_private_services_i (ACE_Service_Gestalt *pcfg, int &argc, char **argv, bool skip_service_config_open, bool ignore_default_svc_conf_file)
	Open services, belonging to the gestalt instance.
void	register_global_services_i (ACE_Service_Gestalt *pcfg)
	registers all process-wide (global) services, available to all ORBs
void	register_additional_services_i (ACE_Service_Gestalt *pcfg)
int	parse_svcconf_args_i (int &argc, ACE_TCHAR **argv, CORBA::StringSeq &svc_config_argv)
	Modifies the argc to reflect any arguments it has "consumed".
int	parse_private_args_i (int &argc, ACE_TCHAR **argv, CORBA::StringSeq &svc_config_argv, bool &skip_service_config_open)
	Modifies the argc to reflect any arguments it has "consumed".
int	parse_global_args_i (int &argc, ACE_TCHAR **argv, CORBA::StringSeq &svc_config_argv, bool apply_values)
	Modifies the argc to reflect any arguments it has "consumed".

---

Function Documentation

int open_private_services_i (  ACE_Service_Gestalt *  pcfg, int &  argc, char **  argv, bool  skip_service_config_open = false, bool  ignore_default_svc_conf_file = false )

Open services, belonging to the gestalt instance. Initialize ORB-local (private) ACE Service Configurator repository. Returns: 0 if successful, -1 with errno set if failure. Definition at line 453 of file TAO_Internal.cpp. References ACE_DEFAULT_LOGGER_KEY, ACE_Argv_Type_Converter::get_argc(), ACE_Argv_Type_Converter::get_TCHAR_argv(), and ACE_Service_Gestalt::open(). Referenced by TAO::ORB::open_services(). { if (skip_service_config_open) { return 0; } #if defined (TAO_PLATFORM_SVC_CONF_FILE_NOTSUP) ignore_default_svc_conf_file = true; #endif /* TAO_PLATFORM_SVC_CONF_FILE_NOTSUP */ // Copy command line parameter to allow conversion ACE_Argv_Type_Converter command_line (argc, argv); return pcfg->open (command_line.get_argc (), command_line.get_TCHAR_argv (), ACE_DEFAULT_LOGGER_KEY, 0, // Don't ignore static services. ignore_default_svc_conf_file); }

int parse_global_args_i (  int &  argc, ACE_TCHAR **  argv, CORBA::StringSeq &  svc_config_argv, bool  apply_values )

Modifies the argc to reflect any arguments it has "consumed". Parses the supplied command-line arguments to extract any that apply to the process (globally) When multiple ORBs are being configured, the global options are only processed for the first ORB loaded. However subsequent ORBs may be supplied with some of these options, so they need to be eliminated as though they were processed. For this reason, this function is called for every ORB, but only the first call sets apply_values to true Definition at line 834 of file TAO_Internal.cpp. References ACE_Arg_Shifter, ACE_DEBUG, ACE_TEXT, ACE_OS::atoi(), ACE::debug(), ACE_OS::getenv(), LM_DEBUG, CORBA::string_dup(), CORBA::StringSeq, and TAO_debug_level. Referenced by TAO::ORB::open_services(). { // NOTE: When adding new global arguments, ensure they are only // applied when apply_values is true, but that they are always // consumed, if they need to be consumed. #if defined (TAO_DEBUG) && !defined (ACE_HAS_WINCE) // Make it a little easier to debug programs using this code. if (apply_values) { TAO_debug_level = ACE_Env_Value<u_int> ("TAO_ORB_DEBUG", 0); char * const value = ACE_OS::getenv ("TAO_ORB_DEBUG"); if (value != 0) { TAO_debug_level = ACE_OS::atoi (value); if (TAO_debug_level <= 0) { TAO_debug_level = 1; } ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TAO_debug_level == %d\n"), TAO_debug_level)); } } #endif /* TAO_DEBUG && !ACE_HAS_WINCE */ // Extract the Service Configurator ORB options from the argument // vector. ACE_Arg_Shifter arg_shifter (argc, argv); CORBA::ULong len = 0; while (arg_shifter.is_anything_left ()) { if (0 == arg_shifter.cur_arg_strncasecmp (ACE_TEXT ("-ORBDebug"))) { if (apply_values) { // Later, replace all of these // warning this turns on a daemon. ACE::debug (1); } arg_shifter.consume_arg (); } else if (0 == arg_shifter.cur_arg_strncasecmp (ACE_TEXT ("-ORBDaemon"))) { // Be a daemon. if (apply_values) { len = svc_config_argv.length (); svc_config_argv.length (len + 1); svc_config_argv[len] = CORBA::string_dup ("-b"); } arg_shifter.consume_arg (); } // Can't interpret this argument. // Move on to the next argument. else { // Any arguments that don't match are ignored so // that the caller can still use them. arg_shifter.ignore_arg (); } } return 0; } /* parse_global_args_i */

int parse_private_args_i (  int &  argc, ACE_TCHAR **  argv, CORBA::StringSeq &  svc_config_argv, bool &  skip_service_config_open )

Modifies the argc to reflect any arguments it has "consumed". Parses the supplied command-line arguments to extract any instance-specific ones. Definition at line 750 of file TAO_Internal.cpp. References ACE_Arg_Shifter, ACE_TCHAR, ACE_TEXT, ACE_TEXT_ALWAYS_CHAR, ACE_OS::atoi(), negotiate_codesets, CORBA::string_dup(), CORBA::StringSeq, and TAO_debug_level. Referenced by TAO::ORB::open_services(). { // Extract the Service Configurator ORB options from the argument // vector. ACE_Arg_Shifter arg_shifter (argc, argv); CORBA::ULong len = 0; while (arg_shifter.is_anything_left ()) { const ACE_TCHAR *current_arg = 0; if (0 == arg_shifter.cur_arg_strncasecmp (ACE_TEXT ("-ORBSkipServiceConfigOpen"))) { skip_service_config_open = true; arg_shifter.consume_arg (); } else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT ("-ORBSvcConfDirective")))) { len = svc_config_argv.length (); svc_config_argv.length (len + 2); // 2 arguments to add // This is used to pass arguments to the Service // Configurator using the "command line" to provide // configuration information rather than using a svc.conf // file. Pass the "-S" to the service configurator. svc_config_argv[len] = CORBA::string_dup ("-S"); svc_config_argv[len + 1] = CORBA::string_dup (ACE_TEXT_ALWAYS_CHAR (current_arg)); arg_shifter.consume_arg (); } else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT ("-ORBServiceConfigLoggerKey")))) { len = svc_config_argv.length (); svc_config_argv.length (len + 2); // 2 arguments to add svc_config_argv[len] = CORBA::string_dup ("-k"); svc_config_argv[len + 1] = CORBA::string_dup (ACE_TEXT_ALWAYS_CHAR (current_arg)); arg_shifter.consume_arg (); } else if (0 == arg_shifter.cur_arg_strncasecmp (ACE_TEXT ("-ORBNegotiateCodesets"))) { // Negotiate codesets must be evaluated prior to calling // register_global_services_i. // Don't consume, the ORB_Core::init will use it again. arg_shifter.ignore_arg(); if (0 != (current_arg = arg_shifter.get_current())) negotiate_codesets = (ACE_OS::atoi (current_arg)); arg_shifter.ignore_arg(); } else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT ("-ORBDebugLevel")))) { // Allowing different ORBs to change the global debug // level may be unexpected, but since this TAO_debug_level = ACE_OS::atoi (current_arg); arg_shifter.consume_arg (); } else { // Can't interpret this argument. Move on to the next // argument. Any arguments that don't match are ignored // so that the caller can still use them. arg_shifter.ignore_arg (); } } return 0; } /* parse_private_args_i */

int parse_svcconf_args_i (  int &  argc, ACE_TCHAR **  argv, CORBA::StringSeq &  svc_config_argv )

Modifies the argc to reflect any arguments it has "consumed". Parses the supplied command-line arguments to extract any that specify a Service Configurator file (-ORBSvcConf). This is done separately, because depending on the context, the configuration file may apply to the process-wide service repository, or to the orb-specific (private) one. Definition at line 687 of file TAO_Internal.cpp. References ACE_Arg_Shifter, ACE_ERROR_RETURN, ACE_TCHAR, ACE_TEXT, ACE_TEXT_ALWAYS_CHAR, ACE_OS::fclose(), ACE_OS::fopen(), LM_ERROR, CORBA::string_dup(), and CORBA::StringSeq. Referenced by TAO::ORB::open_services(). { // Extract the Service Configurator ORB options from the argument // vector. ACE_Arg_Shifter arg_shifter (argc, argv); CORBA::ULong len = 0; while (arg_shifter.is_anything_left ()) { const ACE_TCHAR *current_arg = arg_shifter.get_the_parameter (ACE_TEXT ("-ORBSvcConf")); if (0 != current_arg) { // Specify the name of the svc.conf file to be used. // Proceeds only if the configuration file exists. FILE * const conf_file = ACE_OS::fopen (current_arg, ACE_TEXT ("r")); if (0 == conf_file) { // Assigning EINVAL to errno to make an exception // thrown. calling code does not throw an exception if // the errno is set to ENOENT for some reason. errno = EINVAL; ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) Service ") ACE_TEXT ("Configurator ") ACE_TEXT ("unable to open file %s\n"), current_arg), -1); } else { ACE_OS::fclose (conf_file); } len = svc_config_argv.length (); svc_config_argv.length (len + 2); // 2 arguments to add svc_config_argv[len] = CORBA::string_dup ("-f"); svc_config_argv[len + 1] = CORBA::string_dup (ACE_TEXT_ALWAYS_CHAR (current_arg)); arg_shifter.consume_arg (); } // Can't interpret this argument. Move on to the next argument. else { // Any arguments that don't match are ignored so that the // caller can still use them. arg_shifter.ignore_arg (); } } return 0; } /* parse_svcconf_args_i */

void register_additional_services_i (  ACE_Service_Gestalt *  pcfg  )

Definition at line 577 of file TAO_Internal.cpp. References ACE_TEXT_CHAR_TO_TCHAR, client_strategy_factory_args, ACE_Shared_Object::init(), ACE_Dynamic_Service< TYPE >::instance(), ACE_Service_Gestalt::process_directive(), resource_factory_args, and server_strategy_factory_args. Referenced by TAO::ORB::open_services(). { // @@ What the heck do these things do and do we need to avoid // calling them if we're not invoking the svc.conf file? // @@ They are needed for platforms that have no file system, // like VxWorks. if (resource_factory_args != 0) { pcfg->process_directive( ACE_TEXT_CHAR_TO_TCHAR (resource_factory_args)); } if (client_strategy_factory_args != 0) { pcfg->process_directive (ACE_TEXT_CHAR_TO_TCHAR (client_strategy_factory_args)); } if (server_strategy_factory_args != 0) { pcfg->process_directive (ACE_TEXT_CHAR_TO_TCHAR (server_strategy_factory_args)); } ACE_Service_Object * const pi_server_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "PI_Server_Loader"); if (pi_server_loader != 0) { pi_server_loader->init (0, 0); } ACE_Service_Object * const bidir_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "BiDirGIOP_Loader"); if (bidir_loader != 0) { bidir_loader->init (0, 0); } ACE_Service_Object * const messaging_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "Messaging_Loader"); if (messaging_loader != 0) { messaging_loader->init (0, 0); } // Handle RTCORBA library special case. Since RTCORBA needs // its init method call to register several hooks, call it // here if it hasn't already been called. ACE_Service_Object * const rt_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "RT_ORB_Loader"); if (rt_loader != 0) { rt_loader->init (0, 0); } ACE_Service_Object * const rtscheduler_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "RTScheduler_Loader"); if (rtscheduler_loader != 0) { rtscheduler_loader->init (0, 0); } ACE_Service_Object * const csd_framework_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "CSD_Framework_Loader"); if (csd_framework_loader != 0) { csd_framework_loader->init (0, 0); } ACE_Service_Object * const endpoint_policy_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "EndpointPolicy_Initializer"); if (endpoint_policy_loader != 0) { endpoint_policy_loader->init (0, 0); } ACE_Service_Object * const diffserv_policy_loader = ACE_Dynamic_Service<ACE_Service_Object>::instance ( pcfg, "DiffservPolicy_Initializer"); if (diffserv_policy_loader != 0) { diffserv_policy_loader->init (0, 0); } } /* register_additional_services_i */

void register_global_services_i (  ACE_Service_Gestalt *  pcfg  )

registers all process-wide (global) services, available to all ORBs Initialize the ACE Service Configurator with the process-global services (available to any ORB). Returns: 0 if successful, -1 with errno set if failure. Note: You can provide your program a set of default `svc.conf' entries by setting ignore_default_svc_conf_file to non-zero and use default_svc_conf_entries() before calling open_global_services(). In addition, you can skip_service_config_open altogether, which used to be important when the ORB is linked in via the ACE_Service_Config, since the ACE_Service_Config was non-reentrant. However, the ACE_Service_Config is now reentrant meaning that it is really no longer necessary to do so. Definition at line 482 of file TAO_Internal.cpp. References ACE_DYNAMIC_SERVICE_DIRECTIVE, ACE_ERROR, ACE_REMOVE_SERVICE_DIRECTIVE, ACE_TEXT, ACE_Dynamic_Service< TYPE >::instance(), TAO_Codeset_Manager_Factory_Base::is_default(), LM_ERROR, negotiate_codesets, ACE_Service_Gestalt::process_directive(), ACE_Service_Config::process_directive(), and TAO_debug_level. Referenced by TAO::ORB::open_services(). { // This has to be done before intializing the resource // factory. Codesets is a special library since its configuration // is optional and it may be linked statically. if (negotiate_codesets) { TAO_Codeset_Manager_Factory_Base *factory = ACE_Dynamic_Service<TAO_Codeset_Manager_Factory_Base>::instance ( "TAO_Codeset"); if (factory == 0 || factory->is_default ()) { #if !defined (TAO_AS_STATIC_LIBS) // only for dynamic libs, check to see if default factory // and if so, remove it ACE_Service_Config::process_directive ( ACE_REMOVE_SERVICE_DIRECTIVE ("TAO_Codeset")); ACE_Service_Config::process_directive ( ACE_DYNAMIC_SERVICE_DIRECTIVE ( "TAO_Codeset", "TAO_Codeset", "_make_TAO_Codeset_Manager_Factory", "")); factory = ACE_Dynamic_Service< TAO_Codeset_Manager_Factory_Base >::instance ("TAO_Codeset"); #endif } if (factory == 0) { if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t) ORB_Core: ") ACE_TEXT ("Unable to initialize ") ACE_TEXT ("Codeset Manager\n"))); } } } pcfg->process_directive ( ace_svc_desc_TAO_Default_Resource_Factory); pcfg->process_directive ( ace_svc_desc_TAO_Default_Client_Strategy_Factory); pcfg->process_directive ( ace_svc_desc_TAO_Default_Server_Strategy_Factory); // Configure the IIOP factory. You do *NOT* need modify this // code to add your own protocol, instead simply add the // following to your svc.conf file: // // dynamic PN_Factory Service_Object * LIB:_make_PN_Protocol_Factory() "" // static Resource_Factory "-ORBProtocolFactory PN_Factory" // // where PN is the name of your protocol and LIB is the base // name of the shared library that implements the protocol. #if defined (TAO_HAS_IIOP) && (TAO_HAS_IIOP != 0) pcfg->process_directive (ace_svc_desc_TAO_IIOP_Protocol_Factory); #endif /* TAO_HAS_IIOP && TAO_HAS_IIOP != 0 */ // add descriptor to list of static objects. #if (TAO_HAS_MCAST_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_MCAST_Parser); #endif /* TAO_HAS_MCAST_PARSER == 1 */ #if (TAO_HAS_CORBANAME_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_CORBANAME_Parser); #endif /* TAO_HAS_CORBANAME_PARSER == 1 */ #if (TAO_HAS_CORBALOC_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_CORBALOC_Parser); #endif /* TAO_HAS_CORBALOC_PARSER == 1 */ #if (TAO_HAS_FILE_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_FILE_Parser); #endif /* TAO_HAS_FILE_PARSER == 1 */ #if (TAO_HAS_DDL_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_DLL_Parser); #endif /* TAO_HAS_DDL_PARSER == 1 */ #if (TAO_HAS_HTTP_PARSER == 1) pcfg->process_directive (ace_svc_desc_TAO_HTTP_Parser); #endif /* TAO_HAS_HTTP_PARSER */ pcfg->process_directive (ace_svc_desc_TAO_Default_Stub_Factory); pcfg->process_directive ( ace_svc_desc_TAO_Default_Endpoint_Selector_Factory); pcfg->process_directive ( ace_svc_desc_TAO_Default_Thread_Lane_Resources_Manager_Factory); pcfg->process_directive (ace_svc_desc_TAO_Default_Collocation_Resolver); } /* register_global_services_i */

---