Parcourir la source

Also limit fifos below, not only prioritized fifos

Samuel Thibault il y a 6 ans
Parent
commit
a9972c23e7
1 fichiers modifiés avec 8 ajouts et 2 suppressions
  1. 8 2
      src/sched_policies/modular_ez.c

+ 8 - 2
src/sched_policies/modular_ez.c

@@ -1,6 +1,6 @@
 /* StarPU --- Runtime system for heterogeneous multicore architectures.
  *
- * Copyright (C) 2013-2015,2017,2018                      Université de Bordeaux
+ * Copyright (C) 2013-2015,2017,2018-2019                 Université de Bordeaux
  * Copyright (C) 2013-2015,2017                           Inria
  * Copyright (C) 2014,2015,2017                           CNRS
  * Copyright (C) 2013                                     Simon Archipoff
@@ -75,6 +75,12 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
 			.exp_len_threshold = starpu_get_env_float_default("STARPU_EXP_LEN_THRESHOLD", _STARPU_SCHED_EXP_LEN_THRESHOLD_DEFAULT),
 		};
 
+	struct starpu_sched_component_fifo_data fifo_data =
+		{
+			.ntasks_threshold = starpu_get_env_number_default("STARPU_NTASKS_THRESHOLD", _STARPU_SCHED_NTASKS_THRESHOLD_DEFAULT),
+			.exp_len_threshold = starpu_get_env_float_default("STARPU_EXP_LEN_THRESHOLD", _STARPU_SCHED_EXP_LEN_THRESHOLD_DEFAULT),
+		};
+
 
 	/* See what the component will decide */
 	unsigned nbelow;
@@ -214,7 +220,7 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
 			}
 			else
 			{
-				fifo_below = starpu_sched_component_fifo_create(t, NULL);
+				fifo_below = starpu_sched_component_fifo_create(t, &fifo_data);
 			}
 			starpu_sched_component_connect(last, fifo_below);
 			last = fifo_below;