1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/**
* @file simple_nm_launcher.cpp
* @author William R. Otte <wotte@dre.vanderbilt.edu>
* $Id$
* Launches then immediately tears down a plan.
*/
#include "ace/OS_NS_unistd.h"
#include "tao/ORB.h"
#include "DAnCE/Logger/Logger_Service.h"
#include "DAnCE/Logger/Log_Macros.h"
#include "Deployment/Deployment_NodeApplicationC.h"
#include "Deployment/Deployment_NodeManagerC.h"
#include "Deployment/Deployment_DeploymentPlanC.h"
#include "Config_Handlers/XML_File_Intf.h"
int usage ()
{
ACE_ERROR ((LM_ERROR, "simple_nm_launcher <nm_url> <plan>\n"));
return -1;
}
#include <iostream>
int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
DANCE_DISABLE_TRACE ();
DAnCE::Logger_Service
* dlf = ACE_Dynamic_Service<DAnCE::Logger_Service>::instance ("DAnCE_Logger");
if (dlf)
{
dlf->init (argc, argv);
}
CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
if (argc != 3)
return usage ();
try
{
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: parsing XML\n")));
// Parse plan
CIAO::Config_Handlers::XML_File_Intf xml (argv[2]);
xml.add_search_path (ACE_TEXT ("DANCE_ROOT"), ACE_TEXT ("/docs/schema/"));
xml.add_search_path (ACE_TEXT ("CIAO_ROOT"), ACE_TEXT ("/docs/schema/"));
auto_ptr< ::Deployment::DeploymentPlan> plan (xml.release_plan ());
if (plan.get () == 0)
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** error parsing XML document\n")));
throw 1;
}
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: resolving node manager reference.\n")));
CORBA::Object_var obj = orb->string_to_object (argv[1]);
Deployment::NodeManager_var nm = Deployment::NodeManager::_narrow (obj.in ());
if (CORBA::is_nil (nm.in ()))
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** simple_nm_launcher: NodeManager reference is nil.")));
throw 1;
}
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: calling prepareplan.\n")));
Deployment::NodeApplicationManager_var nam = nm->preparePlan (*plan,
Deployment::ResourceCommitmentManager::_nil ());
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: calling startLaunch\n")));
Deployment::Connections_var conns;
Deployment::Properties props;
Deployment::Application_var app = nam->startLaunch (props, conns.out ());
Deployment::NodeApplication_var na = Deployment::NodeApplication::_narrow (app.in ());
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: calling finishLaunch\n")));
na->finishLaunch (conns.in (), false);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: calling start\n")));
na->start ();
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: start finished, sleeping 5 seconds.\n")));
ACE_OS::sleep (5);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: waking up from sleep, calling destroyApplication\n")));
nam->destroyApplication (na.in ());
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: calling destroyManager\n")));
nm->destroyManager (nam.in ());
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("*** simple_nm_launcher: destroyManager completed.\n")));
orb->destroy ();
}
catch (Deployment::StopError &ex)
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** Caught StopError exception with name %C and reason %C\n"),
ex.name.in (), ex.reason.in ()));
return -1;
}
catch (Deployment::StartError &ex)
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** Caught StartError exception with name %C and reason %C\n"),
ex.name.in (), ex.reason.in ()));
return -1;
}
catch (CORBA::Exception &ex)
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** Caught CORBA exception: %C\n"),
ex._info ().c_str ()));
return -1;
}
catch (...)
{
orb->destroy ();
ACE_ERROR ((LM_ERROR,ACE_TEXT ("*** Caught unknown exception\n")));
return -1;
}
return 0;
}
|
