rename starpu_get_nready_tasks_of_sched_ctx to starpu_sched_ctx_get_nready_tasks

include/starpu_sched_ctx.h

@@ -107,7 +107,7 @@ void *starpu_sched_ctx_get_policy_data(unsigned sched_ctx_id);
 
 void *starpu_sched_ctx_exec_parallel_code(void* (*func)(void*), void *param, unsigned sched_ctx_id);
 
-int starpu_get_nready_tasks_of_sched_ctx(unsigned sched_ctx_id);
+int starpu_sched_ctx_get_nready_tasks(unsigned sched_ctx_id);
 
 double starpu_get_nready_flops_of_sched_ctx(unsigned sched_ctx_id);
 

sc_hypervisor/src/policies_utils/lp_tools.c

@@ -42,7 +42,7 @@ double sc_hypervisor_lp_get_nworkers_per_ctx(int nsched_ctxs, int ntypes_of_work
 			v[i][w] = sc_hypervisor_get_speed(sc_w, sc_hypervisor_get_arch_for_index(w, tw)); 
 
 		double ready_flops = starpu_get_nready_flops_of_sched_ctx(sc_w->sched_ctx);
-		int nready_tasks = starpu_get_nready_tasks_of_sched_ctx(sc_w->sched_ctx);
+		int nready_tasks = starpu_sched_ctx_get_nready_tasks(sc_w->sched_ctx);
 		
 		if(sc_w->to_be_sized)
 		{

sc_hypervisor/src/sc_hypervisor.c

@@ -870,7 +870,7 @@ void sc_hypervisor_update_resize_interval(unsigned *sched_ctxs, int nsched_ctxs)
 
 		double curr_time = starpu_timing_now();
 		double elapsed_time = (curr_time - hypervisor.sched_ctx_w[sched_ctx].start_time) / 1000000.0; /* in seconds */
-		int nready_tasks = starpu_get_nready_tasks_of_sched_ctx(sched_ctx);
+		int nready_tasks = starpu_sched_ctx_get_nready_tasks(sched_ctx);
 		if(norm_idle_time >= 0.9)
 		{
 			config->max_nworkers = lrint(norm_exec_time);
@@ -906,7 +906,7 @@ void sc_hypervisor_update_resize_interval(unsigned *sched_ctxs, int nsched_ctxs)
 		unsigned max_nready_sched_ctx = sched_ctxs[0];
 		for(i = 0; i < nsched_ctxs; i++)
 		{
-			int nready_tasks = starpu_get_nready_tasks_of_sched_ctx(sched_ctxs[i]);
+			int nready_tasks = starpu_sched_ctx_get_nready_tasks(sched_ctxs[i]);
 			if(max_nready < nready_tasks)
 			{
 				max_nready = nready_tasks;
@@ -954,7 +954,7 @@ unsigned choose_ctx_to_steal(int worker)
 	for(j = 0; j < ns; j++)
 	{
 		unsigned other_ctx = hypervisor.sched_ctxs[j];
-		int nready = starpu_get_nready_tasks_of_sched_ctx(other_ctx);
+		int nready = starpu_sched_ctx_get_nready_tasks(other_ctx);
 		if(!starpu_sched_ctx_contains_worker(worker, other_ctx) && max_ready_tasks < nready)
 		{
 			max_ready_tasks = nready;

src/core/sched_ctx.c

@@ -927,7 +927,7 @@ void _starpu_decrement_nready_tasks_of_sched_ctx(unsigned sched_ctx_id, double r
 	_starpu_barrier_counter_decrement_until_empty_counter(&sched_ctx->ready_tasks_barrier, ready_flops);
 }
 
-int starpu_get_nready_tasks_of_sched_ctx(unsigned sched_ctx_id)
+int starpu_sched_ctx_get_nready_tasks(unsigned sched_ctx_id)
 {
 	struct _starpu_sched_ctx *sched_ctx = _starpu_get_sched_ctx_struct(sched_ctx_id);
 	return _starpu_barrier_counter_get_reached_start(&sched_ctx->ready_tasks_barrier);

src/core/task.c

@@ -843,7 +843,7 @@ int starpu_task_nready(void)
 	int nready = 0;
 	struct _starpu_machine_config *config = (struct _starpu_machine_config *)_starpu_get_machine_config();
 	if(config->topology.nsched_ctxs == 1)
-		nready = starpu_get_nready_tasks_of_sched_ctx(0);
+		nready = starpu_sched_ctx_get_nready_tasks(0);
 	else
 	{
 		int s;
@@ -851,7 +851,7 @@ int starpu_task_nready(void)
 		{
 			if(config->sched_ctxs[s].id != STARPU_NMAX_SCHED_CTXS)
 			{
-				nready += starpu_get_nready_tasks_of_sched_ctx(config->sched_ctxs[s].id);
+				nready += starpu_sched_ctx_get_nready_tasks(config->sched_ctxs[s].id);
 			}
 		}
 	}