diff options
Diffstat (limited to 'TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp')
| -rw-r--r-- | TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp | 266 |
1 files changed, 0 insertions, 266 deletions
diff --git a/TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp b/TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp deleted file mode 100644 index 4363ff6e84c..00000000000 --- a/TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp +++ /dev/null @@ -1,266 +0,0 @@ -// $Id$ - -/** - * @file Simple_Component_Server.cpp - * - * This file contains a simple - */ - -#include "ciao/Container_Base.h" -#include "ace/SString.h" -#include "ace/Read_Buffer.h" -#include "ace/Get_Opt.h" -#include "ace/OS_NS_stdio.h" -#include "Simple_Server_i.h" - -//#include "ciao/HomeRegistrar_i.h" - -char *ior_filename = 0; -//char *home_registrar_ior = 0; -char *component_list_ = 0; -int create_component = 0; // If we need to create a cached component. - -int -parse_args (int argc, char *argv[]) -{ - ACE_Get_Opt get_opts (argc, argv, "ci:o:"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'c': // Create cached component - create_component = 1; - break; - - case 'o': // get the server IOR output filename - ior_filename = get_opts.opt_arg (); - break; - - case 'i': // get component configuration - component_list_ = get_opts.opt_arg (); - break; - - case '?': // display help for use of the server. - default: - ACE_ERROR_RETURN ((LM_ERROR, - "usage: %s\n" - "-c instantiate the component" - "-i <component config file>\n" - "-o <server_ior_output_file>" - "\n", - argv [0]), - -1); - } - - return 0; -} - -int -write_IOR(const char *ior) -{ - if (ior_filename == 0 || ior == 0) - ACE_ERROR_RETURN ((LM_ERROR, - "A valid filename and an IOR string are required for saving IOR\n"), - -1); - - - FILE* ior_output_file_ = - ACE_OS::fopen (ior_filename, "w"); - - if (ior_output_file_ == NULL) - ACE_ERROR_RETURN ((LM_ERROR, - "Unable to open <%s> for writing\n", ior_filename), - -1); - - ACE_OS::fprintf (ior_output_file_, - "%s", - ior); - - ACE_OS::fclose (ior_output_file_); - - return 0; -} - -int breakdown (char *source, - int len, - char *list[]) -{ - ACE_Tokenizer line (source); - line.delimiter_replace ('|', 0); - - int cntr = 0; - char *p; - for (p = line.next (); - p && cntr < len; - ++cntr, p=line.next ()) - // @@ More memory leaks? - list[cntr] = ACE::strnew (p); - - return cntr; -} - -Components::CCMHome_ptr -install_homes (CIAO::Session_Container &container, - CORBA::ORB_ptr orb - ACE_ENV_ARG_DECL) -{ - ACE_UNUSED_ARG (orb); - - if (component_list_ == 0) - ACE_THROW_RETURN (CORBA::BAD_PARAM (), - Components::CCMHome::_nil ()); - - FILE* config_file = - ACE_OS::fopen (component_list_, "r"); - - if (config_file) - { - ACE_Read_Buffer ior_buffer (config_file); - char *data = 0; - - if ((data = ior_buffer.read ('\n')) != 0) - { - char *items[10]; - auto_ptr<char> an_entry (data); - int len = breakdown (an_entry.get (), - 10, - items); - - if (len < 4) // we only need the first 4 fields now. - { - ACE_DEBUG ((LM_DEBUG, "Error parsing configuration file\n")); - ACE_THROW_RETURN (CORBA::INTERNAL (), 0); - } - - // len should be at least such and such long so we have all - // the information we need. These items are separate with - // character '|'. - - // 0 -> DLL path to home executor - // 1 -> entry point for home executor factory - // 2 -> DLL path to servant glue code - // 3 -> entry point for servant glue code factory - - // we are not using these until we support HomeFinder. - - // 4 -> Repository ID for home interface - // 5 -> Repository ID for managed component - // 6 -> Canonical Name of home interface. - - Components::CCMHome_var home = - container.ciao_install_home (items[0], - items[1], - items[2], - items[3], - "instance_name" - ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (Components::CCMHome::_nil ()); - - if (CORBA::is_nil (home.in ())) - { - ACE_DEBUG ((LM_DEBUG, "Fail to create home\n")); - ACE_THROW_RETURN (CORBA::INTERNAL (), 0); - } - return home._retn (); - } - } - ACE_OS::fclose (config_file); - ACE_THROW_RETURN (CORBA::INTERNAL (), 0); -} - -int -main (int argc, char *argv[]) -{ - ACE_TRY_NEW_ENV - { - // Initialize orb - CORBA::ORB_var orb = CORBA::ORB_init (argc, - argv, - "" - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - if (parse_args (argc, argv) != 0) - return -1; - - // Get reference to Root POA. - CORBA::Object_var obj - = orb->resolve_initial_references ("RootPOA" - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - PortableServer::POA_var poa - = PortableServer::POA::_narrow (obj.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - // Activate POA manager - PortableServer::POAManager_var mgr - = poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - - mgr->activate (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - - // Start Deployment part - - CIAO::Session_Container container (orb.in ()); - container.init (); - - // install component - - Components::CCMHome_var home = - install_homes (container, - orb.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - CIAO::Simple_Server_i *servant = 0; - ACE_NEW_RETURN (servant, - CIAO::Simple_Server_i (orb.in (), - poa.in (), - home.in ()), - -1); - PortableServer::ServantBase_var safe_daemon (servant); - // Implicit activation - CIAO::Simple_Server_var server = servant->_this (); - - CORBA::String_var str; - Components::CCMObject_var temp; - - if (create_component != 0) - { - temp = server->get_component (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - - str = orb->object_to_string (temp.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - else - { - str = orb->object_to_string (server.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - - write_IOR (str.in ()); - - ACE_DEBUG ((LM_DEBUG, - "Running the simple generic server...\n")); - - // Run the main event loop for the ORB. - orb->run (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - "server::main\t\n"); - return 1; - } - ACE_ENDTRY; - - return 0; -} |