MPCP: export gcs response-time bounds

This will be used by the new LP-based MPCP analysis.

Also, report local blocking to Python and add a clarifying comment.

2 files changed, 23 insertions, 8 deletions

diff --git a/native/include/mpcp.h b/native/include/mpcp.h
new file mode 100644
index 0000000..75f77b1
--- /dev/null
+++ b/native/include/mpcp.h
@@ -0,0 +1,11 @@
+#ifndef _MPCP_H_
+#define _MPCP_H_
+
+typedef std::vector<unsigned long> ResponseTimes;
+typedef std::vector<ResponseTimes> TaskResponseTimes;
+typedef std::vector<TaskResponseTimes> ClusterResponseTimes;
+
+void determine_gcs_response_times(const Clusters& clusters,
+                                  const PriorityCeilings& ceilings,
+                                  ClusterResponseTimes& times);
+#endif
diff --git a/native/src/blocking/mpcp.cpp b/native/src/blocking/mpcp.cpp
index d210595..67d62ac 100644
--- a/native/src/blocking/mpcp.cpp
+++ b/native/src/blocking/mpcp.cpp
@@ -4,12 +4,9 @@
 #include "stl-helper.h"
 #include "math-helper.h"
 
-// ***************************  MPCP ******************************************
-
+# include "mpcp.h"
 
-typedef std::vector<unsigned long> ResponseTimes;
-typedef std::vector<ResponseTimes> TaskResponseTimes;
-typedef std::vector<TaskResponseTimes> ClusterResponseTimes;
+// ***************************  MPCP ******************************************
 
 static unsigned long get_max_gcs_length(const TaskInfo* tsk,
                                         const PriorityCeilings& ceilings,
@@ -69,9 +66,9 @@ static void determine_gcs_response_times(const Cluster& cluster,
         }
 }
 
-static void determine_gcs_response_times(const Clusters& clusters,
-                                         const PriorityCeilings& ceilings,
-                                         ClusterResponseTimes& times)
+void determine_gcs_response_times(const Clusters& clusters,
+                                  const PriorityCeilings& ceilings,
+                                  ClusterResponseTimes& times)
 {
         times.reserve(clusters.size());
         foreach(clusters, it)
@@ -160,6 +157,11 @@ static unsigned long  mpcp_remote_blocking(unsigned int res_id,
 
         for (i = 0; i < clusters.size(); i++)
         {
+                // Note that this also includes the local cluster.
+                // This is indeed correct (and matches LNR:09): we
+                // are interested in computing the *response time*,
+                // which is also affected by local higher-priority tasks.
+                // The response-time is used as a bound on blocking.
                 blocking += mpcp_remote_blocking(res_id, interval,
                                                  tsk, clusters[i], times[i],
                                                  max_lower);
@@ -289,6 +291,8 @@ BlockingBounds* mpcp_bounds(const ResourceSharingInfo& info,
                 Interference inf;
                 inf.total_length = remote;
                 results.set_remote_blocking(i, inf);
+                inf.total_length = local;
+                results.set_local_blocking(i, inf);
         }
 
         return _results;