C++: Properly consider priority ceilings in DPCP bound

The bound should not reflect requests executed by agents that can be preempted.

1 files changed, 20 insertions, 0 deletions

diff --git a/native/src/sharedres.cpp b/native/src/sharedres.cpp
index a91bfdf..5c8acee 100644
--- a/native/src/sharedres.cpp
+++ b/native/src/sharedres.cpp
@@ -225,6 +225,26 @@ void sort_by_request_length(ClusterResources& resources)
         apply_foreach(resources, sort_by_request_length);
 }
 
+void determine_priority_ceilings(const Resources& resources,
+                                        PriorityCeilings& ceilings)
+{
+        ceilings.reserve(resources.size());
+
+        foreach(resources, it)
+        {
+                unsigned int ceiling = UINT_MAX;
+                const ContentionSet& cs = *it;
+
+                foreach(cs, jt)
+                {
+                        const RequestBound* req = *jt;
+                        ceiling = std::min(ceiling, req->get_task()->get_priority());
+                }
+
+                ceilings.push_back(ceiling);
+        }
+}
+
 typedef std::vector<TaskContention> ClusterContention;
 
 typedef std::vector<ContentionSet> TaskContention;