26#ifdef STARPU_HAVE_SIMGRID_MSG_H
27#include <simgrid/msg.h>
28#elif defined(STARPU_HAVE_MSG_MSG_H)
32#ifdef STARPU_HAVE_XBT_BASE_H
35#ifdef STARPU_HAVE_SIMGRID_VERSION_H
36#include <simgrid/version.h>
38#ifdef STARPU_HAVE_SIMGRID_ZONE_H
39#include <simgrid/zone.h>
41#ifdef STARPU_HAVE_SIMGRID_HOST_H
42#include <simgrid/host.h>
44#if defined(HAVE_SIMGRID_SIMDAG_H) && (SIMGRID_VERSION >= 31300)
45#include <simgrid/simdag.h>
48#include <xbt/xbt_os_time.h>
57#pragma GCC visibility push(hidden)
65#if (SIMGRID_VERSION >= 32600)
66typedef void _starpu_simgrid_main_ret;
67#define _STARPU_SIMGRID_MAIN_RETURN do { } while (0)
69typedef int _starpu_simgrid_main_ret;
70#define _STARPU_SIMGRID_MAIN_RETURN return 0
72#if (SIMGRID_VERSION >= 31500) && (SIMGRID_VERSION != 31559)
73typedef sg_link_t starpu_sg_link_t;
75typedef SD_link_t starpu_sg_link_t;
77_starpu_simgrid_main_ret
78_starpu_simgrid_thread_start(
int argc,
char *argv[]);
82#define STARPU_MPI_AS_PREFIX "StarPU-MPI"
83#define _starpu_simgrid_running_smpi() (getenv("SMPI_GLOBAL_SIZE") != NULL)
85void _starpu_start_simgrid(
int *argc,
char **argv);
87void _starpu_simgrid_init_early(
int *argc,
char ***argv);
88void _starpu_simgrid_init(
void);
89void _starpu_simgrid_cpp_init(
void);
90void _starpu_simgrid_deinit(
void);
91void _starpu_simgrid_deinit_late(
void);
92void _starpu_simgrid_actor_setup(
void);
93void _starpu_simgrid_wait_tasks(
int workerid);
95void _starpu_simgrid_submit_job(
int workerid,
int sched_ctx_id,
struct _starpu_job *job,
struct starpu_perfmodel_arch* perf_arch,
double length,
double energy,
unsigned *finished);
96struct _starpu_data_request;
97int _starpu_simgrid_transfer(
size_t size,
unsigned src_node,
unsigned dst_node,
struct _starpu_data_request *req);
98int _starpu_simgrid_wait_transfer_event(
void *event);
99int _starpu_simgrid_test_transfer_event(
void *event);
100void _starpu_simgrid_sync_gpus(
void);
103unsigned long long _starpu_simgrid_get_memsize(
const char *prefix,
unsigned devid);
104const char *_starpu_simgrid_get_devname(
const char *prefix,
unsigned devid);
105starpu_sg_host_t _starpu_simgrid_get_host_by_name(
const char *name);
106starpu_sg_host_t _starpu_simgrid_get_memnode_host(
unsigned node);
108starpu_sg_host_t _starpu_simgrid_get_host_by_worker(
struct _starpu_worker *worker);
109void _starpu_simgrid_get_platform_path(
int version,
char *path,
size_t maxlen);
110#if defined(HAVE_SG_ZONE_GET_BY_NAME) || defined(sg_zone_get_by_name)
111sg_netzone_t _starpu_simgrid_get_as_by_name(
const char *name);
113msg_as_t _starpu_simgrid_get_as_by_name(
const char *name);
115#pragma weak starpu_mpi_world_rank
116extern int starpu_mpi_world_rank(
void);
117#pragma weak _starpu_mpi_simgrid_init
118int _starpu_mpi_simgrid_init(
int argc,
char *argv[]);
120extern starpu_pthread_queue_t _starpu_simgrid_transfer_queue[STARPU_MAXNODES];
121extern starpu_pthread_queue_t _starpu_simgrid_task_queue[STARPU_NMAXWORKERS];
123#ifdef STARPU_HAVE_S4U_ON_TIME_ADVANCE_CB
124extern starpu_pthread_mutex_t _starpu_simgrid_time_advance_mutex;
125extern starpu_pthread_cond_t _starpu_simgrid_time_advance_cond;
128#define _starpu_simgrid_cuda_malloc_cost() starpu_getenv_number_default("STARPU_SIMGRID_CUDA_MALLOC_COST", 1)
129#define _starpu_simgrid_cuda_queue_cost() starpu_getenv_number_default("STARPU_SIMGRID_CUDA_QUEUE_COST", 1)
130#define _starpu_simgrid_task_submit_cost() starpu_getenv_number_default("STARPU_SIMGRID_TASK_SUBMIT_COST", 1)
131#define _starpu_simgrid_task_push_cost() starpu_getenv_number_default("STARPU_SIMGRID_TASK_PUSH_COST", 1)
132#define _starpu_simgrid_fetching_input_cost() starpu_getenv_number_default("STARPU_SIMGRID_FETCHING_INPUT_COST", 1)
133#define _starpu_simgrid_sched_cost() starpu_getenv_number_default("STARPU_SIMGRID_SCHED_COST", 0)
139extern size_t _starpu_default_stack_size;
140void _starpu_simgrid_set_stack_size(
size_t stack_size);
141void _starpu_simgrid_xbt_thread_create(
const char *name, starpu_pthread_attr_t *attr, void_f_pvoid_t code,
144#define _SIMGRID_TIMER_BEGIN(cond) \
146 xbt_os_timer_t __timer = NULL; \
148 __timer = xbt_os_timer_new(); \
149 xbt_os_threadtimer_start(__timer); \
151#define _SIMGRID_TIMER_END \
153 xbt_os_threadtimer_stop(__timer); \
154 starpu_sleep(xbt_os_timer_elapsed(__timer));\
155 xbt_os_timer_free(__timer); \
159#pragma GCC visibility pop
162#define _SIMGRID_TIMER_BEGIN(cond) {
163#define _SIMGRID_TIMER_END }
168#if defined(STARPU_SIMGRID) && 0
170void _starpu_simgrid_data_increase(
size_t size);
171void _starpu_simgrid_data_alloc(
size_t size);
172void _starpu_simgrid_data_free(
size_t size);
173void _starpu_simgrid_data_transfer(
size_t size,
unsigned src_node,
unsigned dst_node);
175#define _starpu_simgrid_data_new(size) (void)0
176#define _starpu_simgrid_data_increase(size) (void)0
177#define _starpu_simgrid_data_alloc(size) (void)0
178#define _starpu_simgrid_data_free(size) (void)0
179#define _starpu_simgrid_data_transfer(size, src_node, dst_node) (void)0
void _starpu_simgrid_count_ngpus(void)
#define _starpu_simgrid_data_new(size)
Definition simgrid.h:175
int _starpu_simgrid_get_nbhosts(const char *prefix)
int workerid
Definition jobs.h:190