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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
|
// $Id$
/**
* @file CmpClient.cpp
*
* @brief This file contains a client of TargetManager.
*
* It picks up the TM ior from the Targetmanager.ior file
* present in the current directory, and makes the calls on the
* TM to getAllResources and getAvailable resources
*/
#include "ciao/Deployment_DataC.h"
#include "DAnCE/TargetManager/TargetManagerImplC.h"
#include "ace/streams.h"
#include "Config_Handlers/DnC_Dump.h"
void write_to_file (::Deployment::Domain domain);
int main (int argc, char* argv[])
{
try {
// First initialize the ORB, that will remove some arguments...
CORBA::ORB_var orb =
CORBA::ORB_init (argc, argv,
"" /* the ORB name, it can be anything! */);
// There must be at least two arguments, the first is the factory
// name, the rest are the names of the stock symbols we want to
// get quotes for.
if (argc < 2) {
cerr << "Usage: " << argv[0]
<< " Factory_IOR ..." << endl;
return 1;
}
// Use the first argument to create the factory object reference,
// in real applications we use the naming service, but let's do
// the easy part first!
CORBA::Object_var factory_object =
orb->string_to_object (argv[1]);
// Now downcast the object reference to the appropriate type
CIAO::TargetManagerImpl_var targetCmp =
CIAO::TargetManagerImpl::_narrow (factory_object.in ());
// Now get the facet reference from the target Manager Component
ACE_DEBUG((LM_DEBUG, "Making a Call to provide_targetMgr ()\n"));
Deployment::TargetManager_ptr targetI = targetCmp->provide_targetMgr ();
// Now make calls on the Target Manager facet
try
{
Deployment::Domain_var domainV = targetI->getAllResources ();
ACE_DEBUG ((LM_DEBUG , "\n\nGetAllResources Returned \n"));
::Deployment::DnC_Dump::dump (domainV);
}
catch(CORBA::NO_IMPLEMENT &)
{
ACE_DEBUG((LM_DEBUG ,"Error:TargetManager:CORBA::NO_IMPLEMENT thrown\n"));
}
catch(CORBA::Exception &)
{
ACE_DEBUG((LM_DEBUG ,"Error:TargetManager:CORBA Generic Exception \n"));
ACE_DEBUG((LM_DEBUG ,"Error:TargetManager:Exception in TargetManager call\n"));
}
// make a call to the commit resources .....
Deployment::DeploymentPlan plan;
plan.instance.length (2);
::Deployment::InstanceDeploymentDescription instance_;
instance_.node = CORBA::string_dup ("foil");
instance_.deployedResource.length (1);
instance_.deployedResource[0].requirementName =
CORBA::string_dup ("Processor");
instance_.deployedResource[0].resourceName =
CORBA::string_dup ("CPULoad");
instance_.deployedResource[0].property.length (1);
instance_.deployedResource[0].property[0].name =
CORBA::string_dup ("LoadAverage");
CORBA::Long d = 20;
instance_.deployedResource[0].property[0].value <<= d;
plan.instance[0] = instance_;
instance_.node = CORBA::string_dup ("blade30");
instance_.deployedResource.length (1);
instance_.deployedResource[0].requirementName =
CORBA::string_dup ("Processor");
instance_.deployedResource[0].resourceName =
CORBA::string_dup ("CPULoad");
instance_.deployedResource[0].property.length (1);
instance_.deployedResource[0].property[0].name =
CORBA::string_dup ("LoadAverage");
d = 50;
instance_.deployedResource[0].property[0].value <<= d;
plan.instance[1] = instance_;
bool resource_available = true;
try
{
targetI->commitResources(plan);
ACE_DEBUG ((LM_DEBUG , "\n\ncommitResources Returned \n"));
}
catch(CORBA::NO_IMPLEMENT &)
{
cerr << "Error:TargetManager:CORBA::NO_IMPLEMENT thrown" << endl;
}
catch (Deployment::ResourceNotAvailable & e)
{
resource_available = 0;
cout << "TargetManager commitResources ResourceNotAvailable Exception" <<endl;
ACE_DEBUG ((LM_DEBUG ,
"ResourceNotAvailable\n name=[%s]\n elementName=[%s]\n resourceName=[%s]\n \
resourceType= [%s]\n propertyName=[%s]\n",
e.name.in (),
e.elementName.in (),
e.resourceName.in (),
e.resourceType.in (),
e.propertyName.in ()));
}
catch(CORBA::Exception & ex)
{
cout << "Error:TargetManager:commitResources Exception" <<endl;
cout << "Error:TargetManager:CORBA Generic Exception " << endl;
cerr << "Error:TargetManager:Exception in TargetManager call" << ex << endl;
}
// Make a call to release resources , if resource < 0
try
{
if (!resource_available)
{
targetI->releaseResources(plan);
ACE_DEBUG ((LM_DEBUG , "\n\nreleaseResources Returned \n"));
}
}
catch(CORBA::NO_IMPLEMENT &)
{
cerr << "Error:TargetManager:CORBA::NO_IMPLEMENT thrown" << endl;
}
catch (Deployment::ResourceNotAvailable &)
{
cout << "Error:TargetManager releaseResources ResourceNotAvailable Exception" <<endl;
}
catch(CORBA::Exception & ex)
{
cout << "Error:TargetManager:releaseResources Exception" <<endl;
cout << "Error:TargetManager:CORBA Generic Exception " << endl;
cerr << "Error:TargetManager:Exception in TargetManager call" << ex << endl;
}
// Here make a call on the TM with update domain and node deletion
::Deployment::Domain updated;
updated.node.length (1);
updated.node[0].name = CORBA::string_dup (argv[2]);
::CORBA::StringSeq elements;
elements.length (0);
bool Add = true;
Add = ACE_OS::atoi (argv[3]);
if (Add)
{
try
{
targetI->updateDomain (elements , updated, ::Deployment::Add);
}
catch(CORBA::NO_IMPLEMENT &)
{
cerr << "Error:TargetManager:CORBA::NO_IMPLEMENT thrown" << endl;
}
catch(CORBA::Exception & ex)
{
cout << "Error:TargetManager:CORBA Generic Exception " << endl;
cerr << "Error:TargetManager:Exception in UpdateDomain call" << ex << endl;
}
}
else
{
try
{
targetI->updateDomain (elements , updated, ::Deployment::Delete);
}
catch(CORBA::NO_IMPLEMENT &)
{
cerr << "Error:TargetManager:CORBA::NO_IMPLEMENT thrown" << endl;
}
catch(CORBA::Exception & ex)
{
cout << "Error:TargetManager:CORBA Generic Exception " << endl;
cerr << "Error:TargetManager:Exception in UpdateDomain call" << ex << endl;
}
}
// Now make a call of getAvailableResources on the TargetManager ...
try
{
Deployment::Domain_var domainV = targetI->getAvailableResources();
// here write things to file ...
write_to_file (domainV.in());
ACE_DEBUG ((LM_DEBUG , "\n\nGetAvailableResources Returned \n"));
::Deployment::DnC_Dump::dump (domainV);
}
catch(CORBA::NO_IMPLEMENT &)
{
cerr << "Error:TargetManager:CORBA::NO_IMPLEMENT thrown" << endl;
}
catch(CORBA::Exception & ex)
{
cout << "Error:TargetManager:CORBA Generic Exception " << endl;
cerr << "Error:TargetManager:Exception in TargetManager call" << ex << endl;
}
// Finally destroy the ORB
orb->destroy ();
}
catch (CORBA::Exception & ex) {
cerr << "Error:TargetManager:CORBA exception raised!" << ex << endl;
}
return 0;
}
void write_to_file (::Deployment::Domain domain)
{
for (size_t i = 0;i < domain.node.length ();i++)
{
std::ofstream out (domain.node[i].name.in ());
// write in the node usage ...
for (size_t j = 0;j < domain.node[i].resource.length ();j++)
{
if (!strcmp (domain.node[i].resource[j].name.in (), "Processor"))
{
CORBA::Double node_cpu;
domain.node[i].resource[j].property[0].value >>= node_cpu;
out << node_cpu << std::endl;
}
if (!strcmp (domain.node[i].resource[j].name.in (), "NA_Monitor"))
{
std::string file_name = "NA_";
file_name += domain.node[i].name.in ();
std::ofstream na_out (file_name.c_str ());
CORBA::Double na_node_cpu;
domain.node[i].resource[j].property[0].value >>= na_node_cpu;
na_out << na_node_cpu << std::endl;
na_out.close ();
}
}
out.close ();
}
}
|
