浏览代码

replace remaining _starpu_wake_worker_relay calls by _starpu_wake_worker_relax_light in sched policies

Olivier Aumage 8 年之前
父节点
当前提交
3c3894020b

+ 1 - 1
src/sched_policies/component_worker.c

@@ -610,7 +610,7 @@ static int combined_worker_can_pull(struct starpu_sched_component * component)
 	{
 		if((unsigned) i == workerid)
 			continue;
-		if (_starpu_wake_worker_relax(workerid))
+		if (_starpu_wake_worker_relax_light(workerid))
 			return 1;
 	}
 	return 0;

+ 1 - 1
src/sched_policies/eager_central_policy.c

@@ -134,7 +134,7 @@ static int push_task_eager_policy(struct starpu_task *task)
 	{
 		unsigned worker = workers->get_next(workers, &it);
 		if (dowake[worker])
-			if (_starpu_wake_worker_relax(worker))
+			if (_starpu_wake_worker_relax_light(worker))
 				break; // wake up a single worker
 	}
 #endif

+ 2 - 2
src/sched_policies/eager_central_priority_policy.c

@@ -145,7 +145,7 @@ static int _starpu_priority_push_task(struct starpu_task *task)
 	{
 		unsigned worker = workers->get_next(workers, &it);
 		if (dowake[worker])
-			if (_starpu_wake_worker_relax(worker))
+			if (_starpu_wake_worker_relax_light(worker))
 				break; // wake up a single worker
 	}
 #endif
@@ -201,7 +201,7 @@ static struct starpu_task *_starpu_priority_pop_task(unsigned sched_ctx_id)
 #ifdef STARPU_NON_BLOCKING_DRIVERS
 				starpu_bitmap_unset(data->waiters, worker);
 #else
-				_starpu_wake_worker_relax(worker);
+				_starpu_wake_worker_relax_light(worker);
 #endif
 			}
 		}

+ 2 - 2
src/sched_policies/graph_test_policy.c

@@ -223,7 +223,7 @@ static void do_schedule_graph_test_policy(unsigned sched_ctx_id)
 	{
 		/* Wake each worker */
 		unsigned worker = workers->get_next(workers, &it);
-		_starpu_wake_worker_relax(worker);
+		_starpu_wake_worker_relax_light(worker);
 	}
 #endif
 }
@@ -303,7 +303,7 @@ static int push_task_graph_test_policy(struct starpu_task *task)
 		unsigned worker = workers->get_next(workers, &it);
 		if (dowake[worker])
 		{
-			if (_starpu_wake_worker_relax(worker))
+			if (_starpu_wake_worker_relax_light(worker))
 				break; // wake up a single worker
 		}
 	}

+ 1 - 1
src/sched_policies/heteroprio.c

@@ -445,7 +445,7 @@ static int push_task_heteroprio_policy(struct starpu_task *task)
 	{
 		unsigned worker = workers->get_next(workers, &it);
 		if (dowake[worker])
-			if (_starpu_wake_worker_relax(worker))
+			if (_starpu_wake_worker_relax_light(worker))
 				break; // wake up a single worker
 	}
 #endif

+ 1 - 1
src/sched_policies/parallel_eager.c

@@ -170,7 +170,7 @@ static int push_task_peager_policy(struct starpu_task *task)
 		    starpu_worker_get_type(worker) != STARPU_MIC_WORKER &&
 		    starpu_worker_get_type(worker) != STARPU_CPU_WORKER)
 			|| (master == worker))
-			_starpu_wake_worker_relax(worker);
+			_starpu_wake_worker_relax_light(worker);
 	}
 #endif
 

+ 1 - 1
src/sched_policies/work_stealing_policy.c

@@ -669,7 +669,7 @@ int ws_push_task(struct starpu_task *task)
 
 	workers->init_iterator(workers, &it);
 	while(workers->has_next(workers, &it))
-		_starpu_wake_worker_relax(workers->get_next(workers, &it));
+		_starpu_wake_worker_relax_light(workers->get_next(workers, &it));
 #endif
 	return 0;
 }