starpu.h 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2009-2011 Université de Bordeaux 1
  4. * Copyright (C) 2010, 2011, 2012 Centre National de la Recherche Scientifique
  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. #ifndef __STARPU_H__
  18. #define __STARPU_H__
  19. #include <stdlib.h>
  20. #ifndef _MSC_VER
  21. #include <stdint.h>
  22. #else
  23. typedef unsigned char uint8_t;
  24. typedef unsigned short uint16_t;
  25. typedef unsigned long uint32_t;
  26. typedef unsigned long long uint64_t;
  27. #endif
  28. #include <starpu_config.h>
  29. #ifdef STARPU_HAVE_WINDOWS
  30. #include <windows.h>
  31. #endif
  32. #include <starpu_util.h>
  33. #include <starpu_data.h>
  34. #include <starpu_data_interfaces.h>
  35. #include <starpu_data_filters.h>
  36. #include <starpu_perfmodel.h>
  37. #include <starpu_task.h>
  38. #include <starpu_task_list.h>
  39. #include <starpu_scheduler.h>
  40. #include <starpu_expert.h>
  41. #include <starpu_rand.h>
  42. #ifdef __cplusplus
  43. extern "C"
  44. {
  45. #endif
  46. struct starpu_conf
  47. {
  48. /* which scheduling policy should be used ? (NULL for default) */
  49. const char *sched_policy_name;
  50. struct starpu_sched_policy *sched_policy;
  51. /* number of CPU workers (-1 for default) */
  52. int ncpus;
  53. /* number of CUDA GPU workers (-1 for default) */
  54. int ncuda;
  55. /* number of GPU OpenCL device workers (-1 for default) */
  56. int nopencl;
  57. /* number of Cell's SPUs (-1 for default) */
  58. int nspus;
  59. unsigned use_explicit_workers_bindid;
  60. unsigned workers_bindid[STARPU_NMAXWORKERS];
  61. unsigned use_explicit_workers_cuda_gpuid;
  62. unsigned workers_cuda_gpuid[STARPU_NMAXWORKERS];
  63. unsigned use_explicit_workers_opencl_gpuid;
  64. unsigned workers_opencl_gpuid[STARPU_NMAXWORKERS];
  65. /* calibrate performance models, if any (-1 for default) */
  66. int calibrate;
  67. /* Create only one combined worker, containing all CPU workers */
  68. int single_combined_worker;
  69. /* indicate if the asynchronous copies should be disabled */
  70. int disable_asynchronous_copy;
  71. };
  72. /* Initialize a starpu_conf structure with default values. */
  73. int starpu_conf_init(struct starpu_conf *conf);
  74. /* Initialization method: it must be called prior to any other StarPU call
  75. * Default configuration is used if NULL is passed as argument.
  76. */
  77. int starpu_init(struct starpu_conf *conf) STARPU_WARN_UNUSED_RESULT;
  78. /* Shutdown method: note that statistics are only generated once StarPU is
  79. * shutdown */
  80. void starpu_shutdown(void);
  81. /* This function returns the number of workers (ie. processing units executing
  82. * StarPU tasks). The returned value should be at most STARPU_NMAXWORKERS. */
  83. unsigned starpu_worker_get_count(void);
  84. unsigned starpu_combined_worker_get_count(void);
  85. unsigned starpu_cpu_worker_get_count(void);
  86. unsigned starpu_cuda_worker_get_count(void);
  87. unsigned starpu_spu_worker_get_count(void);
  88. unsigned starpu_opencl_worker_get_count(void);
  89. int starpu_asynchronous_copy_disabled();
  90. /* Return the identifier of the thread in case this is associated to a worker.
  91. * This will return -1 if this function is called directly from the application
  92. * or if it is some SPU worker where a single thread controls different SPUs. */
  93. int starpu_worker_get_id(void);
  94. int starpu_combined_worker_get_id(void);
  95. int starpu_combined_worker_get_size(void);
  96. int starpu_combined_worker_get_rank(void);
  97. enum starpu_archtype
  98. {
  99. STARPU_CPU_WORKER, /* CPU core */
  100. STARPU_CUDA_WORKER, /* NVIDIA CUDA device */
  101. STARPU_OPENCL_WORKER, /* OpenCL CUDA device */
  102. STARPU_GORDON_WORKER /* Cell SPU */
  103. };
  104. /* This function returns the type of worker associated to an identifier (as
  105. * returned by the starpu_worker_get_id function). The returned value indicates
  106. * the architecture of the worker: STARPU_CPU_WORKER for a CPU core,
  107. * STARPU_CUDA_WORKER for a CUDA device, and STARPU_GORDON_WORKER for a Cell
  108. * SPU. The value returned for an invalid identifier is unspecified. */
  109. enum starpu_archtype starpu_worker_get_type(int id);
  110. /* Returns the number of workers of the type indicated by the argument. A
  111. * positive (or null) value is returned in case of success, -EINVAL indicates
  112. * that the type is not valid otherwise. */
  113. int starpu_worker_get_count_by_type(enum starpu_archtype type);
  114. /* Fill the workerids array with the identifiers of the workers that have the
  115. * type indicated in the first argument. The maxsize argument indicates the
  116. * size of the workids array. The returned value gives the number of
  117. * identifiers that were put in the array. -ERANGE is returned is maxsize is
  118. * lower than the number of workers with the appropriate type: in that case,
  119. * the array is filled with the maxsize first elements. To avoid such
  120. * overflows, the value of maxsize can be chosen by the means of the
  121. * starpu_worker_get_count_by_type function, or by passing a value greater or
  122. * equal to STARPU_NMAXWORKERS. */
  123. int starpu_worker_get_ids_by_type(enum starpu_archtype type, int *workerids, int maxsize);
  124. /* StarPU associates a unique human readable string to each processing unit.
  125. * This function copies at most the "maxlen" first bytes of the unique
  126. * string associated to a worker identified by its identifier "id" into
  127. * the "dst" buffer. The caller is responsible for ensuring that the
  128. * "dst" is a valid pointer to a buffer of "maxlen" bytes at least.
  129. * Calling this function on an invalid identifier results in an unspecified
  130. * behaviour. */
  131. void starpu_worker_get_name(int id, char *dst, size_t maxlen);
  132. /* This functions returns the device id of the worker associated to an
  133. * identifier (as returned by the starpu_worker_get_id() function)
  134. */
  135. int starpu_worker_get_devid(int id);
  136. #ifdef __cplusplus
  137. }
  138. #endif
  139. #if defined(STARPU_USE_DEPRECATED_API)
  140. #include "starpu_deprecated_api.h"
  141. #endif /* STARPU_USE_DEPRECATED_API */
  142. #endif /* __STARPU_H__ */