StarPU Internal Handbook
simgrid.h
Go to the documentation of this file.
1 /* StarPU --- Runtime system for heterogeneous multicore architectures.
2  *
3  * Copyright (C) 2012-2020 Université de Bordeaux, CNRS (LaBRI UMR 5800), Inria
4  * Copyright (C) 2013 Thibaut Lambert
5  *
6  * StarPU is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU Lesser General Public License as published by
8  * the Free Software Foundation; either version 2.1 of the License, or (at
9  * your option) any later version.
10  *
11  * StarPU is distributed in the hope that it will be useful, but
12  * WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
14  *
15  * See the GNU Lesser General Public License in COPYING.LGPL for more details.
16  */
17 
18 #ifndef __SIMGRID_H__
19 #define __SIMGRID_H__
20 
23 #ifdef __cplusplus
24 extern "C"
25 {
26 #endif
27 #ifdef STARPU_SIMGRID
28 #ifdef STARPU_HAVE_SIMGRID_MSG_H
29 #include <simgrid/msg.h>
30 #elif defined(STARPU_HAVE_MSG_MSG_H)
31 #include <msg/msg.h>
32 #endif
33 
34 #ifdef STARPU_HAVE_XBT_BASE_H
35 #include <xbt/base.h>
36 #endif
37 #ifdef STARPU_HAVE_SIMGRID_VERSION_H
38 #include <simgrid/version.h>
39 #endif
40 #ifdef STARPU_HAVE_SIMGRID_ZONE_H
41 #include <simgrid/zone.h>
42 #endif
43 #ifdef STARPU_HAVE_SIMGRID_HOST_H
44 #include <simgrid/host.h>
45 #endif
46 
47 #include <xbt/xbt_os_time.h>
48 
50 {
51  void *(*f)(void*);
52  void *arg;
53 };
54 
55 #define MAX_TSD 16
56 
57 #define STARPU_MPI_AS_PREFIX "StarPU-MPI"
58 #define _starpu_simgrid_running_smpi() (getenv("SMPI_GLOBAL_SIZE") != NULL)
59 
60 void _starpu_start_simgrid(int *argc, char **argv);
61 
62 void _starpu_simgrid_init_early(int *argc, char ***argv);
63 void _starpu_simgrid_init(void);
64 void _starpu_simgrid_deinit(void);
65 void _starpu_simgrid_deinit_late(void);
66 void _starpu_simgrid_actor_setup(void);
67 void _starpu_simgrid_wait_tasks(int workerid);
68 struct _starpu_job;
69 void _starpu_simgrid_submit_job(int workerid, struct _starpu_job *job, struct starpu_perfmodel_arch* perf_arch, double length, unsigned *finished);
70 struct _starpu_data_request;
71 int _starpu_simgrid_transfer(size_t size, unsigned src_node, unsigned dst_node, struct _starpu_data_request *req);
73 int _starpu_simgrid_wait_transfer_event(union _starpu_async_channel_event *event);
74 int _starpu_simgrid_test_transfer_event(union _starpu_async_channel_event *event);
75 void _starpu_simgrid_sync_gpus(void);
77 int _starpu_simgrid_get_nbhosts(const char *prefix);
78 unsigned long long _starpu_simgrid_get_memsize(const char *prefix, unsigned devid);
79 starpu_sg_host_t _starpu_simgrid_get_host_by_name(const char *name);
80 starpu_sg_host_t _starpu_simgrid_get_memnode_host(unsigned node);
81 struct _starpu_worker;
82 starpu_sg_host_t _starpu_simgrid_get_host_by_worker(struct _starpu_worker *worker);
83 void _starpu_simgrid_get_platform_path(int version, char *path, size_t maxlen);
84 #if defined(HAVE_SG_ZONE_GET_BY_NAME) || defined(sg_zone_get_by_name)
85 sg_netzone_t _starpu_simgrid_get_as_by_name(const char *name);
86 #else
87 msg_as_t _starpu_simgrid_get_as_by_name(const char *name);
88 #endif
89 #pragma weak starpu_mpi_world_rank
90 extern int starpu_mpi_world_rank(void);
91 #pragma weak _starpu_mpi_simgrid_init
92 int _starpu_mpi_simgrid_init(int argc, char *argv[]);
93 
94 extern starpu_pthread_queue_t _starpu_simgrid_transfer_queue[STARPU_MAXNODES];
95 extern starpu_pthread_queue_t _starpu_simgrid_task_queue[STARPU_NMAXWORKERS];
96 
97 #define _starpu_simgrid_cuda_malloc_cost() starpu_get_env_number_default("STARPU_SIMGRID_CUDA_MALLOC_COST", 1)
98 #define _starpu_simgrid_queue_malloc_cost() starpu_get_env_number_default("STARPU_SIMGRID_QUEUE_MALLOC_COST", 1)
99 #define _starpu_simgrid_task_submit_cost() starpu_get_env_number_default("STARPU_SIMGRID_TASK_SUBMIT_COST", 1)
100 #define _starpu_simgrid_fetching_input_cost() starpu_get_env_number_default("STARPU_SIMGRID_FETCHING_INPUT_COST", 1)
101 #define _starpu_simgrid_sched_cost() starpu_get_env_number_default("STARPU_SIMGRID_SCHED_COST", 0)
102 
106 
107 void _starpu_simgrid_xbt_thread_create(const char *name, void_f_pvoid_t code,
108  void *param);
109 
110 #define _SIMGRID_TIMER_BEGIN(cond) \
111  { \
112  xbt_os_timer_t __timer = NULL; \
113  if (cond) { \
114  __timer = xbt_os_timer_new(); \
115  xbt_os_threadtimer_start(__timer); \
116  }
117 #define _SIMGRID_TIMER_END \
118  if (__timer) { \
119  xbt_os_threadtimer_stop(__timer); \
120  starpu_sleep(xbt_os_timer_elapsed(__timer));\
121  xbt_os_timer_free(__timer); \
122  } \
123  }
124 
125 #else // !STARPU_SIMGRID
126 #define _SIMGRID_TIMER_BEGIN(cond) {
127 #define _SIMGRID_TIMER_END }
128 #endif
129 
131 /* disk <-> MAIN_RAM only */
132 #if defined(STARPU_SIMGRID) && 0
133 void _starpu_simgrid_data_new(size_t size);
134 void _starpu_simgrid_data_increase(size_t size);
135 void _starpu_simgrid_data_alloc(size_t size);
136 void _starpu_simgrid_data_free(size_t size);
137 void _starpu_simgrid_data_transfer(size_t size, unsigned src_node, unsigned dst_node);
138 #else
139 #define _starpu_simgrid_data_new(size) (void)0
140 #define _starpu_simgrid_data_increase(size) (void)0
141 #define _starpu_simgrid_data_alloc(size) (void)0
142 #define _starpu_simgrid_data_free(size) (void)0
143 #define _starpu_simgrid_data_transfer(size, src_node, dst_node) (void)0
144 #endif
145 
146 #ifdef __cplusplus
147 }
148 #endif
149 
150 #endif // __SIMGRID_H__
Definition: copy_driver.h:103
void _starpu_simgrid_count_ngpus(void)
#define _starpu_simgrid_data_new(size)
Definition: simgrid.h:139
int _starpu_simgrid_get_nbhosts(const char *prefix)
Definition: jobs.h:79
Definition: simgrid.h:50
Definition: workers.h:70