starpu-max/examples/worker_collections/worker_list_example.c

/* StarPU --- Runtime system for heterogeneous multicore architectures.                                                                                                                                            
 *                                                                                                                                                                                                                 
 * Copyright (C) 2010-2013  Université de Bordeaux 1                                                                                                                                                               
 * Copyright (C) 2010-2013  Centre National de la Recherche Scientifique                                                                                                                                           
 *                                                                                                                                                                                                                 
 * StarPU is free software; you can redistribute it and/or modify                                                                                                                                                  
 * it under the terms of the GNU Lesser General Public License as published by                                                                                                                                     
 * the Free Software Foundation; either version 2.1 of the License, or (at                                                                                                                                         
 * your option) any later version.                                                                                                                                                                                 
 *                                                                                                                                                                                                                 
 * StarPU 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 Lesser General Public License in COPYING.LGPL for more details.                                                                                                                                     
 */

#include <starpu.h>

int main()
{
	starpu_init(NULL);

	int procs[STARPU_NMAXWORKERS];
	unsigned ncpus =  starpu_cpu_worker_get_count();
        starpu_worker_get_ids_by_type(STARPU_CPU_WORKER, procs, ncpus);

	struct starpu_worker_collection *co = (struct starpu_worker_collection*)malloc(sizeof(struct starpu_worker_collection));
	co->has_next = worker_list.has_next;
	co->get_next = worker_list.get_next;
	co->add = worker_list.add;
	co->remove = worker_list.remove;
	co->init = worker_list.init;
	co->deinit = worker_list.deinit;
	co->init_iterator = worker_list.init_iterator;
	co->type = STARPU_WORKER_LIST;

	printf("ncpus %d \n", ncpus);

	struct timeval start_time;
        struct timeval end_time;
        gettimeofday(&start_time, NULL);

	co->init(co);

	gettimeofday(&end_time, NULL);

        long diff_s = end_time.tv_sec  - start_time.tv_sec;
        long diff_us = end_time.tv_usec  - start_time.tv_usec;

	float timing = (float)(diff_s*1000000 + diff_us)/1000;

	int i;
	for(i = 0; i < ncpus; i++)
	{
		int added = co->add(co, procs[i]);
		printf("added proc %d to the tree \n", added);
	}

	struct starpu_sched_ctx_iterator it;
        if(co->init_iterator)
                co->init_iterator(co, &it);
	
	int pu;
	while(co->has_next(co, &it))
	{
		pu = co->get_next(co, &it);
		printf("pu = %d out of %d workers \n", pu, co->nworkers);
	}
	
	for(i = 0; i < 6; i++)
	{
		co->remove(co, i);
		printf("remove %d out of %d workers\n", i, co->nworkers);
	}

	while(co->has_next(co, &it))
	{
		pu = co->get_next(co, &it);
		printf("pu = %d out of %d workers \n", pu, co->nworkers);
	}
	
	printf("timing init = %lf \n", timing);
	co->deinit(co);
	starpu_shutdown();
}