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 | 262 |
1 files changed, 262 insertions, 0 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 new file mode 100644 index 00000000000..7fc55d10f6a --- /dev/null +++ b/TAO/CIAO/tools/Simple_Component_Server/Simple_Component_Server.cpp @@ -0,0 +1,262 @@ +// $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 "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 (CORBA::BAD_PARAM ()); + + 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] + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + 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; +} |