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
|
// $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 "Deployment_DataC.h"
#include "TargetManagerC.h"
#include "ace/streams.h"
#include "Config_Handlers/DnC_Dump.h"
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 (1);
::Deployment::InstanceDeploymentDescription instance_;
instance_.node = CORBA::string_dup ("Delta");
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::Double d = 20;
instance_.deployedResource[0].property[0].value <<= d;
plan.instance[0] = instance_;
bool resource_available = 1;
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 == 0)
{
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 & e)
{
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;
}
// Now make a call of getAvailableResources on the TargetManager ...
try
{
Deployment::Domain_var domainV = targetI->getAvailableResources();
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;
}
|
