BE servers will periodically donate slack when there are no BE tasks in the system.

1 files changed, 5 insertions, 6 deletions

diff --git a/litmus/sched_edf_hsb.c b/litmus/sched_edf_hsb.c
index fc533502f5ac..7fd3d545234d 100644
--- a/litmus/sched_edf_hsb.c
+++ b/litmus/sched_edf_hsb.c
@@ -379,11 +379,8 @@ static void check_slack_candidate(struct task_struct *task)
         if (is_srt(task) &&
             /* The task has been synchronously released */
             task_job_no(task) > 2 &&
-            /* The SRT task is not ahead of its server */
-            task_srt_server(task)->job_no >= task_job_no(task) &&
-            /* The task didn't just complete */
-            !(get_rt_flags(task) == RT_F_SLEEP && task_srt_server(task)->job_no ==
-              task_job_no(task)) &&
+            /* The SRT task is behind its server */
+            task_srt_server(task)->job_no > task_job_no(task) &&
             /* The task hasn't already been added to the list */
             !head_in_list(&task_data(task)->candidate_list)) {
 
@@ -1129,7 +1126,7 @@ static noinline server_t* next_eligible_be_server(void)
                 catchup_server(be_server, now);
                 bheap_insert(server_order, &be_ready_servers,
                              be_server->hn);
-
+                check_donate_slack(be_server, NULL);
                 be_server = next_be_server();
                 TRACE_SERVER_SUB(be_server, "catching up BE server");
                 sched_trace_action(NULL, SERVER_RELEASED_ACTION); /* Release */
@@ -1143,6 +1140,7 @@ static noinline server_t* next_eligible_be_server(void)
                 TRACE_SERVER_SUB(be_server, "dead: %llu, rel: %llu, budget: %llu",
                                  be_server->deadline, be_server->release,
                                  be_server->budget);
+
         }
 
         return be_server;
@@ -1822,6 +1820,7 @@ static void servers_released(struct list_head *servers)
                         TRACE_SERVER_SUB(server, "inserting BE server");
                         bheap_insert(server_order, &be_ready_servers,
                                      server->hn);
+                        check_donate_slack(server);
                 } else { /* HRT server */
                         hrt_server_released(server);
                 }