summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp')
-rw-r--r--TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp b/TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp
index e24655ea671..acba6e6aa51 100644
--- a/TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp
+++ b/TAO/orbsvcs/examples/RtEC/test_driver/ECConfig.cpp
@@ -5,7 +5,7 @@
#include "ECConfig.h"
#include "Consumer.h"
-#include "TimeoutConsumer.h"
+#include "Supplier.h"
#include <sstream> //for ostringstream
@@ -255,7 +255,7 @@ ECConfig<SCHED_STRAT>::run (void)
}
// Block waiting for consumers to finish
- //when can acquire write lock, all TimeoutConsumers are finished
+ //when can acquire write lock, all Suppliers are finished
ret = this->test_done->acquire_write();
if (ret == -1)
{
@@ -264,7 +264,7 @@ ECConfig<SCHED_STRAT>::run (void)
return 1;
}
- //all TimeoutConsumers done, so stop EC and ORB
+ //all Suppliers done, so stop EC and ORB
//Shutdown EC
this->reset();
@@ -348,7 +348,7 @@ ECConfig<SCHED_STRAT>::connect_suppliers (ACE_ENV_SINGLE_ARG_DECL)
RtecEventComm::EventSet event(1);
event.length(1);
- ACE_DEBUG((LM_DEBUG,"TimeoutConsumers to connect: %d\n",this->suppliers.size()));
+ ACE_DEBUG((LM_DEBUG,"Suppliers to connect: %d\n",this->suppliers.size()));
//this->suppliers already has correct size
size_t supp_idx = 0;
for (size_t i=0; i<this->testcfgs.size(); ++i)
@@ -356,16 +356,16 @@ ECConfig<SCHED_STRAT>::connect_suppliers (ACE_ENV_SINGLE_ARG_DECL)
if (this->testcfgs[i]->comptype == SOURCE)
{
ACE_ASSERT(supp_idx < this->suppliers.size());
- ACE_NEW (this->suppliers[supp_idx], TimeoutConsumer ());
+ ACE_NEW (this->suppliers[supp_idx], Supplier ());
event[0].header.type = ACE_ES_EVENT_UNDEFINED+this->testcfgs[i]->type;
event[0].header.source = supp_idx; //supplier_id
event[0].header.ttl = 1;
std::ostringstream entry_prefix;
- entry_prefix << "TimeoutConsumer " << supp_idx;
+ entry_prefix << "Supplier " << supp_idx;
- ACE_DEBUG((LM_DEBUG,"TimeoutConsumer.connect() for %s\n",entry_prefix.str().c_str()));
+ ACE_DEBUG((LM_DEBUG,"Supplier.connect() for %s\n",entry_prefix.str().c_str()));
this->suppliers[supp_idx]->connect (this->test_done,
this->scheduler.in(),
entry_prefix.str().c_str(),