summaryrefslogtreecommitdiff
path: root/CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp')
-rw-r--r--CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp39
1 files changed, 6 insertions, 33 deletions
diff --git a/CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp b/CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp
index 5279508d584..e49f1e5535d 100644
--- a/CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp
+++ b/CIAO/DAnCE/NodeManager/NM_Monitor_Impl.cpp
@@ -53,7 +53,7 @@ void Onl_Monitor_NM_Monitor_i::monitor_app_QoS (
{
// ACE_DEBUG ((LM_DEBUG, "\t\nInside the monitor_app_QoS\n"));
- for (CORBA::ULong i;i < plans.length ();i++)
+ for (CORBA::ULong i = 0;i < plans.length ();i++)
{
::Deployment::DeploymentPlan plan = plans[i];
auto_ptr<Deployment::Domain> domain =
@@ -65,9 +65,9 @@ void Onl_Monitor_NM_Monitor_i::monitor_app_QoS (
key += domain->node[0].name.in ();
ACE_DEBUG ((LM_DEBUG, "The key is %s\n", key.c_str ()));
-
+
CORBA::Object_var obj;
-
+
try {
obj = node_manager_->get_NAM (key);
}
@@ -76,7 +76,7 @@ void Onl_Monitor_NM_Monitor_i::monitor_app_QoS (
ex._tao_print_exception ("(%P|%t) NM_Monitor_i::monitor_app_QoS ()\t\n");
ACE_DEBUG ((LM_DEBUG, "TM_DAEMON::Does not have a Component in this Node"));
continue;
- }
+ }
try {
Deployment::NodeApplicationManager_var nam =
@@ -107,45 +107,18 @@ void Onl_Monitor_NM_Monitor_i::monitor_app_QoS (
::Deployment::Domain * Onl_Monitor_NM_Monitor_i::get_resource_data (
void)
{
- // Add your implementation here
-
// ACE_DEBUG ((LM_DEBUG, "Inside the get_resource_data\n"));
- Deployment::Domain_var domainv;
-
- // time stamp the call to measure overhead of monitoring ...
-
- // ACE_High_Res_Timer time;
- //time.start ();
-
- domainv = this->controller_->update_data_for_TM ();
+ Deployment::Domain_var domainv = this->controller_->update_data_for_TM ();
// now get the qos data from each NAM
domainv->node[0].qos_seq.length (this->qos_monitor_seq_.size ());
for (unsigned int i = 0;i < qos_monitor_seq_.size ();i++)
{
- ::Deployment::QoSSpecifications_var qos_seq =
+ ::Deployment::QoSSpecifications_var qos_seq =
this->qos_monitor_seq_[i]->get_app_QoS ();
-
-
domainv->node[0].qos_seq[i] = (*qos_seq)[0];
}
-
- // ACE_Time_Value tv;
- //time.elapsed_time (tv);
-
- //ACE_hrtime_t tm;
- //time.elapsed_microseconds (tm);
-
- //std::string file_prox = domainv->node[0].name.in ();
-
- //file_prox += "_Tprox";
-
- //std::ofstream out (file_prox.c_str (), ios::app);
- //out << tv.msec () << std::endl;
- //out << tm << std::endl;
- //out.close ();
-
return domainv._retn ();
}