diff options
author | jai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-05-06 01:33:08 +0000 |
---|---|---|
committer | jai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-05-06 01:33:08 +0000 |
commit | f9cb1cf4b2df488f81c452444f994a3d7ed8c880 (patch) | |
tree | 2c73d240ee7b5069e64e92fb41bed10eacbb53d6 | |
parent | 2f66ff05fe9f0256fc0ab414224928e55e1ea0b9 (diff) | |
download | ATCD-f9cb1cf4b2df488f81c452444f994a3d7ed8c880.tar.gz |
mods
3 files changed, 16 insertions, 12 deletions
diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/Client_Timer_Handler.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/Client_Timer_Handler.cpp index 4ada76ec746..52bdfb4121f 100644 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/Client_Timer_Handler.cpp +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/Client_Timer_Handler.cpp @@ -67,7 +67,7 @@ Client_Timer_Handler::handle_timeout (const ACE_Time_Value &, // we have to do some profiling first to see how we can achieve // the correct execution time. - server_processing_time = worker_->run_task (execution_time_.msec ()); + // server_processing_time = worker_->run_task (execution_time_.msec ()); timer_.stop (); diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/client-rt.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/client-rt.cpp index 7629e1690b9..90081cd6515 100755 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/client-rt.cpp +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/client-rt.cpp @@ -346,16 +346,16 @@ int max_throughput (DeCoRAM::Worker_ptr test, RTCORBA::Current_ptr current, RTCORBA::PriorityMapping &priority_mapping, - CORBA::ULong &max_rate) + CORBA::ULong &max_rate, CORBA::Short corba_priority) { CORBA::ULong calls_made = 0; - CORBA::Short CORBA_priority = 0; + CORBA::Short CORBA_priority = corba_priority; CORBA::Short native_priority = 0; try { - CORBA_priority = - current->the_priority (); + //CORBA_priority = + //current->the_priority (); CORBA::Boolean result = priority_mapping.to_native (CORBA_priority, @@ -635,7 +635,7 @@ Paced_Worker::svc (void) try { ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); - size_t terminate_count = this->history_.max_samples () / 2; + size_t terminate_count = this->history_.max_samples (); int result = this->setup (); @@ -673,18 +673,18 @@ Paced_Worker::svc (void) if (i == terminate_count) { - // sample_vector[count++] = 0; - this->test_->method (work, prime_number, 1); + sample_vector[count++] = 0; + this->test_->run_method (work, prime_number, 1); } else { - this->test_->method (work, prime_number, 0); + this->test_->run_method (work, prime_number, 0); } ACE_hrtime_t time_after_call = ACE_OS::gethrtime (); this->history_.sample (time_after_call - time_before_call); - // sample_vector[count++] = ((time_after_call - time_before_call) / gsf); + sample_vector[count++] = ((time_after_call - time_before_call) / gsf); if (time_after_call > deadline_for_current_call) { @@ -804,12 +804,15 @@ Task::svc (void) synchronizers.number_of_workers_ = rates.size (); + CORBA::Short corba_priority = + get_implicit_thread_CORBA_priority (this->orb_.in()); + CORBA::ULong max_rate = 0; result = max_throughput (server1.in (), current.in (), priority_mapping, - max_rate); + max_rate), corba_priority; if (result != 0) return result; diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/server-rt.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/server-rt.cpp index 6825729e113..e3e5fca5d95 100755 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/server-rt.cpp +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/RTCORBA/ClientServer/server-rt.cpp @@ -228,7 +228,8 @@ Task::svc (void) RTCORBA::Current::_narrow (object.in ()); default_thread_priority = - current->the_priority (); + // current->the_priority (); + get_implicit_thread_CORBA_priority (this->orb_.in ()); int result = 0; CORBA::ULong stacksize = 0; |