diff options
author | wolff1 <wolff1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-04-30 22:27:14 +0000 |
---|---|---|
committer | wolff1 <wolff1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2009-04-30 22:27:14 +0000 |
commit | a4ed489d6c1dbce94fd679a9060855b116ad3754 (patch) | |
tree | 93a4531f2022656e3f5a8090eaaedec77e7a6607 | |
parent | d4246be678873221e7ffe08d59084e6759b0650c (diff) | |
download | ATCD-a4ed489d6c1dbce94fd679a9060855b116ad3754.tar.gz |
added max check in accumulation
-rw-r--r-- | TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/Forward_Ranking_Scheduler.cpp | 2 | ||||
-rw-r--r-- | TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/schedulability_check.cpp | 14 |
2 files changed, 10 insertions, 6 deletions
diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/Forward_Ranking_Scheduler.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/Forward_Ranking_Scheduler.cpp index 72427628806..397367e4352 100644 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/Forward_Ranking_Scheduler.cpp +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/Forward_Ranking_Scheduler.cpp @@ -100,7 +100,7 @@ Forward_Ranking_Scheduler::update_schedule (const Task & task, void Forward_Ranking_Scheduler::update_failure_map (const Task & task, - const Processor & processor) + const Processor & /* processor */) { PROCESSOR_SET proc_dependencies; diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/schedulability_check.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/schedulability_check.cpp index 0cbe63bb783..cd57eda5114 100644 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/schedulability_check.cpp +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/DeCoRAM/src/schedulability_check.cpp @@ -68,15 +68,19 @@ public: double operator () (double previous, const SCHEDULE::value_type & entry) { + if (previous == .0) + return .0; + PROCESSOR_SETS scenarios = this->calculate_failure_scenarions (entry.first, max_rank_); - return std::accumulate (scenarios.begin (), - scenarios.end (), - -1.0, - FailureAwareWCRT (entry.second, - replica_groups_)); + return std::max(std::accumulate (scenarios.begin (), + scenarios.end (), + -1.0, + FailureAwareWCRT (entry.second, + replica_groups_)), + previous); } private: |