Re: [Starpu-devel] Questionsur les dépendancesexplicites

[Samuel Thibault <samuel.thibault@inria.fr>]

Bonjour,

Il vaut mieux toujours garder la liste en copie, pour éviter de se
retrouver sans réponse si jamais la seule personne à qui vous envoyez un
mail se retrouve partir en vacances...

anne caselli, on mar. 13 mars 2018 20:24:59 +0100, wrote:
> En effet il y a bien une inversion. Cependant, même après 
> correction,l'affichage des id reste décroissant, alors que si les 
> dépendances sont bien respectées l'affichage devrait être croissant non ?

Après correction j'obtiens bien un ordre croissant, cf pièce ci-jointe.

Samuel
#include <starpu.h>

#define cont 10

#define TAG(i)	((starpu_tag_t)  (i))

struct params { starpu_tag_t id; };

uint64_t clts[cont];
volatile int nc;

void display (void * buffers[], void * cl_arg)
{
	struct params *parametres = cl_arg;	
	// int ret = starpu_tag_wait(parametres->id-1);
	// STARPU_CHECK_RETURN_VALUE(ret, "starpu_tag_wait");
	int idx = nc++; //STARPU_ATOMIC_ADD(&nc, 1);	
	clts[idx] = parametres->id;
	free(parametres);
}
	
struct starpu_codelet clt =
{
	.cpu_funcs = { display },
	.cpu_funcs_name  = { "display" },
	.modes = {STARPU_RW},
	.nbuffers = 0,
	.model = NULL
};

void spawn(starpu_tag_t tag, unsigned deps, starpu_tag_t dst)
{
	struct starpu_task *task = starpu_task_create();
	task->cl = &clt; /*Pointeur sur le codelet*/
	task->use_tag = 1;
	task->tag_id = tag;
	struct params *parametres1 = malloc(sizeof(struct params));
	parametres1->id = tag; /* Les paramètres sont arguments de la tâche*/
	task->cl_arg = parametres1;
	task->cl_arg_size = sizeof(*parametres1);
	starpu_tag_declare_deps(tag, deps, dst);
	int ret = starpu_task_submit(task); /*submit the task to StarPU*/
	STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_submit");
}

int main(int argc, char **argv)
{
	/*initialisation StarPU*/
	int ret = starpu_init(NULL);
	STARPU_CHECK_RETURN_VALUE(ret, "starpu_init");
	/*On boucle pour créer le nombre de tâche voulu*/
	for (unsigned long i = cont-1; i>0; i--)
	//for (unsigned long i = 1; i< cont; i++)
		spawn( TAG(i), 1, TAG(i-1));

	spawn(TAG(0),0,TAG(0));	
	starpu_task_wait_for_all();
	
	for (int i = 0; i < cont; i++) {
		printf("%lu\t", clts[i]);
	}
	puts("");
	
	/*terminate StarPU*/
	starpu_shutdown();
	return 0;
}