diff options
Diffstat (limited to 'litmus/sched_edf_hsb.c')
-rw-r--r-- | litmus/sched_edf_hsb.c | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/litmus/sched_edf_hsb.c b/litmus/sched_edf_hsb.c index 0a1316abdf5c..adbcc2551280 100644 --- a/litmus/sched_edf_hsb.c +++ b/litmus/sched_edf_hsb.c | |||
@@ -593,7 +593,7 @@ static void requeue_server(server_t *server, lt_t now) | |||
593 | hrt_server = container_of(server, hrt_server_t, server); | 593 | hrt_server = container_of(server, hrt_server_t, server); |
594 | hrt_server->ready = 1; | 594 | hrt_server->ready = 1; |
595 | hrt_server->no_slack = 0; | 595 | hrt_server->no_slack = 0; |
596 | sched_trace_action(task, SERVER_RELEASED_ACTION); | 596 | sched_trace_action(NULL, SERVER_RELEASED_ACTION); |
597 | } else if (server->type == S_BE) { | 597 | } else if (server->type == S_BE) { |
598 | TRACE_SERVER_SUB(server, "BE added to ready"); | 598 | TRACE_SERVER_SUB(server, "BE added to ready"); |
599 | bheap_insert(server_order, &be_ready_servers, server->hn); | 599 | bheap_insert(server_order, &be_ready_servers, server->hn); |
@@ -612,7 +612,7 @@ static void reclaim_slack(server_t *slack) | |||
612 | server_t *donator = server_slack(slack); | 612 | server_t *donator = server_slack(slack); |
613 | 613 | ||
614 | /* SRT servers do not ever reclaim slack */ | 614 | /* SRT servers do not ever reclaim slack */ |
615 | sched_trace_action(NULL, SLACK_RECLAIMED_ACTION); | 615 | sched_trace_action(NULL, SLACK_RECLAIM_ACTION); |
616 | 616 | ||
617 | exec = slack->wcet - slack->budget; | 617 | exec = slack->wcet - slack->budget; |
618 | TRACE_SERVER_SUB(donator, "reclaiming %llu slack", TIME(exec)); | 618 | TRACE_SERVER_SUB(donator, "reclaiming %llu slack", TIME(exec)); |
@@ -694,7 +694,7 @@ static noinline void unlink_server(cpu_entry_t *entry, int requeue) | |||
694 | 694 | ||
695 | if (server->type == S_SLACK && server->deadline) { | 695 | if (server->type == S_SLACK && server->deadline) { |
696 | add_slack(server); | 696 | add_slack(server); |
697 | sched_trace_action(entry->linked, SLACK_STOPPED_ACTION); | 697 | sched_trace_action(entry->linked, SLACK_STOP_ACTION); |
698 | 698 | ||
699 | /* Donator needs to absorb slack execution time */ | 699 | /* Donator needs to absorb slack execution time */ |
700 | reclaim_slack(server); | 700 | reclaim_slack(server); |
@@ -969,7 +969,6 @@ static server_t* next_eligible_slack_server(void) | |||
969 | */ | 969 | */ |
970 | static struct task_struct* next_eligible_slack(void) | 970 | static struct task_struct* next_eligible_slack(void) |
971 | { | 971 | { |
972 | lt_t now = litmus_clock(); | ||
973 | struct task_struct *next = get_candidate(slack_candidates.next); | 972 | struct task_struct *next = get_candidate(slack_candidates.next); |
974 | 973 | ||
975 | if (!next) { | 974 | if (!next) { |
@@ -1501,7 +1500,6 @@ static void check_for_hrt_preempt(cpu_entry_t *entry) | |||
1501 | { | 1500 | { |
1502 | hrt_server_t *hrt_server = &entry->hrt_server; | 1501 | hrt_server_t *hrt_server = &entry->hrt_server; |
1503 | struct task_struct *next_hrt = next_eligible_hrt(hrt_server); | 1502 | struct task_struct *next_hrt = next_eligible_hrt(hrt_server); |
1504 | struct task_struct *curr = entry->linked; | ||
1505 | 1503 | ||
1506 | if (next_hrt && | 1504 | if (next_hrt && |
1507 | (!entry->linked || !is_hrt(entry->linked) || | 1505 | (!entry->linked || !is_hrt(entry->linked) || |
@@ -1510,11 +1508,6 @@ static void check_for_hrt_preempt(cpu_entry_t *entry) | |||
1510 | 1508 | ||
1511 | preempt(entry, next_hrt, &hrt_server->server, 1); | 1509 | preempt(entry, next_hrt, &hrt_server->server, 1); |
1512 | 1510 | ||
1513 | /* We might have just kicked off something. Check to see if it | ||
1514 | * preempts anything. | ||
1515 | */ | ||
1516 | /* if (curr && !is_hrt(curr)) */ | ||
1517 | /* check_for_global_preempt(); */ | ||
1518 | } else { | 1511 | } else { |
1519 | TRACE_SERVER_SUB(&hrt_server->server, "not HRT preempting"); | 1512 | TRACE_SERVER_SUB(&hrt_server->server, "not HRT preempting"); |
1520 | } | 1513 | } |
@@ -1715,7 +1708,6 @@ static void job_completion(cpu_entry_t *entry, struct task_struct* task) | |||
1715 | */ | 1708 | */ |
1716 | static void server_completed(server_t *server, struct task_struct *task) | 1709 | static void server_completed(server_t *server, struct task_struct *task) |
1717 | { | 1710 | { |
1718 | lt_t now = litmus_clock(); | ||
1719 | hrt_server_t *hrt_server; | 1711 | hrt_server_t *hrt_server; |
1720 | cpu_entry_t *entry = task_linked_entry(task); | 1712 | cpu_entry_t *entry = task_linked_entry(task); |
1721 | 1713 | ||