starpu_task.h 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2011-2017 Inria
  4. * Copyright (C) 2009-2019 Université de Bordeaux
  5. * Copyright (C) 2010-2015,2017,2018,2019 CNRS
  6. * Copyright (C) 2011 Télécom-SudParis
  7. * Copyright (C) 2016 Uppsala University
  8. *
  9. * StarPU is free software; you can redistribute it and/or modify
  10. * it under the terms of the GNU Lesser General Public License as published by
  11. * the Free Software Foundation; either version 2.1 of the License, or (at
  12. * your option) any later version.
  13. *
  14. * StarPU is distributed in the hope that it will be useful, but
  15. * WITHOUT ANY WARRANTY; without even the implied warranty of
  16. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  17. *
  18. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  19. */
  20. #ifndef __STARPU_TASK_H__
  21. #define __STARPU_TASK_H__
  22. #include <starpu.h>
  23. #include <errno.h>
  24. #include <assert.h>
  25. #if defined STARPU_USE_CUDA && !defined STARPU_DONT_INCLUDE_CUDA_HEADERS
  26. # include <cuda.h>
  27. #endif
  28. #ifdef __cplusplus
  29. extern "C"
  30. {
  31. #endif
  32. /**
  33. @defgroup API_Codelet_And_Tasks Codelet And Tasks
  34. @brief This section describes the interface to manipulate codelets
  35. and tasks.
  36. @{
  37. */
  38. /**
  39. To be used when setting the field starpu_codelet::where to specify
  40. that the codelet has no computation part, and thus does not need to
  41. be scheduled, and data does not need to be actually loaded. This is
  42. thus essentially used for synchronization tasks.
  43. */
  44. #define STARPU_NOWHERE ((1ULL)<<0)
  45. /**
  46. To be used when setting the field starpu_codelet::where (or
  47. starpu_task::where) to specify the codelet (or the task) may be
  48. executed on a CPU processing unit.
  49. */
  50. #define STARPU_CPU ((1ULL)<<1)
  51. /**
  52. To be used when setting the field starpu_codelet::where (or
  53. starpu_task::where) to specify the codelet (or the task) may be
  54. executed on a CUDA processing unit.
  55. */
  56. #define STARPU_CUDA ((1ULL)<<3)
  57. /**
  58. To be used when setting the field starpu_codelet::where (or
  59. starpu_task::where) to specify the codelet (or the task) may be
  60. executed on a MAX FPGA.
  61. */
  62. #define STARPU_FPGA ((1ULL)<<9)
  63. /**
  64. To be used when setting the field starpu_codelet::where (or
  65. starpu_task::where) to specify the codelet (or the task) may be
  66. executed on a OpenCL processing unit.
  67. */
  68. #define STARPU_OPENCL ((1ULL)<<6)
  69. /**
  70. To be used when setting the field starpu_codelet::where (or
  71. starpu_task::where) to specify the codelet (or the task) may be
  72. executed on a MIC processing unit.
  73. */
  74. #define STARPU_MIC ((1ULL)<<7)
  75. /**
  76. To be used when setting the field starpu_codelet::where (or
  77. starpu_task::where) to specify the codelet (or the task) may be
  78. executed on a MPI Slave processing unit.
  79. */
  80. #define STARPU_MPI_MS ((1ULL)<<9)
  81. /**
  82. Value to be set in starpu_codelet::flags to execute the codelet
  83. functions even in simgrid mode.
  84. */
  85. #define STARPU_CODELET_SIMGRID_EXECUTE (1<<0)
  86. /**
  87. Value to be set in starpu_codelet::flags to execute the codelet
  88. functions even in simgrid mode, and later inject the measured
  89. timing inside the simulation.
  90. */
  91. #define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1<<1)
  92. /**
  93. Value to be set in starpu_codelet::flags to make starpu_task_submit()
  94. not submit automatic asynchronous partitioning/unpartitioning.
  95. */
  96. #define STARPU_CODELET_NOPLANS (1<<2)
  97. /**
  98. Value to be set in starpu_codelet::cuda_flags to allow asynchronous
  99. CUDA kernel execution.
  100. */
  101. #define STARPU_CUDA_ASYNC (1<<0)
  102. /**
  103. Value to be set in starpu_codelet::opencl_flags to allow
  104. asynchronous OpenCL kernel execution.
  105. */
  106. #define STARPU_OPENCL_ASYNC (1<<0)
  107. /**
  108. To be used when the RAM memory node is specified.
  109. */
  110. #define STARPU_MAIN_RAM 0
  111. /**
  112. Describe the type of parallel task. See \ref ParallelTasks for
  113. details.
  114. */
  115. enum starpu_codelet_type
  116. {
  117. STARPU_SEQ = 0, /**< (default) for classical sequential
  118. tasks.
  119. */
  120. STARPU_SPMD, /**< for a parallel task whose threads are
  121. handled by StarPU, the code has to use
  122. starpu_combined_worker_get_size() and
  123. starpu_combined_worker_get_rank() to
  124. distribute the work.
  125. */
  126. STARPU_FORKJOIN /**< for a parallel task whose threads are
  127. started by the codelet function, which has
  128. to use starpu_combined_worker_get_size() to
  129. determine how many threads should be
  130. started.
  131. */
  132. };
  133. enum starpu_task_status
  134. {
  135. STARPU_TASK_INVALID, /**< The task has just been initialized. */
  136. #define STARPU_TASK_INVALID 0
  137. STARPU_TASK_BLOCKED, /**< The task has just been
  138. submitted, and its dependencies has not been checked yet. */
  139. STARPU_TASK_READY, /**< The task is ready for execution. */
  140. STARPU_TASK_RUNNING, /**< The task is running on some worker. */
  141. STARPU_TASK_FINISHED, /**< The task is finished executing. */
  142. STARPU_TASK_BLOCKED_ON_TAG, /**< The task is waiting for a tag. */
  143. STARPU_TASK_BLOCKED_ON_TASK, /**< The task is waiting for a task. */
  144. STARPU_TASK_BLOCKED_ON_DATA, /**< The task is waiting for some data. */
  145. STARPU_TASK_STOPPED /**< The task is stopped. */
  146. };
  147. /**
  148. CPU implementation of a codelet.
  149. */
  150. typedef void (*starpu_cpu_func_t)(void **, void*);
  151. /**
  152. CUDA implementation of a codelet.
  153. */
  154. typedef void (*starpu_cuda_func_t)(void **, void*);
  155. /**
  156. FPGA implementation of a codelet.
  157. */
  158. typedef void (*starpu_fpga_func_t)(void **, void*);
  159. /**
  160. OpenCL implementation of a codelet.
  161. */
  162. typedef void (*starpu_opencl_func_t)(void **, void*);
  163. /**
  164. MIC implementation of a codelet.
  165. */
  166. typedef void (*starpu_mic_kernel_t)(void **, void*);
  167. /**
  168. MIC kernel for a codelet
  169. */
  170. typedef starpu_mic_kernel_t (*starpu_mic_func_t)(void);
  171. /**
  172. MPI Master Slave kernel for a codelet
  173. */
  174. typedef void (*starpu_mpi_ms_kernel_t)(void **, void*);
  175. /**
  176. MPI Master Slave implementation of a codelet.
  177. */
  178. typedef starpu_mpi_ms_kernel_t (*starpu_mpi_ms_func_t)(void);
  179. /**
  180. @deprecated
  181. Setting the field starpu_codelet::cpu_func with this macro
  182. indicates the codelet will have several implementations. The use of
  183. this macro is deprecated. One should always only define the field
  184. starpu_codelet::cpu_funcs.
  185. */
  186. #define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t) -1)
  187. /**
  188. @deprecated
  189. Setting the field starpu_codelet::cuda_func with this macro
  190. indicates the codelet will have several implementations. The use of
  191. this macro is deprecated. One should always only define the field
  192. starpu_codelet::cuda_funcs.
  193. */
  194. #define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t) -1)
  195. /**
  196. @deprecated
  197. Setting the field starpu_codelet::fpga_func with this macro
  198. indicates the codelet will have several implementations. The use of
  199. this macro is deprecated. One should always only define the field
  200. starpu_codelet::fpga_funcs.
  201. */
  202. #define STARPU_MULTIPLE_FPGA_IMPLEMENTATIONS ((starpu_fpga_func_t) -1)
  203. /**
  204. @deprecated
  205. Setting the field starpu_codelet::opencl_func with this macro
  206. indicates the codelet will have several implementations. The use of
  207. this macro is deprecated. One should always only define the field
  208. starpu_codelet::opencl_funcs.
  209. */
  210. #define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t) -1)
  211. /**
  212. Value to set in starpu_codelet::nbuffers to specify that the
  213. codelet can accept a variable number of buffers, specified in
  214. starpu_task::nbuffers.
  215. */
  216. #define STARPU_VARIABLE_NBUFFERS (-1)
  217. /**
  218. Value to be set in the field starpu_codelet::nodes to request
  219. StarPU to put the data in CPU-accessible memory (and let StarPU
  220. choose the NUMA node).
  221. */
  222. #define STARPU_SPECIFIC_NODE_LOCAL (-1)
  223. #define STARPU_SPECIFIC_NODE_CPU (-2)
  224. #define STARPU_SPECIFIC_NODE_SLOW (-3)
  225. #define STARPU_SPECIFIC_NODE_FAST (-4)
  226. struct starpu_task;
  227. /**
  228. The codelet structure describes a kernel that is possibly
  229. implemented on various targets. For compatibility, make sure to
  230. initialize the whole structure to zero, either by using explicit
  231. memset, or the function starpu_codelet_init(), or by letting the
  232. compiler implicitly do it in e.g. static storage case.
  233. */
  234. struct starpu_codelet
  235. {
  236. /**
  237. Optional field to indicate which types of processing units
  238. are able to execute the codelet. The different values
  239. ::STARPU_CPU, ::STARPU_CUDA, ::STARPU_OPENCL can be
  240. combined to specify on which types of processing units the
  241. codelet can be executed. ::STARPU_CPU|::STARPU_CUDA for
  242. instance indicates that the codelet is implemented for both
  243. CPU cores and CUDA devices while ::STARPU_OPENCL indicates
  244. that it is only available on OpenCL devices. If the field
  245. is unset, its value will be automatically set based on the
  246. availability of the XXX_funcs fields defined below. It can
  247. also be set to ::STARPU_NOWHERE to specify that no
  248. computation has to be actually done.
  249. */
  250. uint32_t where;
  251. /**
  252. Define a function which should return 1 if the worker
  253. designated by \p workerid can execute the \p nimpl -th
  254. implementation of \p task, 0 otherwise.
  255. */
  256. int (*can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl);
  257. /**
  258. Optional field to specify the type of the codelet. The
  259. default is ::STARPU_SEQ, i.e. usual sequential
  260. implementation. Other values (::STARPU_SPMD or
  261. ::STARPU_FORKJOIN) declare that a parallel implementation is
  262. also available. See \ref ParallelTasks for details.
  263. */
  264. enum starpu_codelet_type type;
  265. /**
  266. Optional field. If a parallel implementation is available,
  267. this denotes the maximum combined worker size that StarPU
  268. will use to execute parallel tasks for this codelet.
  269. */
  270. int max_parallelism;
  271. /**
  272. @deprecated
  273. Optional field which has been made deprecated. One should
  274. use instead the field starpu_codelet::cpu_funcs.
  275. */
  276. starpu_cpu_func_t cpu_func STARPU_DEPRECATED;
  277. /**
  278. @deprecated
  279. Optional field which has been made deprecated. One should
  280. use instead the starpu_codelet::cuda_funcs field.
  281. */
  282. starpu_cuda_func_t cuda_func STARPU_DEPRECATED;
  283. /**
  284. @deprecated
  285. Optional field which has been made deprecated. One should
  286. use instead the starpu_codelet::fpga_funcs field.
  287. */
  288. starpu_fpga_func_t fpga_func STARPU_DEPRECATED;
  289. /**
  290. @deprecated
  291. Optional field which has been made deprecated. One should
  292. use instead the starpu_codelet::opencl_funcs field.
  293. */
  294. starpu_opencl_func_t opencl_func STARPU_DEPRECATED;
  295. /**
  296. Optional array of function pointers to the CPU
  297. implementations of the codelet. The functions prototype
  298. must be:
  299. \code{.c}
  300. void cpu_func(void *buffers[], void *cl_arg)
  301. \endcode
  302. The first argument being the array of data managed by the
  303. data management library, and the second argument is a
  304. pointer to the argument passed from the field
  305. starpu_task::cl_arg. If the field starpu_codelet::where is
  306. set, then the field tarpu_codelet::cpu_funcs is ignored if
  307. ::STARPU_CPU does not appear in the field
  308. starpu_codelet::where, it must be non-<c>NULL</c> otherwise.
  309. */
  310. starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS];
  311. /**
  312. Optional array of function pointers to the CUDA
  313. implementations of the codelet. The functions must be
  314. host-functions written in the CUDA runtime API. Their
  315. prototype must be:
  316. \code{.c}
  317. void cuda_func(void *buffers[], void *cl_arg)
  318. \endcode
  319. If the field starpu_codelet::where is set, then the field
  320. starpu_codelet::cuda_funcs is ignored if ::STARPU_CUDA does
  321. not appear in the field starpu_codelet::where, it must be
  322. non-<c>NULL</c> otherwise.
  323. */
  324. starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS];
  325. starpu_fpga_func_t fpga_funcs[STARPU_MAXIMPLEMENTATIONS];
  326. /**
  327. Optional array of flags for CUDA execution. They specify
  328. some semantic details about CUDA kernel execution, such as
  329. asynchronous execution.
  330. */
  331. char cuda_flags[STARPU_MAXIMPLEMENTATIONS];
  332. /**
  333. Optional array of function pointers to the OpenCL
  334. implementations of the codelet. The functions prototype
  335. must be:
  336. \code{.c}
  337. void opencl_func(void *buffers[], void *cl_arg)
  338. \endcode
  339. If the field starpu_codelet::where field is set, then the
  340. field starpu_codelet::opencl_funcs is ignored if
  341. ::STARPU_OPENCL does not appear in the field
  342. starpu_codelet::where, it must be non-<c>NULL</c> otherwise.
  343. */
  344. starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS];
  345. /**
  346. Optional array of flags for OpenCL execution. They specify
  347. some semantic details about OpenCL kernel execution, such
  348. as asynchronous execution.
  349. */
  350. char opencl_flags[STARPU_MAXIMPLEMENTATIONS];
  351. /**
  352. Optional array of function pointers to a function which
  353. returns the MIC implementation of the codelet. The
  354. functions prototype must be:
  355. \code{.c}
  356. starpu_mic_kernel_t mic_func(struct starpu_codelet *cl, unsigned nimpl)
  357. \endcode
  358. If the field starpu_codelet::where is set, then the field
  359. starpu_codelet::mic_funcs is ignored if ::STARPU_MIC does
  360. not appear in the field starpu_codelet::where. It can be
  361. <c>NULL</c> if starpu_codelet::cpu_funcs_name is
  362. non-<c>NULL</c>, in which case StarPU will simply make a
  363. symbol lookup to get the implementation.
  364. */
  365. starpu_mic_func_t mic_funcs[STARPU_MAXIMPLEMENTATIONS];
  366. /**
  367. Optional array of function pointers to a function which
  368. returns the MPI Master Slave implementation of the codelet.
  369. The functions prototype must be:
  370. \code{.c}
  371. starpu_mpi_ms_kernel_t mpi_ms_func(struct starpu_codelet *cl, unsigned nimpl)
  372. \endcode
  373. If the field starpu_codelet::where is set, then the field
  374. starpu_codelet::mpi_ms_funcs is ignored if ::STARPU_MPI_MS
  375. does not appear in the field starpu_codelet::where. It can
  376. be <c>NULL</c> if starpu_codelet::cpu_funcs_name is
  377. non-<c>NULL</c>, in which case StarPU will simply make a
  378. symbol lookup to get the implementation.
  379. */
  380. starpu_mpi_ms_func_t mpi_ms_funcs[STARPU_MAXIMPLEMENTATIONS];
  381. /**
  382. Optional array of strings which provide the name of the CPU
  383. functions referenced in the array
  384. starpu_codelet::cpu_funcs. This can be used when running on
  385. MIC devices for StarPU to simply look
  386. up the MIC function implementation through its name.
  387. */
  388. const char *cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS];
  389. char *fpga_funcs_name[STARPU_MAXIMPLEMENTATIONS];
  390. char *fpga_kernel_type[STARPU_MAXIMPLEMENTATIONS];
  391. /**
  392. Specify the number of arguments taken by the codelet. These
  393. arguments are managed by the DSM and are accessed from the
  394. <c>void *buffers[]</c> array. The constant argument passed
  395. with the field starpu_task::cl_arg is not counted in this
  396. number. This value should not be above \ref
  397. STARPU_NMAXBUFS. It may be set to \ref
  398. STARPU_VARIABLE_NBUFFERS to specify that the number of
  399. buffers and their access modes will be set in
  400. starpu_task::nbuffers and starpu_task::modes or
  401. starpu_task::dyn_modes, which thus permits to define
  402. codelets with a varying number of data.
  403. */
  404. int nbuffers;
  405. /**
  406. Is an array of ::starpu_data_access_mode. It describes the
  407. required access modes to the data neeeded by the codelet
  408. (e.g. ::STARPU_RW). The number of entries in this array
  409. must be specified in the field starpu_codelet::nbuffers,
  410. and should not exceed \ref STARPU_NMAXBUFS. If
  411. unsufficient, this value can be set with the configure
  412. option \ref enable-maxbuffers "--enable-maxbuffers".
  413. */
  414. enum starpu_data_access_mode modes[STARPU_NMAXBUFS];
  415. /**
  416. Is an array of ::starpu_data_access_mode. It describes the
  417. required access modes to the data needed by the codelet
  418. (e.g. ::STARPU_RW). The number of entries in this array
  419. must be specified in the field starpu_codelet::nbuffers.
  420. This field should be used for codelets having a number of
  421. datas greater than \ref STARPU_NMAXBUFS (see \ref
  422. SettingManyDataHandlesForATask). When defining a codelet,
  423. one should either define this field or the field
  424. starpu_codelet::modes defined above.
  425. */
  426. enum starpu_data_access_mode *dyn_modes;
  427. /**
  428. Default value is 0. If this flag is set, StarPU will not
  429. systematically send all data to the memory node where the
  430. task will be executing, it will read the
  431. starpu_codelet::nodes or starpu_codelet::dyn_nodes array to
  432. determine, for each data, whether to send it on the memory
  433. node where the task will be executing (-1), or on a
  434. specific node (!= -1).
  435. */
  436. unsigned specific_nodes;
  437. /**
  438. Optional field. When starpu_codelet::specific_nodes is 1,
  439. this specifies the memory nodes where each data should be
  440. sent to for task execution. The number of entries in this
  441. array is starpu_codelet::nbuffers, and should not exceed
  442. \ref STARPU_NMAXBUFS.
  443. */
  444. int nodes[STARPU_NMAXBUFS];
  445. /**
  446. Optional field. When starpu_codelet::specific_nodes is 1,
  447. this specifies the memory nodes where each data should be
  448. sent to for task execution. The number of entries in this
  449. array is starpu_codelet::nbuffers. This field should be
  450. used for codelets having a number of datas greater than
  451. \ref STARPU_NMAXBUFS (see \ref
  452. SettingManyDataHandlesForATask). When defining a codelet,
  453. one should either define this field or the field
  454. starpu_codelet::nodes defined above.
  455. */
  456. int *dyn_nodes;
  457. /**
  458. Optional pointer to the task duration performance model
  459. associated to this codelet. This optional field is ignored
  460. when set to <c>NULL</c> or when its field
  461. starpu_perfmodel::symbol is not set.
  462. */
  463. struct starpu_perfmodel *model;
  464. /**
  465. Optional pointer to the task energy consumption performance
  466. model associated to this codelet. This optional field is
  467. ignored when set to <c>NULL</c> or when its field
  468. starpu_perfmodel::symbol is not set. In the case of
  469. parallel codelets, this has to account for all processing
  470. units involved in the parallel execution.
  471. */
  472. struct starpu_perfmodel *energy_model;
  473. /**
  474. Optional array for statistics collected at runtime: this is
  475. filled by StarPU and should not be accessed directly, but
  476. for example by calling the function
  477. starpu_codelet_display_stats() (See
  478. starpu_codelet_display_stats() for details).
  479. */
  480. unsigned long per_worker_stats[STARPU_NMAXWORKERS];
  481. /**
  482. Optional name of the codelet. This can be useful for
  483. debugging purposes.
  484. */
  485. const char *name;
  486. /**
  487. Optional color of the codelet. This can be useful for
  488. debugging purposes.
  489. */
  490. unsigned color;
  491. /**
  492. Various flags for the codelet.
  493. */
  494. int flags;
  495. };
  496. /**
  497. Describe a data handle along with an access mode.
  498. */
  499. struct starpu_data_descr
  500. {
  501. starpu_data_handle_t handle; /**< data */
  502. enum starpu_data_access_mode mode; /**< access mode */
  503. };
  504. /**
  505. Describe a task that can be offloaded on the various processing
  506. units managed by StarPU. It instantiates a codelet. It can either
  507. be allocated dynamically with the function starpu_task_create(), or
  508. declared statically. In the latter case, the programmer has to zero
  509. the structure starpu_task and to fill the different fields
  510. properly. The indicated default values correspond to the
  511. configuration of a task allocated with starpu_task_create().
  512. */
  513. struct starpu_task
  514. {
  515. /**
  516. Optional name of the task. This can be useful for debugging
  517. purposes.
  518. With starpu_task_insert() and alike this can be specified thanks to
  519. ::STARPU_NAME followed by the const char *.
  520. */
  521. const char *name;
  522. /**
  523. Pointer to the corresponding structure starpu_codelet. This
  524. describes where the kernel should be executed, and supplies
  525. the appropriate implementations. When set to <c>NULL</c>,
  526. no code is executed during the tasks, such empty tasks can
  527. be useful for synchronization purposes.
  528. */
  529. struct starpu_codelet *cl;
  530. /**
  531. When set, specify where the task is allowed to be executed.
  532. When unset, take the value of starpu_codelet::where.
  533. With starpu_task_insert() and alike this can be specified thanks to
  534. ::STARPU_EXECUTE_WHERE followed by an unsigned long long.
  535. */
  536. int32_t where;
  537. /**
  538. Specify the number of buffers. This is only used when
  539. starpu_codelet::nbuffers is \ref STARPU_VARIABLE_NBUFFERS.
  540. With starpu_task_insert() and alike this is automatically computed
  541. when using ::STARPU_DATA_ARRAY and alike.
  542. */
  543. int nbuffers;
  544. /* Keep dyn_handles, dyn_interfaces and dyn_modes before the
  545. * equivalent static arrays, so we can detect dyn_handles
  546. * being NULL while nbuffers being bigger that STARPU_NMAXBUFS
  547. * (otherwise the overflow would put a non-NULL) */
  548. /**
  549. Array of ::starpu_data_handle_t. Specify the handles to the
  550. different pieces of data accessed by the task. The number
  551. of entries in this array must be specified in the field
  552. starpu_codelet::nbuffers. This field should be used for
  553. tasks having a number of datas greater than \ref
  554. STARPU_NMAXBUFS (see \ref SettingManyDataHandlesForATask).
  555. When defining a task, one should either define this field
  556. or the field starpu_task::handles defined below.
  557. With starpu_task_insert() and alike this is automatically filled
  558. when using ::STARPU_DATA_ARRAY and alike.
  559. */
  560. starpu_data_handle_t *dyn_handles;
  561. /**
  562. Array of data pointers to the memory node where execution
  563. will happen, managed by the DSM. Is used when the field
  564. starpu_task::dyn_handles is defined.
  565. This is filled by StarPU.
  566. */
  567. void **dyn_interfaces;
  568. /**
  569. Used only when starpu_codelet::nbuffers is \ref
  570. STARPU_VARIABLE_NBUFFERS.
  571. Array of ::starpu_data_access_mode which describes the
  572. required access modes to the data needed by the codelet
  573. (e.g. ::STARPU_RW). The number of entries in this array
  574. must be specified in the field starpu_codelet::nbuffers.
  575. This field should be used for codelets having a number of
  576. datas greater than \ref STARPU_NMAXBUFS (see \ref
  577. SettingManyDataHandlesForATask).
  578. When defining a codelet, one should either define this
  579. field or the field starpu_task::modes defined below.
  580. With starpu_task_insert() and alike this is automatically filled
  581. when using ::STARPU_DATA_MODE_ARRAY and alike.
  582. */
  583. enum starpu_data_access_mode *dyn_modes;
  584. /**
  585. Array of ::starpu_data_handle_t. Specify the handles to the
  586. different pieces of data accessed by the task. The number
  587. of entries in this array must be specified in the field
  588. starpu_codelet::nbuffers, and should not exceed
  589. \ref STARPU_NMAXBUFS. If unsufficient, this value can be
  590. set with the configure option \ref enable-maxbuffers
  591. "--enable-maxbuffers".
  592. With starpu_task_insert() and alike this is automatically filled
  593. when using ::STARPU_R and alike.
  594. */
  595. starpu_data_handle_t handles[STARPU_NMAXBUFS];
  596. /**
  597. Array of Data pointers to the memory node where execution
  598. will happen, managed by the DSM.
  599. This is filled by StarPU.
  600. */
  601. void *interfaces[STARPU_NMAXBUFS];
  602. /**
  603. Used only when starpu_codelet::nbuffers is \ref
  604. STARPU_VARIABLE_NBUFFERS.
  605. Array of ::starpu_data_access_mode which describes the
  606. required access modes to the data neeeded by the codelet
  607. (e.g. ::STARPU_RW). The number of entries in this array
  608. must be specified in the field starpu_task::nbuffers, and
  609. should not exceed \ref STARPU_NMAXBUFS. If unsufficient,
  610. this value can be set with the configure option
  611. \ref enable-maxbuffers "--enable-maxbuffers".
  612. With starpu_task_insert() and alike this is automatically filled
  613. when using ::STARPU_DATA_MODE_ARRAY and alike.
  614. */
  615. enum starpu_data_access_mode modes[STARPU_NMAXBUFS];
  616. /**
  617. Optional pointer to an array of characters which allows to
  618. define the sequential consistency for each handle for the
  619. current task.
  620. With starpu_task_insert() and alike this can be specified thanks to
  621. ::STARPU_HANDLES_SEQUENTIAL_CONSISTENCY followed by an unsigned char *
  622. */
  623. unsigned char *handles_sequential_consistency;
  624. /**
  625. Optional pointer which is passed to the codelet through the
  626. second argument of the codelet implementation (e.g.
  627. starpu_codelet::cpu_func or starpu_codelet::cuda_func). The
  628. default value is <c>NULL</c>. starpu_codelet_pack_args()
  629. and starpu_codelet_unpack_args() are helpers that can can
  630. be used to respectively pack and unpack data into and from
  631. it, but the application can manage it any way, the only
  632. requirement is that the size of the data must be set in
  633. starpu_task::cl_arg_size .
  634. With starpu_task_insert() and alike this can be specified thanks to
  635. ::STARPU_CL_ARGS followed by a void* and a size_t.
  636. */
  637. void *cl_arg;
  638. /**
  639. Optional field. For some specific drivers, the pointer
  640. starpu_task::cl_arg cannot not be directly given to the
  641. driver function. A buffer of size starpu_task::cl_arg_size
  642. needs to be allocated on the driver. This buffer is then
  643. filled with the starpu_task::cl_arg_size bytes starting at
  644. address starpu_task::cl_arg. In this case, the argument
  645. given to the codelet is therefore not the
  646. starpu_task::cl_arg pointer, but the address of the buffer
  647. in local store (LS) instead. This field is ignored for CPU,
  648. CUDA and OpenCL codelets, where the starpu_task::cl_arg
  649. pointer is given as such.
  650. With starpu_task_insert() and alike this can be specified thanks to
  651. ::STARPU_CL_ARGS followed by a void* and a size_t.
  652. */
  653. size_t cl_arg_size;
  654. /**
  655. Optional field, the default value is <c>NULL</c>. This is a
  656. function pointer of prototype <c>void (*f)(void *)</c>
  657. which specifies a possible callback. If this pointer is
  658. non-<c>NULL</c>, the callback function is executed on the
  659. host after the execution of the task. Tasks which depend on
  660. it might already be executing. The callback is passed the
  661. value contained in the starpu_task::callback_arg field. No
  662. callback is executed if the field is set to <c>NULL</c>.
  663. With starpu_task_insert() and alike this can be specified thanks to
  664. ::STARPU_CALLBACK followed by the function pointer, or thanks to
  665. ::STARPU_CALLBACK_WITH_ARG followed by the function pointer and the argument.
  666. */
  667. void (*callback_func)(void *);
  668. /**
  669. Optional field, the default value is <c>NULL</c>. This is
  670. the pointer passed to the callback function. This field is
  671. ignored if the field starpu_task::callback_func is set to
  672. <c>NULL</c>.
  673. With starpu_task_insert() and alike this can be specified thanks to
  674. ::STARPU_CALLBACK_ARG followed by the function pointer, or thanks to
  675. ::STARPU_CALLBACK_WITH_ARG followed by the function pointer and the argument.
  676. */
  677. void *callback_arg;
  678. /**
  679. Optional field, the default value is <c>NULL</c>. This is a
  680. function pointer of prototype <c>void (*f)(void *)</c>
  681. which specifies a possible callback. If this pointer is
  682. non-<c>NULL</c>, the callback function is executed on the
  683. host when the task becomes ready for execution, before
  684. getting scheduled. The callback is passed the value
  685. contained in the starpu_task::prologue_callback_arg field.
  686. No callback is executed if the field is set to <c>NULL</c>.
  687. With starpu_task_insert() and alike this can be specified thanks to
  688. ::STARPU_PROLOGUE_CALLBACK followed by the function pointer.
  689. */
  690. void (*prologue_callback_func)(void *);
  691. /**
  692. Optional field, the default value is <c>NULL</c>. This is
  693. the pointer passed to the prologue callback function. This
  694. field is ignored if the field
  695. starpu_task::prologue_callback_func is set to <c>NULL</c>.
  696. With starpu_task_insert() and alike this can be specified thanks to
  697. ::STARPU_PROLOGUE_CALLBACK followed by the function pointer.
  698. */
  699. void *prologue_callback_arg;
  700. void (*prologue_callback_pop_func)(void *);
  701. void *prologue_callback_pop_arg;
  702. /**
  703. Optional field. Contain the tag associated to the task if
  704. the field starpu_task::use_tag is set, ignored
  705. otherwise.
  706. With starpu_task_insert() and alike this can be specified thanks to
  707. ::STARPU_TAG followed by a starpu_tag_t.
  708. */
  709. starpu_tag_t tag_id;
  710. /**
  711. Optional field. In case starpu_task::cl_arg was allocated
  712. by the application through <c>malloc()</c>, setting
  713. starpu_task::cl_arg_free to 1 makes StarPU automatically
  714. call <c>free(cl_arg)</c> when destroying the task. This
  715. saves the user from defining a callback just for that. This
  716. is mostly useful when targetting MIC, where the
  717. codelet does not execute in the same memory space as the
  718. main thread.
  719. With starpu_task_insert() and alike this is set to 1 when using
  720. ::STARPU_CL_ARGS.
  721. */
  722. unsigned cl_arg_free:1;
  723. /**
  724. Optional field. In case starpu_task::callback_arg was
  725. allocated by the application through <c>malloc()</c>,
  726. setting starpu_task::callback_arg_free to 1 makes StarPU
  727. automatically call <c>free(callback_arg)</c> when
  728. destroying the task.
  729. TODO: does not have a starpu_task_insert() equivalent
  730. */
  731. unsigned callback_arg_free:1;
  732. /**
  733. Optional field. In case starpu_task::prologue_callback_arg
  734. was allocated by the application through <c>malloc()</c>,
  735. setting starpu_task::prologue_callback_arg_free to 1 makes
  736. StarPU automatically call
  737. <c>free(prologue_callback_arg)</c> when destroying the task.
  738. TODO: does not have a starpu_task_insert() equivalent
  739. */
  740. unsigned prologue_callback_arg_free:1;
  741. /**
  742. Optional field. In case starpu_task::prologue_callback_pop_arg
  743. was allocated by the application through <c>malloc()</c>,
  744. setting starpu_task::prologue_callback_pop_arg_free to 1 makes
  745. StarPU automatically call
  746. <c>free(prologue_callback_pop_arg)</c> when destroying the
  747. task.
  748. TODO: does not have a starpu_task_insert() equivalent
  749. */
  750. unsigned prologue_callback_pop_arg_free:1;
  751. /**
  752. Optional field, the default value is 0. If set, this flag
  753. indicates that the task should be associated with the tag
  754. contained in the starpu_task::tag_id field. Tag allow the
  755. application to synchronize with the task and to express
  756. task dependencies easily.
  757. With starpu_task_insert() and alike this is set to 1 when using
  758. ::STARPU_TAG.
  759. */
  760. unsigned use_tag:1;
  761. /**
  762. If this flag is set (which is the default), sequential
  763. consistency is enforced for the data parameters of this
  764. task for which sequential consistency is enabled. Clearing
  765. this flag permits to disable sequential consistency for
  766. this task, even if data have it enabled.
  767. TODO: does not have a starpu_task_insert() equivalent
  768. */
  769. unsigned sequential_consistency:1;
  770. /**
  771. If this flag is set, the function starpu_task_submit() is
  772. blocking and returns only when the task has been executed
  773. (or if no worker is able to process the task). Otherwise,
  774. starpu_task_submit() returns immediately.
  775. With starpu_task_insert() and alike this can be specified thanks to
  776. ::STARPU_TASK_SYNCHRONOUS followed an int.
  777. */
  778. unsigned synchronous:1;
  779. /**
  780. Default value is 0. If this flag is set, StarPU will bypass
  781. the scheduler and directly affect this task to the worker
  782. specified by the field starpu_task::workerid.
  783. With starpu_task_insert() and alike this is set to 1 when using
  784. ::STARPU_EXECUTE_ON_WORKER.
  785. */
  786. unsigned execute_on_a_specific_worker:1;
  787. /**
  788. Optional field, default value is 1. If this flag is set, it
  789. is not possible to synchronize with the task by the means
  790. of starpu_task_wait() later on. Internal data structures
  791. are only guaranteed to be freed once starpu_task_wait() is
  792. called if the flag is not set.
  793. With starpu_task_insert() and alike this is set to 1.
  794. */
  795. unsigned detach:1;
  796. /**
  797. Optional value. Default value is 0 for starpu_task_init(),
  798. and 1 for starpu_task_create(). If this flag is set, the
  799. task structure will automatically be freed, either after
  800. the execution of the callback if the task is detached, or
  801. during starpu_task_wait() otherwise. If this flag is not
  802. set, dynamically allocated data structures will not be
  803. freed until starpu_task_destroy() is called explicitly.
  804. Setting this flag for a statically allocated task structure
  805. will result in undefined behaviour. The flag is set to 1
  806. when the task is created by calling starpu_task_create().
  807. Note that starpu_task_wait_for_all() will not free any task.
  808. With starpu_task_insert() and alike this is set to 1.
  809. */
  810. unsigned destroy:1;
  811. /**
  812. Optional field. If this flag is set, the task will be
  813. re-submitted to StarPU once it has been executed. This flag
  814. must not be set if the flag starpu_task::destroy is set.
  815. This flag must be set before making another task depend on
  816. this one.
  817. With starpu_task_insert() and alike this is set to 0.
  818. */
  819. unsigned regenerate:1;
  820. /**
  821. @private
  822. This is only used for tasks that use multiformat handle.
  823. This should only be used by StarPU.
  824. */
  825. unsigned mf_skip:1;
  826. /**
  827. do not allocate a submitorder id for this task
  828. TODO: does not have a starpu_task_insert() equivalent
  829. */
  830. unsigned no_submitorder:1;
  831. /**
  832. Whether this task has failed and will thus have to be retried
  833. Set by StarPU.
  834. */
  835. unsigned failed:1;
  836. /**
  837. Whether the scheduler has pushed the task on some queue
  838. Set by StarPU.
  839. */
  840. unsigned scheduled:1;
  841. unsigned prefetched:1;
  842. /**
  843. Optional field. If the field
  844. starpu_task::execute_on_a_specific_worker is set, this
  845. field indicates the identifier of the worker that should
  846. process this task (as returned by starpu_worker_get_id()).
  847. This field is ignored if the field
  848. starpu_task::execute_on_a_specific_worker is set to 0.
  849. With starpu_task_insert() and alike this can be specified thanks to
  850. ::STARPU_EXECUTE_ON_WORKER followed by an int.
  851. */
  852. unsigned workerid;
  853. /**
  854. Optional field. If the field
  855. starpu_task::execute_on_a_specific_worker is set, this
  856. field indicates the per-worker consecutive order in which
  857. tasks should be executed on the worker. Tasks will be
  858. executed in consecutive starpu_task::workerorder values,
  859. thus ignoring the availability order or task priority. See
  860. \ref StaticScheduling for more details. This field is
  861. ignored if the field
  862. starpu_task::execute_on_a_specific_worker is set to 0.
  863. With starpu_task_insert() and alike this can be specified thanks to
  864. ::STARPU_WORKER_ORDER followed by an unsigned.
  865. */
  866. unsigned workerorder;
  867. /**
  868. Optional field. If the field starpu_task::workerids_len is
  869. different from 0, this field indicates an array of bits
  870. (stored as uint32_t values) which indicate the set of
  871. workers which are allowed to execute the task.
  872. starpu_task::workerid takes precedence over this.
  873. TODO: does not have a starpu_task_insert() equivalent
  874. */
  875. uint32_t *workerids;
  876. /**
  877. Optional field. This provides the number of uint32_t values
  878. in the starpu_task::workerids array.
  879. TODO: does not have a starpu_task_insert() equivalent
  880. */
  881. unsigned workerids_len;
  882. /**
  883. Optional field, the default value is ::STARPU_DEFAULT_PRIO.
  884. This field indicates a level of priority for the task. This
  885. is an integer value that must be set between the return
  886. values of the function starpu_sched_get_min_priority() for
  887. the least important tasks, and that of the function
  888. starpu_sched_get_max_priority() for the most important
  889. tasks (included). The ::STARPU_MIN_PRIO and
  890. ::STARPU_MAX_PRIO macros are provided for convenience and
  891. respectively return the value of
  892. starpu_sched_get_min_priority() and
  893. starpu_sched_get_max_priority(). Default priority is
  894. ::STARPU_DEFAULT_PRIO, which is always defined as 0 in
  895. order to allow static task initialization. Scheduling
  896. strategies that take priorities into account can use this
  897. parameter to take better scheduling decisions, but the
  898. scheduling policy may also ignore it.
  899. With starpu_task_insert() and alike this can be specified thanks to
  900. ::STARPU_PRIORITY followed by an unsigned long long.
  901. */
  902. int priority;
  903. /**
  904. Current state of the task.
  905. Set by StarPU.
  906. */
  907. enum starpu_task_status status;
  908. /**
  909. @private
  910. This field is set when initializing a task. The function
  911. starpu_task_submit() will fail if the field does not have
  912. the correct value. This will hence avoid submitting tasks
  913. which have not been properly initialised.
  914. */
  915. int magic;
  916. /**
  917. Allow to get the type of task, for filtering out tasks
  918. in profiling outputs, whether it is really internal to
  919. StarPU (::STARPU_TASK_TYPE_INTERNAL), a data acquisition
  920. synchronization task (::STARPU_TASK_TYPE_DATA_ACQUIRE), or
  921. a normal task (::STARPU_TASK_TYPE_NORMAL)
  922. Set by StarPU.
  923. */
  924. unsigned type;
  925. /**
  926. color of the task to be used in dag.dot.
  927. With starpu_task_insert() and alike this can be specified thanks to
  928. ::STARPU_TASK_COLOR followed by an int.
  929. */
  930. unsigned color;
  931. /**
  932. Scheduling context.
  933. With starpu_task_insert() and alike this can be specified thanks to
  934. ::STARPU_SCHED_CTX followed by an unsigned.
  935. */
  936. unsigned sched_ctx;
  937. /**
  938. Help the hypervisor monitor the execution of this task.
  939. With starpu_task_insert() and alike this can be specified thanks to
  940. ::STARPU_HYPERVISOR_TAG followed by an int.
  941. */
  942. int hypervisor_tag;
  943. /**
  944. TODO: related with sched contexts and parallel tasks
  945. With starpu_task_insert() and alike this can be specified thanks to
  946. ::STARPU_POSSIBLY_PARALLEL followed by an unsigned.
  947. */
  948. unsigned possibly_parallel;
  949. /**
  950. Optional field. The bundle that includes this task. If no
  951. bundle is used, this should be <c>NULL</c>.
  952. */
  953. starpu_task_bundle_t bundle;
  954. /**
  955. Optional field. Profiling information for the task.
  956. TODO: does not have a starpu_task_insert() equivalent
  957. */
  958. struct starpu_profiling_task_info *profiling_info;
  959. /**
  960. This can be set to the number of floating points operations
  961. that the task will have to achieve. This is useful for
  962. easily getting GFlops curves from the tool
  963. <c>starpu_perfmodel_plot</c>, and for the hypervisor load
  964. balancing.
  965. With starpu_task_insert() and alike this can be specified thanks to
  966. ::STARPU_FLOPS followed by a double.
  967. */
  968. double flops;
  969. /**
  970. Output field. Predicted duration of the task. This field is
  971. only set if the scheduling strategy uses performance
  972. models.
  973. Set by StarPU.
  974. */
  975. double predicted;
  976. /**
  977. Output field. Predicted data transfer duration for the task in
  978. microseconds. This field is only valid if the scheduling
  979. strategy uses performance models.
  980. Set by StarPU.
  981. */
  982. double predicted_transfer;
  983. double predicted_start;
  984. /**
  985. @private
  986. A pointer to the previous task. This should only be used by
  987. StarPU schedulers.
  988. */
  989. struct starpu_task *prev;
  990. /**
  991. @private
  992. A pointer to the next task. This should only be used by
  993. StarPU schedulers.
  994. */
  995. struct starpu_task *next;
  996. /**
  997. @private
  998. This is private to StarPU, do not modify.
  999. */
  1000. void *starpu_private;
  1001. #ifdef STARPU_OPENMP
  1002. /**
  1003. @private
  1004. This is private to StarPU, do not modify.
  1005. */
  1006. struct starpu_omp_task *omp_task;
  1007. #else
  1008. void *omp_task;
  1009. #endif
  1010. /**
  1011. @private
  1012. This is private to StarPU, do not modify.
  1013. */
  1014. unsigned nb_termination_call_required;
  1015. /**
  1016. This field is managed by the scheduler, is it allowed to do
  1017. whatever with it. Typically, some area would be allocated on push, and released on pop.
  1018. */
  1019. void *sched_data;
  1020. };
  1021. #define STARPU_TASK_TYPE_NORMAL 0
  1022. #define STARPU_TASK_TYPE_INTERNAL (1<<0)
  1023. #define STARPU_TASK_TYPE_DATA_ACQUIRE (1<<1)
  1024. /**
  1025. Value to be used to initialize statically allocated tasks. This is
  1026. equivalent to initializing a structure starpu_task
  1027. with the function starpu_task_init().
  1028. */
  1029. /* Note: remember to update starpu_task_init as well */
  1030. #define STARPU_TASK_INITIALIZER \
  1031. { \
  1032. .cl = NULL, \
  1033. .where = -1, \
  1034. .cl_arg = NULL, \
  1035. .cl_arg_size = 0, \
  1036. .callback_func = NULL, \
  1037. .callback_arg = NULL, \
  1038. .priority = STARPU_DEFAULT_PRIO, \
  1039. .use_tag = 0, \
  1040. .sequential_consistency = 1, \
  1041. .synchronous = 0, \
  1042. .execute_on_a_specific_worker = 0, \
  1043. .workerorder = 0, \
  1044. .bundle = NULL, \
  1045. .detach = 1, \
  1046. .destroy = 0, \
  1047. .regenerate = 0, \
  1048. .status = STARPU_TASK_INVALID, \
  1049. .profiling_info = NULL, \
  1050. .predicted = NAN, \
  1051. .predicted_transfer = NAN, \
  1052. .predicted_start = NAN, \
  1053. .starpu_private = NULL, \
  1054. .magic = 42, \
  1055. .type = 0, \
  1056. .color = 0, \
  1057. .sched_ctx = STARPU_NMAX_SCHED_CTXS, \
  1058. .hypervisor_tag = 0, \
  1059. .flops = 0.0, \
  1060. .scheduled = 0, \
  1061. .prefetched = 0, \
  1062. .dyn_handles = NULL, \
  1063. .dyn_interfaces = NULL, \
  1064. .dyn_modes = NULL, \
  1065. .name = NULL, \
  1066. .possibly_parallel = 0 \
  1067. }
  1068. /**
  1069. Return the number of buffers for \p task, i.e.
  1070. starpu_codelet::nbuffers, or starpu_task::nbuffers if the former is
  1071. \ref STARPU_VARIABLE_NBUFFERS.
  1072. */
  1073. #define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
  1074. /**
  1075. Return the \p i -th data handle of \p task. If \p task is defined
  1076. with a static or dynamic number of handles, will either return the
  1077. \p i -th element of the field starpu_task::handles or the \p i -th
  1078. element of the field starpu_task::dyn_handles (see \ref
  1079. SettingManyDataHandlesForATask)
  1080. */
  1081. #define STARPU_TASK_GET_HANDLE(task, i) (((task)->dyn_handles) ? (task)->dyn_handles[i] : (task)->handles[i])
  1082. #define STARPU_TASK_GET_HANDLES(task) (((task)->dyn_handles) ? (task)->dyn_handles : (task)->handles)
  1083. /**
  1084. Set the \p i -th data handle of \p task with \p handle. If \p task
  1085. is defined with a static or dynamic number of handles, will either
  1086. set the \p i -th element of the field starpu_task::handles or the
  1087. \p i -th element of the field starpu_task::dyn_handles
  1088. (see \ref SettingManyDataHandlesForATask)
  1089. */
  1090. #define STARPU_TASK_SET_HANDLE(task, handle, i) \
  1091. do { if ((task)->dyn_handles) (task)->dyn_handles[i] = handle; else (task)->handles[i] = handle; } while(0)
  1092. /**
  1093. Return the access mode of the \p i -th data handle of \p codelet.
  1094. If \p codelet is defined with a static or dynamic number of
  1095. handles, will either return the \p i -th element of the field
  1096. starpu_codelet::modes or the \p i -th element of the field
  1097. starpu_codelet::dyn_modes (see \ref SettingManyDataHandlesForATask)
  1098. */
  1099. #define STARPU_CODELET_GET_MODE(codelet, i) \
  1100. (((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
  1101. /**
  1102. Set the access mode of the \p i -th data handle of \p codelet. If
  1103. \p codelet is defined with a static or dynamic number of handles,
  1104. will either set the \p i -th element of the field
  1105. starpu_codelet::modes or the \p i -th element of the field
  1106. starpu_codelet::dyn_modes (see \ref SettingManyDataHandlesForATask)
  1107. */
  1108. #define STARPU_CODELET_SET_MODE(codelet, mode, i) \
  1109. do { if ((codelet)->dyn_modes) (codelet)->dyn_modes[i] = mode; else (codelet)->modes[i] = mode; } while(0)
  1110. /**
  1111. Return the access mode of the \p i -th data handle of \p task. If
  1112. \p task is defined with a static or dynamic number of handles, will
  1113. either return the \p i -th element of the field starpu_task::modes
  1114. or the \p i -th element of the field starpu_task::dyn_modes (see
  1115. \ref SettingManyDataHandlesForATask)
  1116. */
  1117. #define STARPU_TASK_GET_MODE(task, i) \
  1118. ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->dyn_modes ? \
  1119. (((task)->dyn_modes) ? (task)->dyn_modes[i] : (task)->modes[i]) : \
  1120. STARPU_CODELET_GET_MODE((task)->cl, i) )
  1121. /**
  1122. Set the access mode of the \p i -th data handle of \p task. If \p
  1123. task is defined with a static or dynamic number of handles, will
  1124. either set the \p i -th element of the field starpu_task::modes or
  1125. the \p i -th element of the field starpu_task::dyn_modes (see \ref
  1126. SettingManyDataHandlesForATask)
  1127. */
  1128. #define STARPU_TASK_SET_MODE(task, mode, i) \
  1129. do { \
  1130. if ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->cl->nbuffers > STARPU_NMAXBUFS) \
  1131. if ((task)->dyn_modes) (task)->dyn_modes[i] = mode; else (task)->modes[i] = mode; \
  1132. else \
  1133. STARPU_CODELET_SET_MODE((task)->cl, mode, i); \
  1134. } while(0)
  1135. /**
  1136. Return the target node of the \p i -th data handle of \p codelet.
  1137. If \p node is defined with a static or dynamic number of handles,
  1138. will either return the \p i -th element of the field
  1139. starpu_codelet::nodes or the \p i -th element of the field
  1140. starpu_codelet::dyn_nodes (see \ref SettingManyDataHandlesForATask)
  1141. */
  1142. #define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
  1143. /**
  1144. Set the target node of the \p i -th data handle of \p codelet. If
  1145. \p codelet is defined with a static or dynamic number of handles,
  1146. will either set the \p i -th element of the field
  1147. starpu_codelet::nodes or the \p i -th element of the field
  1148. starpu_codelet::dyn_nodes (see \ref SettingManyDataHandlesForATask)
  1149. */
  1150. #define STARPU_CODELET_SET_NODE(codelet, __node, i) \
  1151. do { if ((codelet)->dyn_nodes) (codelet)->dyn_nodes[i] = __node; else (codelet)->nodes[i] = __node; } while(0)
  1152. /**
  1153. Initialize \p task with default values. This function is implicitly
  1154. called by starpu_task_create(). By default, tasks initialized with
  1155. starpu_task_init() must be deinitialized explicitly with
  1156. starpu_task_clean(). Tasks can also be initialized statically,
  1157. using ::STARPU_TASK_INITIALIZER.
  1158. */
  1159. void starpu_task_init(struct starpu_task *task);
  1160. /**
  1161. Release all the structures automatically allocated to execute \p
  1162. task, but not the task structure itself and values set by the user
  1163. remain unchanged. It is thus useful for statically allocated tasks
  1164. for instance. It is also useful when users want to execute the same
  1165. operation several times with as least overhead as possible. It is
  1166. called automatically by starpu_task_destroy(). It has to be called
  1167. only after explicitly waiting for the task or after
  1168. starpu_shutdown() (waiting for the callback is not enough, since
  1169. StarPU still manipulates the task after calling the callback).
  1170. */
  1171. void starpu_task_clean(struct starpu_task *task);
  1172. /**
  1173. Allocate a task structure and initialize it with default values.
  1174. Tasks allocated dynamically with starpu_task_create() are
  1175. automatically freed when the task is terminated. This means that
  1176. the task pointer can not be used any more once the task is
  1177. submitted, since it can be executed at any time (unless
  1178. dependencies make it wait) and thus freed at any time. If the field
  1179. starpu_task::destroy is explicitly unset, the resources used by the
  1180. task have to be freed by calling starpu_task_destroy().
  1181. */
  1182. struct starpu_task *starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC;
  1183. /**
  1184. Free the resource allocated during starpu_task_create() and
  1185. associated with \p task. This function is called automatically
  1186. after the execution of a task when the field starpu_task::destroy
  1187. is set, which is the default for tasks created by
  1188. starpu_task_create(). Calling this function on a statically
  1189. allocated task results in an undefined behaviour.
  1190. */
  1191. void starpu_task_destroy(struct starpu_task *task);
  1192. /**
  1193. Submit \p task to StarPU. Calling this function does not mean that
  1194. the task will be executed immediately as there can be data or task
  1195. (tag) dependencies that are not fulfilled yet: StarPU will take
  1196. care of scheduling this task with respect to such dependencies.
  1197. This function returns immediately if the field
  1198. starpu_task::synchronous is set to 0, and block until the
  1199. termination of the task otherwise. It is also possible to
  1200. synchronize the application with asynchronous tasks by the means of
  1201. tags, using the function starpu_tag_wait() function for instance.
  1202. In case of success, this function returns 0, a return value of
  1203. <c>-ENODEV</c> means that there is no worker able to process this
  1204. task (e.g. there is no GPU available and this task is only
  1205. implemented for CUDA devices). starpu_task_submit() can be called
  1206. from anywhere, including codelet functions and callbacks, provided
  1207. that the field starpu_task::synchronous is set to 0.
  1208. */
  1209. int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
  1210. /**
  1211. Submit \p task to StarPU with dependency bypass.
  1212. This can only be called on behalf of another task which has already taken the
  1213. proper dependencies, e.g. this task is just an attempt of doing the actual
  1214. computation of that task.
  1215. */
  1216. int starpu_task_submit_nodeps(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
  1217. /**
  1218. Submit \p task to the context \p sched_ctx_id. By default,
  1219. starpu_task_submit() submits the task to a global context that is
  1220. created automatically by StarPU.
  1221. */
  1222. int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id);
  1223. int starpu_task_finished(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
  1224. /**
  1225. Block until \p task has been executed. It is not possible to
  1226. synchronize with a task more than once. It is not possible to wait
  1227. for synchronous or detached tasks. Upon successful completion, this
  1228. function returns 0. Otherwise, <c>-EINVAL</c> indicates that the
  1229. specified task was either synchronous or detached.
  1230. */
  1231. int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
  1232. /**
  1233. Allow to wait for an array of tasks. Upon successful completion,
  1234. this function returns 0. Otherwise, <c>-EINVAL</c> indicates that
  1235. one of the tasks was either synchronous or detached.
  1236. */
  1237. int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT;
  1238. /**
  1239. Block until all the tasks that were submitted (to the current
  1240. context or the global one if there is no current context) are
  1241. terminated. It does not destroy these tasks.
  1242. */
  1243. int starpu_task_wait_for_all(void);
  1244. /**
  1245. Block until there are \p n submitted tasks left (to the current
  1246. context or the global one if there is no current context) to be
  1247. executed. It does not destroy these tasks.
  1248. */
  1249. int starpu_task_wait_for_n_submitted(unsigned n);
  1250. /**
  1251. Wait until all the tasks that were already submitted to the context
  1252. \p sched_ctx_id have been terminated.
  1253. */
  1254. int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id);
  1255. /**
  1256. Wait until there are \p n tasks submitted left to be
  1257. executed that were already submitted to the context \p
  1258. sched_ctx_id.
  1259. */
  1260. int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n);
  1261. /**
  1262. Wait until there is no more ready task.
  1263. */
  1264. int starpu_task_wait_for_no_ready(void);
  1265. /**
  1266. Return the number of submitted tasks which are ready for execution
  1267. are already executing. It thus does not include tasks waiting for
  1268. dependencies.
  1269. */
  1270. int starpu_task_nready(void);
  1271. /**
  1272. Return the number of submitted tasks which have not completed yet.
  1273. */
  1274. int starpu_task_nsubmitted(void);
  1275. /**
  1276. Set the iteration number for all the tasks to be submitted after
  1277. this call. This is typically called at the beginning of a task
  1278. submission loop. This number will then show up in tracing tools. A
  1279. corresponding starpu_iteration_pop() call must be made to match the
  1280. call to starpu_iteration_push(), at the end of the same task
  1281. submission loop, typically.
  1282. Nested calls to starpu_iteration_push() and starpu_iteration_pop()
  1283. are allowed, to describe a loop nest for instance, provided that
  1284. they match properly.
  1285. */
  1286. void starpu_iteration_push(unsigned long iteration);
  1287. /**
  1288. Drop the iteration number for submitted tasks. This must match a
  1289. previous call to starpu_iteration_push(), and is typically called
  1290. at the end of a task submission loop.
  1291. */
  1292. void starpu_iteration_pop(void);
  1293. void starpu_do_schedule(void);
  1294. /**
  1295. Initialize \p cl with default values. Codelets should preferably be
  1296. initialized statically as shown in \ref DefiningACodelet. However
  1297. such a initialisation is not always possible, e.g. when using C++.
  1298. */
  1299. void starpu_codelet_init(struct starpu_codelet *cl);
  1300. /**
  1301. Output on \c stderr some statistics on the codelet \p cl.
  1302. */
  1303. void starpu_codelet_display_stats(struct starpu_codelet *cl);
  1304. /**
  1305. Return the task currently executed by the worker, or <c>NULL</c> if
  1306. it is called either from a thread that is not a task or simply
  1307. because there is no task being executed at the moment.
  1308. */
  1309. struct starpu_task *starpu_task_get_current(void);
  1310. /**
  1311. Return the memory node number of parameter \p i of the task
  1312. currently executed, or -1 if it is called either from a thread that
  1313. is not a task or simply because there is no task being executed at
  1314. the moment.
  1315. Usually, the returned memory node number is simply the memory node
  1316. for the current worker. That may however be different when using
  1317. e.g. starpu_codelet::specific_nodes.
  1318. */
  1319. int starpu_task_get_current_data_node(unsigned i);
  1320. /**
  1321. Return the name of the performance model of \p task.
  1322. */
  1323. const char *starpu_task_get_model_name(struct starpu_task *task);
  1324. /**
  1325. Return the name of \p task, i.e. either its starpu_task::name
  1326. field, or the name of the corresponding performance model.
  1327. */
  1328. const char *starpu_task_get_name(struct starpu_task *task);
  1329. /**
  1330. Allocate a task structure which is the exact duplicate of \p task.
  1331. */
  1332. struct starpu_task *starpu_task_dup(struct starpu_task *task);
  1333. /**
  1334. This function should be called by schedulers to specify the
  1335. codelet implementation to be executed when executing \p task.
  1336. */
  1337. void starpu_task_set_implementation(struct starpu_task *task, unsigned impl);
  1338. /**
  1339. Return the codelet implementation to be executed
  1340. when executing \p task.
  1341. */
  1342. unsigned starpu_task_get_implementation(struct starpu_task *task);
  1343. /**
  1344. Create (and submit) an empty task that unlocks a tag once all its
  1345. dependencies are fulfilled.
  1346. */
  1347. void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void (*callback)(void *), void *callback_arg);
  1348. /**
  1349. Function to be used as a prologue callback to enable fault tolerance for the
  1350. task. This prologue will create a try-task, i.e a duplicate of the task,
  1351. which will to the actual computation.
  1352. The prologue argument can be set to a check_ft function that will be
  1353. called on termination of the duplicate, which can check the result of the
  1354. task, and either confirm success, or resubmit another attempt.
  1355. If it is not set, the default implementation is to just resubmit a new
  1356. try-task.
  1357. */
  1358. void starpu_task_ft_prologue(void *check_ft);
  1359. /**
  1360. Create a try-task for a \p meta_task, given a \p template_task task
  1361. template. The meta task can be passed as template on the first call, but
  1362. since it is mangled by starpu_task_ft_create_retry(), further calls
  1363. (typically made by the check_ft callback) need to be passed the previous
  1364. try-task as template task.
  1365. \p check_ft is similar to the prologue argument of
  1366. starpu_task_ft_prologue(), and is typicall set to the very function calling
  1367. starpu_task_ft_create_retry().
  1368. The try-task is returned, and can be modified (e.g. to change scheduling
  1369. parameters) before being submitted with starpu_task_submit_nodeps().
  1370. */
  1371. struct starpu_task * starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void (*check_ft)(void*));
  1372. /**
  1373. Record that this task failed, and should thus be retried.
  1374. This is usually called from the task codelet function itself, after checking
  1375. the result and noticing that the computation went wrong, and thus the task
  1376. should be retried. The performance of this task execution will not be
  1377. recorded for performance models.
  1378. This can only be called for a task whose data access modes are either
  1379. STARPU_R and STARPU_W.
  1380. */
  1381. void starpu_task_ft_failed(struct starpu_task *task);
  1382. /**
  1383. Notify that the try-task was successful and thus the meta-task was
  1384. successful.
  1385. */
  1386. void starpu_task_ft_success(struct starpu_task *meta_task);
  1387. /** @} */
  1388. #ifdef __cplusplus
  1389. }
  1390. #endif
  1391. #endif /* __STARPU_TASK_H__ */