------------------------------------------------------------------------------ ------------------------------------------------------------------------------ -- Cheddar is a GNU GPL real-time scheduling analysis tool. -- This program provides services to automatically check schedulability and -- other performance criteria of real-time architecture models. -- -- Copyright (C) 2002-2020, Frank Singhoff, Alain Plantec, Jerome Legrand, -- Hai Nam Tran, Stephane Rubini -- -- The Cheddar project was started in 2002 by -- Frank Singhoff, Lab-STICC UMR 6285, Université de Bretagne Occidentale -- -- Cheddar has been published in the "Agence de Protection des Programmes/France" in 2008. -- Since 2008, Ellidiss technologies also contributes to the development of -- Cheddar and provides industrial support. -- -- The full list of contributors and sponsors can be found in AUTHORS.txt and SPONSORS.txt -- -- This program is free software; you can redistribute it and/or modify -- it under the terms of the GNU General Public License as published by -- the Free Software Foundation; either version 2 of the License, or -- (at your option) any later version. -- -- This program is distributed in the hope that it will be useful, -- but WITHOUT ANY WARRANTY; without even the implied warranty of -- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -- GNU General Public License for more details. -- -- You should have received a copy of the GNU General Public License -- along with this program; if not, write to the Free Software -- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA -- -- -- Contact : cheddar@listes.univ-brest.fr -- ------------------------------------------------------------------------------ -- Last update : -- $Rev: 3520 $ -- $Date: 2020-07-23 12:44:45 +0200 (Thu, 23 Jul 2020) $ -- $Author: singhoff $ ------------------------------------------------------------------------------ ------------------------------------------------------------------------------ with scheduler; use scheduler; with scheduling_analysis; use scheduling_analysis; use scheduling_analysis.double_tasks_parameters_package; with scheduler.fixed_priority; use scheduler.fixed_priority; with scheduler.fixed_priority.hpf; use scheduler.fixed_priority.hpf; with Text_IO; use Text_IO; with debug; use debug; package body scheduler.mixed_criticality.amc is procedure initialize (a_scheduler : in out mixed_criticality_amc_scheduler) is begin reset (a_scheduler); a_scheduler.parameters.scheduler_type := mixed_criticality_amc_protocol; end initialize; function copy (a_scheduler : in mixed_criticality_amc_scheduler) return generic_scheduler_ptr is ptr : mixed_criticality_amc_scheduler_ptr; begin ptr := new mixed_criticality_amc_scheduler; ptr.parameters := a_scheduler.parameters; ptr.previously_elected := a_scheduler.previously_elected; return generic_scheduler_ptr (ptr); end copy; procedure check_before_scheduling (my_scheduler : in mixed_criticality_amc_scheduler; my_tasks : in tasks_set; processor_name : in Unbounded_String) is begin null; end check_before_scheduling; procedure specific_scheduler_initialization (my_scheduler : in out mixed_criticality_amc_scheduler; si : in out scheduling_information; processor_name : in Unbounded_String; address_space_name : in Unbounded_String; my_tasks : in out tasks_set; my_schedulers : in scheduler_table; my_resources : in out resources_set; my_buffers : in out buffers_set; my_messages : in messages_set; msg : in out Unbounded_String) is begin null; end specific_scheduler_initialization; procedure do_election (my_scheduler : in out mixed_criticality_amc_scheduler; si : in out scheduling_information; result : in out scheduling_sequence_ptr; msg : in out Unbounded_String; current_time : in Natural; processor_name : in Unbounded_String; address_space_name : in Unbounded_String; core_name : in Unbounded_String; options : in scheduling_option; event_to_generate : in time_unit_event_type_boolean_table; elected : in out tasks_range; no_task : in out Boolean) is highiest_priority : Natural := Natural'first; is_critical : Boolean := False; i : tasks_range := 0; is_ready : Boolean := False; previous_task_can_be_run : Boolean := False; begin put_debug ("Call Do_Election: AMC"); -- For each task, call "check_resources" to -- take care of priority modification (PCP and PIP) -- loop if (si.tcbs (i).tsk.cpu_name = processor_name) and ((address_space_name = To_Unbounded_String ("")) or (address_space_name = si.tcbs (i).tsk.address_space_name)) then if (si.tcbs (i).wake_up_time <= current_time) and (si.tcbs (i).rest_of_capacity /= 0) then check_jitter (si.tcbs (i), current_time, si.tcbs (i).is_jitter_ready); if (options.with_jitters = False) or (si.tcbs (i).is_jitter_ready) then if (options.with_offsets = False) or check_offset (si.tcbs (i), current_time) then if (options.with_precedencies = False) or check_precedencies (si, current_time, si.tcbs (i)) then if options.with_resources then check_resource (my_scheduler, si, result, current_time, si.tcbs (i), fixed_priority_tcb_ptr (si.tcbs (i)) .is_resource_ready, event_to_generate); end if; end if; end if; end if; end if; end if; i := i + 1; exit when si.tcbs (i) = null; end loop; -- We can compute scheduling since priorities are ok -- i := 0; loop -- la vérification de si une tache doit passer en criticité haute, si criticality = 1 alors elle est HIGH if ((0 + si.tcbs (i).wake_up_time) < current_time) then is_critical := True; si.tcbs (i).tsk.criticality := 2; end if; if not si.tcbs (i).already_run_at_current_time then if (si.tcbs (i).tsk.cpu_name = processor_name) and ((address_space_name = To_Unbounded_String ("")) or (address_space_name = si.tcbs (i).tsk.address_space_name)) then if (check_core_assignment (my_scheduler, si.tcbs (i))) or (core_name = si.tcbs (i).tsk.core_name) then -- We check if there is a task in critical mode if (is_critical) then -- We check if the task we are looking is critical if (si.tcbs (i).tsk.criticality = 2) then if (si.tcbs (i).wake_up_time <= current_time) and (Natural (fixed_priority_tcb_ptr (si.tcbs (i)) .current_priority) > highiest_priority) and (si.tcbs (i).rest_of_capacity /= 0) then if (options.with_jitters = False) or (si.tcbs (i).is_jitter_ready) then if (options.with_offsets = False) or check_offset (si.tcbs (i), current_time) then if (options.with_precedencies = False) or check_precedencies (si, current_time, si.tcbs (i)) then if (options.with_resources = False) or fixed_priority_tcb_ptr (si.tcbs (i)) .is_resource_ready then highiest_priority := Natural (fixed_priority_tcb_ptr (si.tcbs (i)) .current_priority); elected := i; end if; end if; end if; end if; end if; end if; else if (si.tcbs (i).wake_up_time <= current_time) and (Natural (fixed_priority_tcb_ptr (si.tcbs (i)) .current_priority) > highiest_priority) and (si.tcbs (i).rest_of_capacity /= 0) then if (options.with_jitters = False) or (si.tcbs (i).is_jitter_ready) then if (options.with_offsets = False) or check_offset (si.tcbs (i), current_time) then if (options.with_precedencies = False) or check_precedencies (si, current_time, si.tcbs (i)) then if (options.with_resources = False) or fixed_priority_tcb_ptr (si.tcbs (i)) .is_resource_ready then highiest_priority := Natural (fixed_priority_tcb_ptr (si.tcbs (i)) .current_priority); elected := i; end if; end if; end if; end if; end if; end if; end if; end if; end if; i := i + 1; is_critical := false; exit when si.tcbs (i) = null; end loop; if highiest_priority = Natural'first then no_task := True; else no_task := False; end if; put_debug ("Call Do_Election: AMC : Elected : " & elected'img); end do_election; function build_resource (my_scheduler : in mixed_criticality_amc_scheduler; a_resource : generic_resource_ptr) return shared_resource_ptr is new_a_resource : fixed_priority_resource_ptr; begin new_a_resource := new fixed_priority_resource; new_a_resource.shared := a_resource; -- Set priority ceiling of the resource -- new_a_resource.priority_ceiling := low_priority; return shared_resource_ptr (new_a_resource); end build_resource; function build_tcb (my_scheduler : in mixed_criticality_amc_scheduler; a_task : generic_task_ptr) return tcb_ptr is a_tcb : hpf_tcb_ptr; begin a_tcb := new hpf_tcb; initialize (tcb (a_tcb.all), a_task); initialize (fixed_priority_tcb (a_tcb.all)); initialize (a_tcb.all); return tcb_ptr (a_tcb); end build_tcb; procedure initialize (a_tcb : in out hpf_tcb_ptr) is begin a_tcb.current_priority := a_tcb.tsk.priority; end initialize; end scheduler.mixed_criticality.amc;