diff options
Diffstat (limited to 'DAnCE/dance/Plan_Launcher/Plan_Launcher.cpp')
| -rw-r--r-- | DAnCE/dance/Plan_Launcher/Plan_Launcher.cpp | 1042 |
1 files changed, 0 insertions, 1042 deletions
diff --git a/DAnCE/dance/Plan_Launcher/Plan_Launcher.cpp b/DAnCE/dance/Plan_Launcher/Plan_Launcher.cpp deleted file mode 100644 index a7fd94b8cda..00000000000 --- a/DAnCE/dance/Plan_Launcher/Plan_Launcher.cpp +++ /dev/null @@ -1,1042 +0,0 @@ -#include "ace/OS_NS_sys_time.h" -#include "ace/OS_NS_unistd.h" -#include "ace/OS_NS_stdlib.h" -#include "ace/Dynamic_Service.h" -#include "ace/Env_Value_T.h" -#include "ace/Get_Opt.h" -#include "tao/ORB.h" -#include "tao/Object.h" -#include "dance/Logger/Log_Macros.h" -#include "dance/Logger/Logger_Service.h" -#include "tools/Convert_Plan/Convert_Plan_Impl.h" -#include "tools/Config_Handlers/XML_File_Intf.h" -#include "tools/Domain_Validator/CORBA/CORBA_Domain_Validator_impl.h" - -#include "EM_Launcher.h" -#include "NM_Launcher.h" -#include "LM_Launcher.h" - -//#include "Plan_Launcher_Impl.h" - -namespace -{ - struct Options - { - enum MODE - { - LAUNCH, - STARTLAUNCH, - FINISHLAUNCH, - START, - TEARDOWN, - INVALID - }; - - Options (void) - : em_ior_ ("corbaname:rir:/NameService#ExecutionManager"), - nm_ior_ (0), - lm_ior_ (0), - xml_plan_ (0), - cdr_plan_ (0), - domain_file_ (0), - uuid_ (0), - am_ior_ (0), - app_ior_ (0), - output_ (false), - output_prefix_ (0), - mode_ (LAUNCH), - force_ (false), - quiet_ (false), - em_timeout_ (1), - domain_timeout_ (0) - {} - - const ACE_TCHAR *em_ior_; - const ACE_TCHAR *nm_ior_; - const ACE_TCHAR *lm_ior_; - const ACE_TCHAR *xml_plan_; - const ACE_TCHAR *cdr_plan_; - const ACE_TCHAR *domain_file_; - const ACE_TCHAR *uuid_; - const ACE_TCHAR *am_ior_; - const ACE_TCHAR *app_ior_; - bool output_; - const ACE_TCHAR *output_prefix_; - MODE mode_; - bool force_; - bool quiet_; - int em_timeout_; - int domain_timeout_; - }; -} - - -void -usage(const ACE_TCHAR*) -{ - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Plan Launcher Options :\n") - ACE_TEXT ("\t-k|--em-ior <EM IOR>\t\t") - ACE_TEXT ("ExecutionManager IOR for EM based deployment.\n") - ACE_TEXT ("\t-n|--nm-ior <NodeManager IOR>\t") - ACE_TEXT ("NodeManager IOR for NM based deployment.\n") - ACE_TEXT ("\t--lm-ior <LocalityManager IOR>\t") - ACE_TEXT ("LocalityManager IOR for LM based deployment.\n") - ACE_TEXT ("\t--manager-timeout <seconds>\t\n") - ACE_TEXT ("Number of seconds to wait for a valid Execution Manager reference.\n") - ACE_TEXT ("\t--domain-timeout <seconds>\t") - ACE_TEXT ("Number of seconds to wait for a domain validation.\n") - ACE_TEXT ("\t--domain-file <cdd>\t") - ACE_TEXT ("The domain file that the plan launcher should use for domain validation\n") - /* - ACE_TEXT ("\nName Service Options\n") - ACE_TEXT ("\t--domain-nc [NC]\t\t) - ACE_TEXT (Domain Naming Context (default will rir NameService)\n") - ACE_TEXT ("\t--instance-nc [NC]\t\t") - ACE_TEXT("Instance Naming Context (default will rir NameService)\n") - */ - ACE_TEXT ("\nPlan Identification Options:\n") - ACE_TEXT ("\t-c|--cdr-plan <CDR Deployment Plan>\n") - ACE_TEXT ("\t-x|--xml-plan <XML Deployment Plan>\n") - - ACE_TEXT ("\t-u|--plan-uuid <PLAN UUID>\t") - ACE_TEXT ("Only supported for EM-based deployments\n") - - ACE_TEXT ("\t-a|--app-ior <APP IOR>\t\t") - ACE_TEXT ("IOR for Application entity (Domain or Node)\n") - - ACE_TEXT ("\t-m|--am-ior <AM IOR>\t\t") - ACE_TEXT ("IOR For ApplicationManager entity (Domain or Node)\n") - - ACE_TEXT ("\nPlan Control Options:\n") - ACE_TEXT ("The default action is to fully launch a plan. ") - ACE_TEXT ("The following options may be used\n") - ACE_TEXT ("to arrive at a different state\n") - ACE_TEXT ("\t-l|--launch-plan\t\t") - ACE_TEXT ("Launch the plan (Requires CDR/XML plan)\n") - - ACE_TEXT ("\t-s|--stop-plan\t\t\tStop the plan ") - ACE_TEXT ("(Requires Plan, UUID, or APP/AM references\n") - - ACE_TEXT ("\t-f|--force\t\t\tDo not stop teardown on errors") - - ACE_TEXT ("\nOther Options\n") - ACE_TEXT ("\t-o|--output[prefix]\t\tOutput IOR files ") - ACE_TEXT ("that result from plan control action, ") - ACE_TEXT ("if any. Optional prefix to filename defaults ") - ACE_TEXT ("to plan UUID if plan is provided. ") - ACE_TEXT ("Default is on for NM-based deployments.\n") - - ACE_TEXT ("\t-q|--quiet\t\t\tSuppress error messages.\n") - ACE_TEXT ("\t-h|--help\t\t\tShow this usage information\n") - )); -} - -bool -parse_args(int argc, ACE_TCHAR *argv[], Options &options) -{ - DANCE_TRACE_LOG (DANCE_LOG_TRACE, - (LM_TRACE, DLINFO - ACE_TEXT("PL options : \""))); - - for (int i = 0; i < argc; ++i) - { - DANCE_TRACE_LOG (DANCE_LOG_TRACE, (LM_TRACE, "\t%s\n", argv[i])); - } - - ACE_Get_Opt get_opt(argc, argv, - ACE_TEXT ("k:n:c:x:u:m:a:lsfqo::h")); - get_opt.long_option(ACE_TEXT("em-ior"), 'k', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("nm-ior"), 'n', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("lm-ior"), ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("xml-plan"), 'x', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("cdr-plan"), 'c', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("plan-uuid"), 'u', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("am-ior"), 'm', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("app-ior"), 'a', ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("launch-plan"), 'l', ACE_Get_Opt::NO_ARG); - get_opt.long_option(ACE_TEXT("stop-plan"), 's', ACE_Get_Opt::NO_ARG); - get_opt.long_option(ACE_TEXT("force"), 'f', ACE_Get_Opt::NO_ARG); - get_opt.long_option(ACE_TEXT("quiet"), 'q', ACE_Get_Opt::NO_ARG); - get_opt.long_option(ACE_TEXT("output"), 'o', ACE_Get_Opt::ARG_OPTIONAL); - get_opt.long_option(ACE_TEXT("help"), 'h', ACE_Get_Opt::NO_ARG); - get_opt.long_option(ACE_TEXT("manager-timeout"), ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("domain-timeout"), ACE_Get_Opt::ARG_REQUIRED); - get_opt.long_option(ACE_TEXT("domain-file"), ACE_Get_Opt::ARG_REQUIRED); - - int c; - ACE_CString s; - while ( (c = get_opt ()) != EOF) - { - switch (c) - { - case 'k': - if (get_opt.opt_arg () == 0) - { - options.em_ior_ = ACE_TEXT ("corbaname:rir:/NameService#ExecutionManager"); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Defaulting to NameService lookup") - ACE_TEXT ("of ExecutionManager\n"))); - } - else - { - options.em_ior_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using ExecutionManager IOR: %s\n"), - options.em_ior_)); - } - break; - - case 'n': - options.em_ior_ = 0; - options.nm_ior_ = get_opt.opt_arg (); - options.output_ = true; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using NodeManager IOR: %s\n"), - options.nm_ior_)); - break; - - case 'x': - options.xml_plan_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using XML plan: %s\n"), - options.xml_plan_)); - break; - - case 'c': - options.cdr_plan_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using CDR plan: %s\n"), - options.cdr_plan_)); - break; - - case 'u': - options.uuid_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using UUID: %s\n"), - options.uuid_)); - break; - - case 'm': - options.am_ior_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Using ApplicationManager IOR %s\n"), - options.am_ior_)); - break; - - case 'a': - options.app_ior_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Application IOR: %s\n"), - options.app_ior_)); - break; - - case 'l': - options.mode_ = Options::LAUNCH; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Launching nominated plan\n"))); - break; - - case 's': - options.mode_ = Options::TEARDOWN; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Tearing down nominated plan\n"))); - break; - - case 'f': - options.force_ = true; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Not stopping teardown on errors\n"))); - break; - - case 'o': - options.output_ = true; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("IOR files will be output to ") - ACE_TEXT ("the current working directory\n"))); - - if (get_opt.opt_arg () != 0) - { - options.output_prefix_ = get_opt.opt_arg (); - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Storing user-provided output ") - ACE_TEXT ("postfix <%s>\n"), - options.output_prefix_)); - } - - break; - - case 'q': - options.quiet_ = true; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Plan_Launcher will hide all ouput") - ACE_TEXT ("messages.\n"))); - break; - case 'h': - usage (argv[0]); - return false; - - case 0: - if (ACE_OS::strcmp (get_opt.long_option (), - ACE_TEXT ("lm-ior")) == 0) - { - options.em_ior_ = 0; - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Got LM IOR file: %C"), - get_opt.opt_arg ())); - options.lm_ior_ = get_opt.opt_arg (); - break; - } - if (ACE_OS::strcmp (get_opt.long_option (), - ACE_TEXT ("domain-file")) == 0) - { - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Got domain file: %C\n"), - get_opt.opt_arg ())); - options.domain_file_ = get_opt.opt_arg (); - break; - } - if ((ACE_OS::strcmp (get_opt.long_option (), - ACE_TEXT ("manager-timeout")) == 0)) - { - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Got Manager Timeout value: %C\n"), - get_opt.opt_arg ())); - options.em_timeout_ = ACE_OS::atoi (get_opt.opt_arg ()); - break; - } - if ((ACE_OS::strcmp (get_opt.long_option (), - ACE_TEXT ("domain-timeout")) == 0)) - { - DANCE_DEBUG (DANCE_LOG_MAJOR_DEBUG_INFO, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Got Manager Timeout value: %C\n"), - get_opt.opt_arg ())); - options.domain_timeout_ = ACE_OS::atoi (get_opt.opt_arg ()); - break; - } - - default: - usage (argv[0]); - return false; - } - } - - /// Sanity checking on the options. - - // In all cases, we need to have a EM/NM IOR specified, but only one. - if ((!options.em_ior_ && !options.nm_ior_ && !options.lm_ior_) || - (options.em_ior_ && options.nm_ior_ && options.lm_ior_)) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_launcher::parse_args - ") - ACE_TEXT ("Error: Must specify either EM IOR, NM IOR, LM IOR\n"))); - return false; - } - - // Launching plans requires a plan (duh), and only one plan - if ((options.mode_ == Options::LAUNCH) && - ((!options.xml_plan_ && !options.cdr_plan_) || - (options.xml_plan_ && options.cdr_plan_))) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Error: Launching plans requires ") - ACE_TEXT ("exactly one type of plan (CDR/XML) be ") - ACE_TEXT ("specified.\n"))); - return false; - } - - // tearing down plans requires a bit more complex set of options: - if ((options.mode_ == Options::TEARDOWN) - // Either way (EM/NM), we ca use a combination of a AM and a APP. - && !( - (options.am_ior_ && options.app_ior_) || - // If we are tearing down from EM, we have more options, namely: - // A plan of some kind - (options.em_ior_ && - ( - ((!options.xml_plan_ && !options.cdr_plan_) || - (options.xml_plan_ && options.cdr_plan_)) || - // A UUID - (!options.uuid_) - ) - ) - ) - ) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::parse_args - ") - ACE_TEXT ("Invalid set of plan identification ") - ACE_TEXT ("as required for teardown\n"))); - return false; - } - - - return true; -} - -bool -write_IOR (const ACE_TCHAR * ior_file_name, const char* ior) -{ - FILE* ior_output_file_ = ACE_OS::fopen (ior_file_name, ACE_TEXT("w")); - - if (ior_output_file_) - { - ACE_OS::fprintf (ior_output_file_, "%s", ior); - ACE_OS::fclose (ior_output_file_); - return true; - } - return false; -} - -int -launch_plan (const Options &opts, - DAnCE::Plan_Launcher_Base *pl_base, - const ::Deployment::DeploymentPlan *plan, - CORBA::ORB_ptr orb) -{ - DANCE_TRACE ("launch_plan"); - - try - { - CORBA::Object_var app_mgr, app; - - CORBA::String_var - uuid_safe (pl_base->launch_plan (*plan, app_mgr.out () , app.out ())); - ACE_CString uuid = uuid_safe.in (); - - DANCE_DEBUG (DANCE_LOG_MAJOR_EVENT, - (LM_NOTICE, DLINFO - ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Successfully deployed plan ") - ACE_TEXT ("with UUID: <%C>\n"), - uuid.c_str ())); - - if (!opts.output_) - return 0; - - ACE_TString am_output, app_output; - - if (opts.output_prefix_) - am_output = app_output = opts.output_prefix_; - else - am_output = app_output = ACE_TEXT_CHAR_TO_TCHAR (uuid.c_str ()); - - am_output += ACE_TEXT ("_AM.ior"); - app_output += ACE_TEXT ("_APP.ior"); - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Writing Application Manager IOR to <%s>\n"), - am_output.c_str ())); - CORBA::String_var tmp = orb->object_to_string (app_mgr.in ()); - write_IOR (am_output.c_str (), - tmp.in ()); - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Writing Application IOR to <%s>\n"), - am_output.c_str ())); - - tmp = orb->object_to_string (app.in ()); - write_IOR (app_output.c_str (), - tmp.in ()); - - } - catch (const DAnCE::Deployment_Failure &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Deployment failed, exception: %C\n"), - ex.ex_.c_str ())); - } - - return 1; - } - catch (const Deployment::PlanError &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Caught PlanError exception: %C, %C\n"), - ex.name.in (), - ex.reason.in () - )); - } - return 1; - } - catch (const Deployment::StartError &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Caught PlanError exception: %C, %C\n"), - ex.name.in (), - ex.reason.in () - )); - } - return 1; - } - catch (const Deployment::StopError &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Caught PlanError exception: %C, %C\n"), - ex.name.in (), - ex.reason.in () - )); - } - return 1; - } - catch (const CORBA::Exception &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Deployment failed, caught CORBA exception %C\n"), - ex._info ().c_str ())); - } - return 1; - } - catch (...) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher::launch_plan - ") - ACE_TEXT ("Deployment failed, ") - ACE_TEXT ("caught unknown C++ exception\n"))); - } - return 1; - } - - return 0; -} - -int -teardown_plan (const Options &opts, - DAnCE::Plan_Launcher_Base *pl_base, - const ::Deployment::DeploymentPlan *plan, - CORBA::ORB_ptr orb) -{ - DANCE_TRACE ("teardown_plan"); - - int rc = 0; - try - { - CORBA::Object_var am; - CORBA::Object_var app; - if (opts.am_ior_ && opts.app_ior_) - { - DANCE_DEBUG (DANCE_LOG_MAJOR_EVENT, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Tearing down plan with explicitly ") - ACE_TEXT ("nominated App and AM IORs.\n"))); - am = orb->string_to_object (opts.am_ior_); - app = orb->string_to_object (opts.app_ior_); - } - else - { - // Need to perform lookup by uuid, - // either explicitly provided or in plan. - ACE_CString uuid; - if (plan) - uuid = plan->UUID.in (); - else - uuid = ACE_TEXT_ALWAYS_CHAR (opts.uuid_); - - DAnCE::EM_Launcher *em_launcher = - dynamic_cast <DAnCE::EM_Launcher *> (pl_base); - - if (!em_launcher) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Error: Attempting UUID lookup on non") - ACE_TEXT ("-EM managed plan not supported\n"))); - return 1; - } - - if (em_launcher->lookup_by_uuid (uuid.c_str (), - am.out (), - app.out ())) - { - DANCE_DEBUG (DANCE_LOG_MAJOR_EVENT, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Tearing down plan with UUID %C\n"), - uuid.c_str ())); - } - else - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Error: Lookup by UUID failed\n"))); - return 1; - } - } - - try - { - pl_base->teardown_application (am, app); - } - catch (const DAnCE::Deployment_Failure &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Application Teardown failed, exception: %C\n"), - ex.ex_.c_str ())); - } - rc = 1; - } - catch (const CORBA::Exception &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Application Teardown failed, ") - ACE_TEXT ("caught CORBA exception %C\n"), - ex._info ().c_str ())); - } - rc = 1; - } - catch (...) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Application Teardown failed, ") - ACE_TEXT ("caught unknown C++ exception\n"))); - } - rc = 1; - } - - if (rc == 0 || opts.force_) - pl_base->destroy_app_manager (am); - } - catch (const DAnCE::Deployment_Failure &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Teardown failed, exception: %C\n"), - ex.ex_.c_str ())); - } - return 1; - } - catch (const CORBA::Exception &ex) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Teardown failed, caught CORBA exception %C\n"), - ex._info ().c_str ())); - } - return 1; - } - catch (...) - { - if (!opts.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher::teardown_plan - ") - ACE_TEXT ("Teardown failed, ") - ACE_TEXT ("caught unknown C++ exception\n"))); - } - return 1; - } - - return rc; -} - -template <typename Manager> -typename Manager::_ptr_type -resolve_manager (ACE_Time_Value timeout, const ACE_TCHAR * ior, CORBA::ORB_ptr orb) -{ - ACE_Time_Value retry (0, 1000000 / 4); - - CORBA::Object_var obj; - typename Manager::_var_type tmp_em; - - ACE_CString last_error; - - do - { - try - { - obj = orb->string_to_object (ior); - - if (CORBA::is_nil (obj)) - { - ACE_OS::sleep (retry); - } - else - break; - } - catch (const CORBA::Exception &ex) - { - DANCE_ERROR (DANCE_LOG_WARNING, - (LM_ERROR, DLINFO, ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Caught CORBA Exception while resolving Manager object reference: %C\n"), - ex._info ().c_str ())); - last_error = ex._info (); - } - } while (ACE_OS::gettimeofday () < timeout); - - tmp_em = Manager::_narrow (obj); - - if (CORBA::is_nil (tmp_em.in ())) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Unable to resolve ") - ACE_TEXT ("Manager reference <%s>, %C\n"), - ior, - last_error.c_str ())); - return 0; - } - - bool non_existant (false); - - do { - try - { - non_existant = tmp_em->_non_existent (); - - if (!non_existant) - break; - ACE_OS::sleep (retry); - } - catch (const CORBA::Exception &ex) - { - DANCE_ERROR (DANCE_LOG_WARNING, - (LM_ERROR, DLINFO, ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Caught CORBA Exception while resolving Manager object reference: %C\n"), - ex._info ().c_str ())); - last_error = ex._info (); - } - } while (ACE_OS::gettimeofday () < timeout); - - if (non_existant) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_EMERGENCY, DLINFO, ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Unable to validate connection to Manager: %C\n"), - last_error.c_str ())); - return 0; - } - - return tmp_em._retn (); -} - -struct ORB_Destroyer -{ - ORB_Destroyer (CORBA::ORB_var &orb) : - orb_ (orb) - { - } - - ~ORB_Destroyer (void) - { - orb_->destroy (); - } - CORBA::ORB_var &orb_; -}; - -int -ACE_TMAIN (int argc, ACE_TCHAR *argv[]) -{ - DANCE_DISABLE_TRACE (); - - int retval = 0; - - Options options; - - try - { - CORBA::ORB_var orb = CORBA::ORB_init (argc, argv); - ORB_Destroyer safe_orb (orb); - - DAnCE::Logger_Service * dlf = - ACE_Dynamic_Service<DAnCE::Logger_Service>::instance ("DAnCE_Logger"); - - if (dlf) - { - dlf->init (argc, argv); - } - - if (!parse_args (argc, argv, options)) - { - return 1; - } - - - auto_ptr<DAnCE::Plan_Launcher_Base> pl_base (0); - - - Deployment::DeploymentPlan_var dp; - - DANCE_DEBUG (DANCE_LOG_MAJOR_EVENT, - (LM_DEBUG, DLINFO ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Parsing deployment plan\n"))); - if (options.cdr_plan_) - { - dp = DAnCE::Convert_Plan::read_cdr_plan (options.cdr_plan_); - if (!dp.ptr ()) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("PlanLauncher - ") - ACE_TEXT ("Error: Unable to read ") - ACE_TEXT ("in CDR plan\n"))); - } - return 1; - } - } - else if (options.xml_plan_) - { - dp = DAnCE::Convert_Plan::read_xml_plan (options.xml_plan_); - - if (!dp.ptr ()) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO - ACE_TEXT ("PlanLauncher - Error: ") - ACE_TEXT ("Unable to read in XML plan\n"))); - } - return 1; - } - } - - if (options.domain_file_) - { - ::DAnCE::Config_Handlers::XML_File_Intf file (options.domain_file_); - file.add_search_path (ACE_TEXT ("DANCE_ROOT"), ACE_TEXT ("/docs/schema/")); - ::Deployment::Domain *plan = file.release_domain (); - - if (!plan) - { - DANCE_ERROR (DANCE_LOG_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT("PlanLauncher - Error - ") - ACE_TEXT("Error: Processing file <%C>\n"), options.domain_file_)); - return false; - } - - DAnCE_Domain_Validator_i validator (orb); - validator.load_domain (*plan); - - ::DAnCE::Time_Value tv; - tv.seconds (options.domain_timeout_); - CORBA::StringSeq_var late_nodes; - - if (!validator.block_for_domain (tv, late_nodes.out ())) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO - ACE_TEXT ("PlanLauncher - Error: ") - ACE_TEXT ("Not all nodes in domain ready\n"))); - - for (CORBA::ULong i = 0; i < late_nodes->length (); ++i) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO - ACE_TEXT ("PlanLauncher - Error: ") - ACE_TEXT ("Node <%C> is not started\n"), - late_nodes[i].in ())); - } - return 1; - } - } - - ACE_Time_Value timeout (ACE_OS::gettimeofday () + ACE_Time_Value (options.em_timeout_)); - - if (options.em_ior_) - { - // Resolve ExecutionManager IOR for EM base deployment. - DAnCE::EM_Launcher *em_pl (0); - - - Deployment::ExecutionManager_var tmp_em = - resolve_manager<Deployment::ExecutionManager> (timeout, - options.em_ior_, - orb); - - if (CORBA::is_nil (tmp_em)) - { - DANCE_ERROR(DANCE_LOG_EMERGENCY, - (LM_ERROR, DLINFO - ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Unable to resolve EM object reference\n"))); - return 0; - } - - ACE_NEW_THROW_EX (em_pl, - DAnCE::EM_Launcher (orb.in (), - tmp_em.in ()), - CORBA::NO_MEMORY ()); - - pl_base.reset (em_pl); - } - else if (options.nm_ior_) - { - // Resolve NM IOR for NM based deployment. - DAnCE::NM_Launcher *nm_pl (0); - - CORBA::Object_var obj = orb->string_to_object (options.nm_ior_); - Deployment::NodeManager_var tmp_em = - Deployment::NodeManager::_narrow (obj); - - if (CORBA::is_nil (tmp_em.in ())) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Unable to resolve ") - ACE_TEXT ("NodeManager reference <%s>\n"), - options.nm_ior_)); - } - return 1; - } - - ACE_NEW_THROW_EX (nm_pl, - DAnCE::NM_Launcher (orb.in (), - tmp_em.in ()), - CORBA::NO_MEMORY ()); - - pl_base.reset (nm_pl); - } - else if (options.lm_ior_) - { - // Resolve NM IOR for NM based deployment. - DAnCE::LM_Launcher *lm_pl (0); - - CORBA::Object_var obj = orb->string_to_object (options.lm_ior_); - DAnCE::LocalityManager_var tmp_em = - DAnCE::LocalityManager::_narrow (obj); - - if (CORBA::is_nil (tmp_em.in ())) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher - ") - ACE_TEXT ("Unable to resolve ") - ACE_TEXT ("LocalityManager reference <%s>\n"), - options.lm_ior_)); - } - return 1; - } - - ACE_NEW_THROW_EX (lm_pl, - DAnCE::LM_Launcher (orb.in (), - tmp_em.in ()), - CORBA::NO_MEMORY ()); - - pl_base.reset (lm_pl); - } - - - - switch (options.mode_) - { - case Options::LAUNCH: - retval = launch_plan (options, pl_base.get (), dp, orb.in ()); - - break; - - case Options::TEARDOWN: - retval = teardown_plan (options, pl_base.get (), dp, orb.in ()); - break; - - default: - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("Plan_Launcher -") - ACE_TEXT ("Mode not yet supported\n"))); - } - break; - - }; - } - catch (const Deployment::PlanError &ex) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("PlanLauncher - ") - ACE_TEXT ("Error in plan: <%C>, <%C>\n"), - ex.name.in (), - ex.reason.in ())); - } - retval = -1; - } - catch (const DAnCE::Deployment_Failure& e) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ("PlanLauncher - ") - ACE_TEXT ("Error: %C.\n"), e.ex_.c_str())); - } - retval = 1; - } - catch (const CORBA::Exception& ex) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, (LM_ERROR, DLINFO ACE_TEXT ( "PlanLauncher - ") - ACE_TEXT ("Error: %C\n"), ex._info ().c_str ())); - } - retval = 1; - } - catch (...) - { - if (!options.quiet_) - { - DANCE_ERROR (DANCE_LOG_EMERGENCY, - (LM_ERROR, ACE_TEXT ("PlanLauncher - ") - ACE_TEXT ("Error: Unknown exception.\n"))); - } - retval = 1; - } - - return retval; -} |