starpu-data-interfaces.h 9.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224
  1. /*
  2. * StarPU
  3. * Copyright (C) INRIA 2008-2009 (see AUTHORS file)
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU Lesser General Public License as published by
  7. * the Free Software Foundation; either version 2.1 of the License, or (at
  8. * your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful, but
  11. * WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  13. *
  14. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  15. */
  16. #ifndef __STARPU_DATA_INTERFACES_H__
  17. #define __STARPU_DATA_INTERFACES_H__
  18. #include <starpu.h>
  19. #include <starpu-data.h>
  20. #ifdef __cplusplus
  21. extern "C" {
  22. #endif
  23. /* "node" means memory node: 0 for main RAM, then 1, 2, etc. for various GPUs,
  24. * etc.
  25. *
  26. * On registration, the source of data is usually a pointer in RAM, in which
  27. * case 0 should be passed.
  28. */
  29. void *starpu_data_get_interface_on_node(starpu_data_handle handle, unsigned memory_node);
  30. /* Matrix interface for dense matrices */
  31. typedef struct starpu_matrix_interface_s {
  32. uintptr_t ptr;
  33. uint32_t nx;
  34. uint32_t ny;
  35. uint32_t ld;
  36. size_t elemsize;
  37. } starpu_matrix_interface_t;
  38. void starpu_register_matrix_data(starpu_data_handle *handle, uint32_t home_node,
  39. uintptr_t ptr, uint32_t ld, uint32_t nx,
  40. uint32_t ny, size_t elemsize);
  41. uint32_t starpu_get_matrix_nx(starpu_data_handle handle);
  42. uint32_t starpu_get_matrix_ny(starpu_data_handle handle);
  43. uint32_t starpu_get_matrix_local_ld(starpu_data_handle handle);
  44. uintptr_t starpu_get_matrix_local_ptr(starpu_data_handle handle);
  45. size_t starpu_get_matrix_elemsize(starpu_data_handle handle);
  46. /* helper methods */
  47. #define STARPU_GET_MATRIX_PTR(interface) (((starpu_matrix_interface_t *)(interface))->ptr)
  48. #define STARPU_GET_MATRIX_NX(interface) (((starpu_matrix_interface_t *)(interface))->nx)
  49. #define STARPU_GET_MATRIX_NY(interface) (((starpu_matrix_interface_t *)(interface))->ny)
  50. #define STARPU_GET_MATRIX_LD(interface) (((starpu_matrix_interface_t *)(interface))->ld)
  51. #define STARPU_GET_MATRIX_ELEMSIZE(interface) (((starpu_matrix_interface_t *)(interface))->elemsize)
  52. /* BLOCK interface for 3D dense blocks */
  53. typedef struct starpu_block_interface_s {
  54. uintptr_t ptr;
  55. uint32_t nx;
  56. uint32_t ny;
  57. uint32_t nz;
  58. uint32_t ldy; /* number of elements between two lines */
  59. uint32_t ldz; /* number of elements between two planes */
  60. size_t elemsize;
  61. } starpu_block_interface_t;
  62. void starpu_register_block_data(starpu_data_handle *handle, uint32_t home_node,
  63. uintptr_t ptr, uint32_t ldy, uint32_t ldz, uint32_t nx,
  64. uint32_t ny, uint32_t nz, size_t elemsize);
  65. uint32_t starpu_get_block_nx(starpu_data_handle handle);
  66. uint32_t starpu_get_block_ny(starpu_data_handle handle);
  67. uint32_t starpu_get_block_nz(starpu_data_handle handle);
  68. uint32_t starpu_get_block_local_ldy(starpu_data_handle handle);
  69. uint32_t starpu_get_block_local_ldz(starpu_data_handle handle);
  70. uintptr_t starpu_get_block_local_ptr(starpu_data_handle handle);
  71. size_t starpu_get_block_elemsize(starpu_data_handle handle);
  72. /* helper methods */
  73. #define STARPU_GET_BLOCK_PTR(interface) (((starpu_block_interface_t *)(interface))->ptr)
  74. #define STARPU_GET_BLOCK_NX(interface) (((starpu_block_interface_t *)(interface))->nx)
  75. #define STARPU_GET_BLOCK_NY(interface) (((starpu_block_interface_t *)(interface))->ny)
  76. #define STARPU_GET_BLOCK_NZ(interface) (((starpu_block_interface_t *)(interface))->nz)
  77. #define STARPU_GET_BLOCK_LDY(interface) (((starpu_block_interface_t *)(interface))->ldy)
  78. #define STARPU_GET_BLOCK_LDZ(interface) (((starpu_block_interface_t *)(interface))->ldz)
  79. #define STARPU_GET_BLOCK_ELEMSIZE(interface) (((starpu_block_interface_t *)(interface))->elemsize)
  80. /* vector interface for contiguous (non-strided) buffers */
  81. typedef struct starpu_vector_interface_s {
  82. uintptr_t ptr;
  83. uint32_t nx;
  84. size_t elemsize;
  85. } starpu_vector_interface_t;
  86. void starpu_register_vector_data(starpu_data_handle *handle, uint32_t home_node,
  87. uintptr_t ptr, uint32_t nx, size_t elemsize);
  88. uint32_t starpu_get_vector_nx(starpu_data_handle handle);
  89. size_t starpu_get_vector_elemsize(starpu_data_handle handle);
  90. uintptr_t starpu_get_vector_local_ptr(starpu_data_handle handle);
  91. /* helper methods */
  92. #define STARPU_GET_VECTOR_PTR(interface) (((starpu_vector_interface_t *)(interface))->ptr)
  93. #define STARPU_GET_VECTOR_NX(interface) (((starpu_vector_interface_t *)(interface))->nx)
  94. #define STARPU_GET_VECTOR_ELEMSIZE(interface) (((starpu_vector_interface_t *)(interface))->elemsize)
  95. /* variable interface for a single data (not a vector, a matrix, a list, ...) */
  96. typedef struct starpu_variable_interface_s {
  97. uintptr_t ptr;
  98. size_t elemsize;
  99. } starpu_variable_interface_t;
  100. void starpu_register_variable_data(starpu_data_handle *handle, uint32_t home_node,
  101. uintptr_t ptr, size_t elemsize);
  102. size_t starpu_get_variable_elemsize(starpu_data_handle handle);
  103. uintptr_t starpu_get_variable_local_ptr(starpu_data_handle handle);
  104. /* helper methods */
  105. #define STARPU_GET_VARIABLE_PTR(interface) (((starpu_variable_interface_t *)(interface))->ptr)
  106. #define STARPU_GET_VARIABLE_ELEMSIZE(interface) (((starpu_variable_interface_t *)(interface))->elemsize)
  107. /* CSR interface for sparse matrices (compressed sparse row representation) */
  108. typedef struct starpu_csr_interface_s {
  109. uint32_t nnz; /* number of non-zero entries */
  110. uint32_t nrow; /* number of rows */
  111. uintptr_t nzval; /* non-zero values */
  112. uint32_t *colind; /* position of non-zero entried on the row */
  113. uint32_t *rowptr; /* index (in nzval) of the first entry of the row */
  114. /* k for k-based indexing (0 or 1 usually) */
  115. /* also useful when partitionning the matrix ... */
  116. uint32_t firstentry;
  117. size_t elemsize;
  118. } starpu_csr_interface_t;
  119. void starpu_register_csr_data(starpu_data_handle *handle, uint32_t home_node, uint32_t nnz, uint32_t nrow,
  120. uintptr_t nzval, uint32_t *colind, uint32_t *rowptr, uint32_t firstentry, size_t elemsize);
  121. uint32_t starpu_get_csr_nnz(starpu_data_handle handle);
  122. uint32_t starpu_get_csr_nrow(starpu_data_handle handle);
  123. uint32_t starpu_get_csr_firstentry(starpu_data_handle handle);
  124. uintptr_t starpu_get_csr_local_nzval(starpu_data_handle handle);
  125. uint32_t *starpu_get_csr_local_colind(starpu_data_handle handle);
  126. uint32_t *starpu_get_csr_local_rowptr(starpu_data_handle handle);
  127. size_t starpu_get_csr_elemsize(starpu_data_handle handle);
  128. #define STARPU_GET_CSR_NNZ(interface) (((starpu_csr_interface_t *)(interface))->nnz)
  129. #define STARPU_GET_CSR_NROW(interface) (((starpu_csr_interface_t *)(interface))->nrow)
  130. #define STARPU_GET_CSR_NZVAL(interface) (((starpu_csr_interface_t *)(interface))->nzval)
  131. #define STARPU_GET_CSR_COLIND(interface) (((starpu_csr_interface_t *)(interface))->colind)
  132. #define STARPU_GET_CSR_ROWPTR(interface) (((starpu_csr_interface_t *)(interface))->rowptr)
  133. #define STARPU_GET_CSR_FIRSTENTRY(interface) (((starpu_csr_interface_t *)(interface))->firstentry)
  134. #define STARPU_GET_CSR_ELEMSIZE(interface) (((starpu_csr_interface_t *)(interface))->elemsize)
  135. /* CSC interface for sparse matrices (compressed sparse column representation) */
  136. typedef struct starpu_csc_interface_s {
  137. int nnz; /* number of non-zero entries */
  138. int nrow; /* number of rows */
  139. float *nzval; /* non-zero values */
  140. int *colind; /* position of non-zero entried on the row */
  141. int *rowptr; /* index (in nzval) of the first entry of the row */
  142. /* k for k-based indexing (0 or 1 usually) */
  143. /* also useful when partitionning the matrix ... */
  144. int firstentry;
  145. } starpu_csc_interface_t;
  146. /* BCSR interface for sparse matrices (blocked compressed sparse row
  147. * representation) */
  148. typedef struct starpu_bcsr_interface_s {
  149. uint32_t nnz; /* number of non-zero BLOCKS */
  150. uint32_t nrow; /* number of rows (in terms of BLOCKS) */
  151. uintptr_t nzval; /* non-zero values */
  152. uint32_t *colind; /* position of non-zero entried on the row */
  153. // uint32_t *rowind; /* position of non-zero entried on the col */
  154. uint32_t *rowptr; /* index (in nzval) of the first entry of the row */
  155. /* k for k-based indexing (0 or 1 usually) */
  156. /* also useful when partitionning the matrix ... */
  157. uint32_t firstentry;
  158. /* size of the blocks */
  159. uint32_t r;
  160. uint32_t c;
  161. size_t elemsize;
  162. } starpu_bcsr_interface_t;
  163. void starpu_register_bcsr_data(starpu_data_handle *handle, uint32_t home_node, uint32_t nnz, uint32_t nrow,
  164. uintptr_t nzval, uint32_t *colind, uint32_t *rowptr, uint32_t firstentry, uint32_t r, uint32_t c, size_t elemsize);
  165. uint32_t starpu_get_bcsr_nnz(starpu_data_handle);
  166. uint32_t starpu_get_bcsr_nrow(starpu_data_handle);
  167. uint32_t starpu_get_bcsr_firstentry(starpu_data_handle);
  168. uintptr_t starpu_get_bcsr_local_nzval(starpu_data_handle);
  169. uint32_t *starpu_get_bcsr_local_colind(starpu_data_handle);
  170. uint32_t *starpu_get_bcsr_local_rowptr(starpu_data_handle);
  171. uint32_t starpu_get_bcsr_r(starpu_data_handle);
  172. uint32_t starpu_get_bcsr_c(starpu_data_handle);
  173. size_t starpu_get_bcsr_elemsize(starpu_data_handle);
  174. #define STARPU_MATRIX_INTERFACE_ID 0
  175. #define STARPU_BLOCK_INTERFACE_ID 1
  176. #define STARPU_VECTOR_INTERFACE_ID 2
  177. #define STARPU_CSR_INTERFACE_ID 3
  178. #define STARPU_CSC_INTERFACE_ID 4
  179. #define STARPU_BCSCR_INTERFACE_ID 5
  180. #define STARPU_VARIABLE_INTERFACE_ID 6
  181. #define STARPU_NINTERFACES_ID 7 /* number of data interfaces */
  182. unsigned starpu_get_handle_interface_id(starpu_data_handle);
  183. #ifdef __cplusplus
  184. }
  185. #endif
  186. #endif // __STARPU_DATA_INTERFACES_H__