xlu_kernels.c 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2009-2021 Université de Bordeaux, CNRS (LaBRI UMR 5800), Inria
  4. *
  5. * StarPU 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. * StarPU 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. /* LU Kernels */
  17. #include "xlu.h"
  18. #include <math.h>
  19. #include <complex.h>
  20. #ifdef STARPU_USE_CUDA
  21. #include <cublas.h>
  22. #include <starpu_cublas_v2.h>
  23. #endif
  24. #define str(s) #s
  25. #define xstr(s) str(s)
  26. #define STARPU_LU_STR(name) xstr(STARPU_LU(name))
  27. #ifdef STARPU_USE_CUDA
  28. static const TYPE p1 = 1.0f;
  29. static const TYPE m1 = -1.0f;
  30. #endif
  31. /*
  32. * U22
  33. */
  34. static inline void STARPU_LU(common_u22)(void *descr[], int s, void *_args)
  35. {
  36. (void)_args;
  37. TYPE *right = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  38. TYPE *left = (TYPE *)STARPU_MATRIX_GET_PTR(descr[1]);
  39. TYPE *center = (TYPE *)STARPU_MATRIX_GET_PTR(descr[2]);
  40. unsigned dx = STARPU_MATRIX_GET_NX(descr[2]);
  41. unsigned dy = STARPU_MATRIX_GET_NY(descr[2]);
  42. unsigned dz = STARPU_MATRIX_GET_NY(descr[0]);
  43. unsigned ld12 = STARPU_MATRIX_GET_LD(descr[0]);
  44. unsigned ld21 = STARPU_MATRIX_GET_LD(descr[1]);
  45. unsigned ld22 = STARPU_MATRIX_GET_LD(descr[2]);
  46. #ifdef STARPU_USE_CUDA
  47. cublasStatus status;
  48. #endif
  49. switch (s)
  50. {
  51. case 0:
  52. CPU_GEMM("N", "N", dy, dx, dz,
  53. (TYPE)-1.0, right, ld21, left, ld12,
  54. (TYPE)1.0, center, ld22);
  55. break;
  56. #ifdef STARPU_USE_CUDA
  57. case 1:
  58. {
  59. status = CUBLAS_GEMM(starpu_cublas_get_local_handle(),
  60. CUBLAS_OP_N, CUBLAS_OP_N, dx, dy, dz,
  61. (CUBLAS_TYPE *)&m1, (CUBLAS_TYPE *)right, ld21, (CUBLAS_TYPE *)left, ld12,
  62. (CUBLAS_TYPE *)&p1, (CUBLAS_TYPE *)center, ld22);
  63. if (STARPU_UNLIKELY(status != CUBLAS_STATUS_SUCCESS))
  64. STARPU_CUBLAS_REPORT_ERROR(status);
  65. break;
  66. }
  67. #endif
  68. default:
  69. STARPU_ABORT();
  70. break;
  71. }
  72. }
  73. void STARPU_LU(cpu_u22)(void *descr[], void *_args)
  74. {
  75. STARPU_LU(common_u22)(descr, 0, _args);
  76. }
  77. #ifdef STARPU_USE_CUDA
  78. void STARPU_LU(cublas_u22)(void *descr[], void *_args)
  79. {
  80. STARPU_LU(common_u22)(descr, 1, _args);
  81. }
  82. #endif /* STARPU_USE_CUDA */
  83. static struct starpu_perfmodel STARPU_LU(model_22) =
  84. {
  85. .type = STARPU_HISTORY_BASED,
  86. #ifdef STARPU_ATLAS
  87. .symbol = STARPU_LU_STR(lu_model_22_atlas)
  88. #elif defined(STARPU_GOTO)
  89. .symbol = STARPU_LU_STR(lu_model_22_goto)
  90. #elif defined(STARPU_OPENBLAS)
  91. .symbol = STARPU_LU_STR(lu_model_22_openblas)
  92. #else
  93. .symbol = STARPU_LU_STR(lu_model_22)
  94. #endif
  95. };
  96. #ifdef STARPU_USE_CUDA
  97. static int can_execute(unsigned workerid, struct starpu_task *task, unsigned nimpl)
  98. {
  99. (void)task;
  100. (void)nimpl;
  101. enum starpu_worker_archtype type = starpu_worker_get_type(workerid);
  102. if (type == STARPU_CPU_WORKER)
  103. return 1;
  104. #ifdef STARPU_SIMGRID
  105. /* We don't know, let's assume it can */
  106. return 1;
  107. #else
  108. /* Cuda device */
  109. const struct cudaDeviceProp *props;
  110. props = starpu_cuda_get_device_properties(workerid);
  111. if (props->major >= 2 || props->minor >= 3)
  112. {
  113. /* At least compute capability 1.3, supports doubles */
  114. return 1;
  115. }
  116. else
  117. {
  118. /* Old card does not support doubles */
  119. return 0;
  120. }
  121. #endif
  122. }
  123. #endif
  124. #define STRINGIFY_(x) #x
  125. #define STRINGIFY(x) STRINGIFY_(x)
  126. struct starpu_codelet cl22 =
  127. {
  128. .cpu_funcs = {STARPU_LU(cpu_u22)},
  129. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_u22))},
  130. #ifdef STARPU_USE_CUDA
  131. .cuda_funcs = {STARPU_LU(cublas_u22)},
  132. CAN_EXECUTE
  133. #elif defined(STARPU_SIMGRID)
  134. .cuda_funcs = {(void*)1},
  135. #endif
  136. .cuda_flags = {STARPU_CUDA_ASYNC},
  137. .nbuffers = 3,
  138. .modes = {STARPU_R, STARPU_R, STARPU_RW},
  139. .model = &STARPU_LU(model_22)
  140. };
  141. /*
  142. * U12
  143. */
  144. static inline void STARPU_LU(common_u12)(void *descr[], int s, void *_args)
  145. {
  146. (void)_args;
  147. TYPE *sub11;
  148. TYPE *sub12;
  149. sub11 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  150. sub12 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[1]);
  151. unsigned ld11 = STARPU_MATRIX_GET_LD(descr[0]);
  152. unsigned ld12 = STARPU_MATRIX_GET_LD(descr[1]);
  153. unsigned nx12 = STARPU_MATRIX_GET_NX(descr[1]);
  154. unsigned ny12 = STARPU_MATRIX_GET_NY(descr[1]);
  155. #ifdef STARPU_USE_CUDA
  156. cublasStatus status;
  157. #endif
  158. /* solve L11 U12 = A12 (find U12) */
  159. switch (s)
  160. {
  161. case 0:
  162. CPU_TRSM("L", "L", "N", "N", nx12, ny12,
  163. (TYPE)1.0, sub11, ld11, sub12, ld12);
  164. break;
  165. #ifdef STARPU_USE_CUDA
  166. case 1:
  167. status = CUBLAS_TRSM(starpu_cublas_get_local_handle(),
  168. CUBLAS_SIDE_LEFT, CUBLAS_FILL_MODE_LOWER, CUBLAS_OP_N, CUBLAS_DIAG_NON_UNIT,
  169. ny12, nx12,
  170. (CUBLAS_TYPE*)&p1, (CUBLAS_TYPE*)sub11, ld11, (CUBLAS_TYPE*)sub12, ld12);
  171. if (STARPU_UNLIKELY(status != CUBLAS_STATUS_SUCCESS))
  172. STARPU_CUBLAS_REPORT_ERROR(status);
  173. break;
  174. #endif
  175. default:
  176. STARPU_ABORT();
  177. break;
  178. }
  179. }
  180. void STARPU_LU(cpu_u12)(void *descr[], void *_args)
  181. {
  182. STARPU_LU(common_u12)(descr, 0, _args);
  183. }
  184. #ifdef STARPU_USE_CUDA
  185. void STARPU_LU(cublas_u12)(void *descr[], void *_args)
  186. {
  187. STARPU_LU(common_u12)(descr, 1, _args);
  188. }
  189. #endif /* STARPU_USE_CUDA */
  190. static struct starpu_perfmodel STARPU_LU(model_12) =
  191. {
  192. .type = STARPU_HISTORY_BASED,
  193. #ifdef STARPU_ATLAS
  194. .symbol = STARPU_LU_STR(lu_model_12_atlas)
  195. #elif defined(STARPU_GOTO)
  196. .symbol = STARPU_LU_STR(lu_model_12_goto)
  197. #elif defined(STARPU_OPENBLAS)
  198. .symbol = STARPU_LU_STR(lu_model_12_openblas)
  199. #else
  200. .symbol = STARPU_LU_STR(lu_model_12)
  201. #endif
  202. };
  203. struct starpu_codelet cl12 =
  204. {
  205. .cpu_funcs = {STARPU_LU(cpu_u12)},
  206. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_u12))},
  207. #ifdef STARPU_USE_CUDA
  208. .cuda_funcs = {STARPU_LU(cublas_u12)},
  209. CAN_EXECUTE
  210. #elif defined(STARPU_SIMGRID)
  211. .cuda_funcs = {(void*)1},
  212. #endif
  213. .cuda_flags = {STARPU_CUDA_ASYNC},
  214. .nbuffers = 2,
  215. .modes = {STARPU_R, STARPU_RW},
  216. .model = &STARPU_LU(model_12)
  217. };
  218. /*
  219. * U21
  220. */
  221. static inline void STARPU_LU(common_u21)(void *descr[], int s, void *_args)
  222. {
  223. (void)_args;
  224. TYPE *sub11;
  225. TYPE *sub21;
  226. sub11 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  227. sub21 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[1]);
  228. unsigned ld11 = STARPU_MATRIX_GET_LD(descr[0]);
  229. unsigned ld21 = STARPU_MATRIX_GET_LD(descr[1]);
  230. unsigned nx21 = STARPU_MATRIX_GET_NX(descr[1]);
  231. unsigned ny21 = STARPU_MATRIX_GET_NY(descr[1]);
  232. #ifdef STARPU_USE_CUDA
  233. cublasStatus status;
  234. #endif
  235. switch (s)
  236. {
  237. case 0:
  238. CPU_TRSM("R", "U", "N", "U", nx21, ny21,
  239. (TYPE)1.0, sub11, ld11, sub21, ld21);
  240. break;
  241. #ifdef STARPU_USE_CUDA
  242. case 1:
  243. status = CUBLAS_TRSM(starpu_cublas_get_local_handle(),
  244. CUBLAS_SIDE_RIGHT, CUBLAS_FILL_MODE_UPPER, CUBLAS_OP_N, CUBLAS_DIAG_UNIT,
  245. ny21, nx21,
  246. (CUBLAS_TYPE*)&p1, (CUBLAS_TYPE*)sub11, ld11, (CUBLAS_TYPE*)sub21, ld21);
  247. if (status != CUBLAS_STATUS_SUCCESS)
  248. STARPU_CUBLAS_REPORT_ERROR(status);
  249. break;
  250. #endif
  251. default:
  252. STARPU_ABORT();
  253. break;
  254. }
  255. }
  256. void STARPU_LU(cpu_u21)(void *descr[], void *_args)
  257. {
  258. STARPU_LU(common_u21)(descr, 0, _args);
  259. }
  260. #ifdef STARPU_USE_CUDA
  261. void STARPU_LU(cublas_u21)(void *descr[], void *_args)
  262. {
  263. STARPU_LU(common_u21)(descr, 1, _args);
  264. }
  265. #endif
  266. static struct starpu_perfmodel STARPU_LU(model_21) =
  267. {
  268. .type = STARPU_HISTORY_BASED,
  269. #ifdef STARPU_ATLAS
  270. .symbol = STARPU_LU_STR(lu_model_21_atlas)
  271. #elif defined(STARPU_GOTO)
  272. .symbol = STARPU_LU_STR(lu_model_21_goto)
  273. #elif defined(STARPU_OPENBLAS)
  274. .symbol = STARPU_LU_STR(lu_model_21_openblas)
  275. #else
  276. .symbol = STARPU_LU_STR(lu_model_21)
  277. #endif
  278. };
  279. struct starpu_codelet cl21 =
  280. {
  281. .cpu_funcs = {STARPU_LU(cpu_u21)},
  282. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_u21))},
  283. #ifdef STARPU_USE_CUDA
  284. .cuda_funcs = {STARPU_LU(cublas_u21)},
  285. CAN_EXECUTE
  286. #elif defined(STARPU_SIMGRID)
  287. .cuda_funcs = {(void*)1},
  288. #endif
  289. .cuda_flags = {STARPU_CUDA_ASYNC},
  290. .nbuffers = 2,
  291. .modes = {STARPU_R, STARPU_RW},
  292. .model = &STARPU_LU(model_21)
  293. };
  294. /*
  295. * U11
  296. */
  297. static inline void STARPU_LU(common_u11)(void *descr[], int s, void *_args)
  298. {
  299. (void)_args;
  300. TYPE *sub11;
  301. sub11 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  302. unsigned long nx = STARPU_MATRIX_GET_NX(descr[0]);
  303. unsigned long ld = STARPU_MATRIX_GET_LD(descr[0]);
  304. unsigned long z;
  305. #ifdef STARPU_USE_CUDA
  306. cublasStatus status;
  307. cublasHandle_t handle;
  308. cudaStream_t stream;
  309. #endif
  310. switch (s)
  311. {
  312. case 0:
  313. for (z = 0; z < nx; z++)
  314. {
  315. TYPE pivot;
  316. pivot = sub11[z+z*ld];
  317. STARPU_ASSERT(!ISZERO(pivot));
  318. CPU_SCAL(nx - z - 1, (1.0/pivot), &sub11[z+(z+1)*ld], ld);
  319. CPU_GER(nx - z - 1, nx - z - 1, -1.0,
  320. &sub11[(z+1)+z*ld], 1,
  321. &sub11[z+(z+1)*ld], ld,
  322. &sub11[(z+1) + (z+1)*ld],ld);
  323. }
  324. break;
  325. #ifdef STARPU_USE_CUDA
  326. case 1:
  327. handle = starpu_cublas_get_local_handle();
  328. stream = starpu_cuda_get_local_stream();
  329. for (z = 0; z < nx; z++)
  330. {
  331. TYPE pivot;
  332. TYPE inv_pivot;
  333. cudaMemcpyAsync(&pivot, &sub11[z+z*ld], sizeof(TYPE), cudaMemcpyDeviceToHost, stream);
  334. cudaStreamSynchronize(stream);
  335. STARPU_ASSERT(!ISZERO(pivot));
  336. inv_pivot = 1.0/pivot;
  337. status = CUBLAS_SCAL(handle,
  338. nx - z - 1,
  339. (CUBLAS_TYPE*)&inv_pivot, (CUBLAS_TYPE*)&sub11[z+(z+1)*ld], ld);
  340. if (status != CUBLAS_STATUS_SUCCESS)
  341. STARPU_CUBLAS_REPORT_ERROR(status);
  342. status = CUBLAS_GER(handle,
  343. nx - z - 1, nx - z - 1,
  344. (CUBLAS_TYPE*)&m1,
  345. (CUBLAS_TYPE*)&sub11[(z+1)+z*ld], 1,
  346. (CUBLAS_TYPE*)&sub11[z+(z+1)*ld], ld,
  347. (CUBLAS_TYPE*)&sub11[(z+1) + (z+1)*ld],ld);
  348. if (status != CUBLAS_STATUS_SUCCESS)
  349. STARPU_CUBLAS_REPORT_ERROR(status);
  350. }
  351. cudaStreamSynchronize(stream);
  352. break;
  353. #endif
  354. default:
  355. STARPU_ABORT();
  356. break;
  357. }
  358. }
  359. void STARPU_LU(cpu_u11)(void *descr[], void *_args)
  360. {
  361. STARPU_LU(common_u11)(descr, 0, _args);
  362. }
  363. #ifdef STARPU_USE_CUDA
  364. void STARPU_LU(cublas_u11)(void *descr[], void *_args)
  365. {
  366. STARPU_LU(common_u11)(descr, 1, _args);
  367. }
  368. #endif /* STARPU_USE_CUDA */
  369. static struct starpu_perfmodel STARPU_LU(model_11) =
  370. {
  371. .type = STARPU_HISTORY_BASED,
  372. #ifdef STARPU_ATLAS
  373. .symbol = STARPU_LU_STR(lu_model_11_atlas)
  374. #elif defined(STARPU_GOTO)
  375. .symbol = STARPU_LU_STR(lu_model_11_goto)
  376. #elif defined(STARPU_OPENBLAS)
  377. .symbol = STARPU_LU_STR(lu_model_11_openblas)
  378. #else
  379. .symbol = STARPU_LU_STR(lu_model_11)
  380. #endif
  381. };
  382. struct starpu_codelet cl11 =
  383. {
  384. .cpu_funcs = {STARPU_LU(cpu_u11)},
  385. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_u11))},
  386. #ifdef STARPU_USE_CUDA
  387. .cuda_funcs = {STARPU_LU(cublas_u11)},
  388. CAN_EXECUTE
  389. #elif defined(STARPU_SIMGRID)
  390. .cuda_funcs = {(void*)1},
  391. #endif
  392. .nbuffers = 1,
  393. .modes = {STARPU_RW},
  394. .model = &STARPU_LU(model_11)
  395. };
  396. /*
  397. * U11 with pivoting
  398. */
  399. static inline void STARPU_LU(common_u11_pivot)(void *descr[],
  400. int s, void *_args)
  401. {
  402. TYPE *sub11;
  403. sub11 = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  404. unsigned long nx = STARPU_MATRIX_GET_NX(descr[0]);
  405. unsigned long ld = STARPU_MATRIX_GET_LD(descr[0]);
  406. unsigned long z;
  407. struct piv_s *piv = _args;
  408. unsigned *ipiv = piv->piv;
  409. unsigned first = piv->first;
  410. #ifdef STARPU_USE_CUDA
  411. cublasStatus status;
  412. cublasHandle_t handle;
  413. cudaStream_t stream;
  414. #endif
  415. switch (s)
  416. {
  417. case 0:
  418. for (z = 0; z < nx; z++)
  419. {
  420. TYPE pivot;
  421. pivot = sub11[z+z*ld];
  422. if (fabs((double)(pivot)) < PIVOT_THRESHHOLD)
  423. {
  424. /* find the pivot */
  425. int piv_ind = CPU_IAMAX(nx - z, &sub11[z*(ld+1)], ld);
  426. ipiv[z + first] = piv_ind + z + first;
  427. /* swap if needed */
  428. if (piv_ind != 0)
  429. {
  430. CPU_SWAP(nx, &sub11[z*ld], 1, &sub11[(z+piv_ind)*ld], 1);
  431. }
  432. pivot = sub11[z+z*ld];
  433. }
  434. STARPU_ASSERT(!ISZERO(pivot));
  435. CPU_SCAL(nx - z - 1, (1.0/pivot), &sub11[z+(z+1)*ld], ld);
  436. CPU_GER(nx - z - 1, nx - z - 1, -1.0,
  437. &sub11[(z+1)+z*ld], 1,
  438. &sub11[z+(z+1)*ld], ld,
  439. &sub11[(z+1) + (z+1)*ld],ld);
  440. }
  441. break;
  442. #ifdef STARPU_USE_CUDA
  443. case 1:
  444. handle = starpu_cublas_get_local_handle();
  445. stream = starpu_cuda_get_local_stream();
  446. for (z = 0; z < nx; z++)
  447. {
  448. TYPE pivot;
  449. TYPE inv_pivot;
  450. cudaMemcpyAsync(&pivot, &sub11[z+z*ld], sizeof(TYPE), cudaMemcpyDeviceToHost, stream);
  451. cudaStreamSynchronize(stream);
  452. if (fabs((double)(pivot)) < PIVOT_THRESHHOLD)
  453. {
  454. /* find the pivot */
  455. int piv_ind;
  456. status = CUBLAS_IAMAX(handle,
  457. nx - z, (CUBLAS_TYPE*)&sub11[z*(ld+1)], ld, &piv_ind);
  458. piv_ind -= 1;
  459. if (status != CUBLAS_STATUS_SUCCESS)
  460. STARPU_CUBLAS_REPORT_ERROR(status);
  461. ipiv[z + first] = piv_ind + z + first;
  462. /* swap if needed */
  463. if (piv_ind != 0)
  464. {
  465. status = CUBLAS_SWAP(handle,
  466. nx,
  467. (CUBLAS_TYPE*)&sub11[z*ld], 1,
  468. (CUBLAS_TYPE*)&sub11[(z+piv_ind)*ld], 1);
  469. if (status != CUBLAS_STATUS_SUCCESS)
  470. STARPU_CUBLAS_REPORT_ERROR(status);
  471. }
  472. cudaMemcpyAsync(&pivot, &sub11[z+z*ld], sizeof(TYPE), cudaMemcpyDeviceToHost, stream);
  473. cudaStreamSynchronize(stream);
  474. }
  475. STARPU_ASSERT(!ISZERO(pivot));
  476. inv_pivot = 1.0/pivot;
  477. status = CUBLAS_SCAL(handle,
  478. nx - z - 1,
  479. (CUBLAS_TYPE*)&inv_pivot,
  480. (CUBLAS_TYPE*)&sub11[z+(z+1)*ld], ld);
  481. if (status != CUBLAS_STATUS_SUCCESS)
  482. STARPU_CUBLAS_REPORT_ERROR(status);
  483. status = CUBLAS_GER(handle,
  484. nx - z - 1, nx - z - 1,
  485. (CUBLAS_TYPE*)&m1,
  486. (CUBLAS_TYPE*)&sub11[(z+1)+z*ld], 1,
  487. (CUBLAS_TYPE*)&sub11[z+(z+1)*ld], ld,
  488. (CUBLAS_TYPE*)&sub11[(z+1) + (z+1)*ld],ld);
  489. if (status != CUBLAS_STATUS_SUCCESS)
  490. STARPU_CUBLAS_REPORT_ERROR(status);
  491. }
  492. cudaStreamSynchronize(stream);
  493. break;
  494. #endif
  495. default:
  496. STARPU_ABORT();
  497. break;
  498. }
  499. }
  500. void STARPU_LU(cpu_u11_pivot)(void *descr[], void *_args)
  501. {
  502. STARPU_LU(common_u11_pivot)(descr, 0, _args);
  503. }
  504. #ifdef STARPU_USE_CUDA
  505. void STARPU_LU(cublas_u11_pivot)(void *descr[], void *_args)
  506. {
  507. STARPU_LU(common_u11_pivot)(descr, 1, _args);
  508. }
  509. #endif /* STARPU_USE_CUDA */
  510. static struct starpu_perfmodel STARPU_LU(model_11_pivot) =
  511. {
  512. .type = STARPU_HISTORY_BASED,
  513. #ifdef STARPU_ATLAS
  514. .symbol = STARPU_LU_STR(lu_model_11_pivot_atlas)
  515. #elif defined(STARPU_GOTO)
  516. .symbol = STARPU_LU_STR(lu_model_11_pivot_goto)
  517. #elif defined(STARPU_OPENBLAS)
  518. .symbol = STARPU_LU_STR(lu_model_11_pivot_openblas)
  519. #else
  520. .symbol = STARPU_LU_STR(lu_model_11_pivot)
  521. #endif
  522. };
  523. struct starpu_codelet cl11_pivot =
  524. {
  525. .cpu_funcs = {STARPU_LU(cpu_u11_pivot)},
  526. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_u11_pivot))},
  527. #ifdef STARPU_USE_CUDA
  528. .cuda_funcs = {STARPU_LU(cublas_u11_pivot)},
  529. CAN_EXECUTE
  530. #elif defined(STARPU_SIMGRID)
  531. .cuda_funcs = {(void*)1},
  532. #endif
  533. .nbuffers = 1,
  534. .modes = {STARPU_RW},
  535. .model = &STARPU_LU(model_11_pivot)
  536. };
  537. /*
  538. * Pivoting
  539. */
  540. static inline void STARPU_LU(common_pivot)(void *descr[],
  541. int s, void *_args)
  542. {
  543. TYPE *matrix;
  544. matrix = (TYPE *)STARPU_MATRIX_GET_PTR(descr[0]);
  545. unsigned long nx = STARPU_MATRIX_GET_NX(descr[0]);
  546. unsigned long ld = STARPU_MATRIX_GET_LD(descr[0]);
  547. unsigned row;
  548. struct piv_s *piv = _args;
  549. unsigned *ipiv = piv->piv;
  550. unsigned first = piv->first;
  551. #ifdef STARPU_USE_CUDA
  552. cublasStatus status;
  553. cublasHandle_t handle;
  554. #endif
  555. switch (s)
  556. {
  557. case 0:
  558. for (row = 0; row < nx; row++)
  559. {
  560. unsigned rowpiv = ipiv[row+first] - first;
  561. if (rowpiv != row)
  562. {
  563. CPU_SWAP(nx, &matrix[row*ld], 1, &matrix[rowpiv*ld], 1);
  564. }
  565. }
  566. break;
  567. #ifdef STARPU_USE_CUDA
  568. case 1:
  569. handle = starpu_cublas_get_local_handle();
  570. for (row = 0; row < nx; row++)
  571. {
  572. unsigned rowpiv = ipiv[row+first] - first;
  573. if (rowpiv != row)
  574. {
  575. status = CUBLAS_SWAP(handle,
  576. nx,
  577. (CUBLAS_TYPE*)&matrix[row*ld], 1,
  578. (CUBLAS_TYPE*)&matrix[rowpiv*ld], 1);
  579. if (status != CUBLAS_STATUS_SUCCESS)
  580. STARPU_CUBLAS_REPORT_ERROR(status);
  581. }
  582. }
  583. break;
  584. #endif
  585. default:
  586. STARPU_ABORT();
  587. break;
  588. }
  589. }
  590. void STARPU_LU(cpu_pivot)(void *descr[], void *_args)
  591. {
  592. STARPU_LU(common_pivot)(descr, 0, _args);
  593. }
  594. #ifdef STARPU_USE_CUDA
  595. void STARPU_LU(cublas_pivot)(void *descr[], void *_args)
  596. {
  597. STARPU_LU(common_pivot)(descr, 1, _args);
  598. }
  599. #endif /* STARPU_USE_CUDA */
  600. static struct starpu_perfmodel STARPU_LU(model_pivot) =
  601. {
  602. .type = STARPU_HISTORY_BASED,
  603. #ifdef STARPU_ATLAS
  604. .symbol = STARPU_LU_STR(lu_model_pivot_atlas)
  605. #elif defined(STARPU_GOTO)
  606. .symbol = STARPU_LU_STR(lu_model_pivot_goto)
  607. #elif defined(STARPU_OPENBLAS)
  608. .symbol = STARPU_LU_STR(lu_model_pivot_openblas)
  609. #else
  610. .symbol = STARPU_LU_STR(lu_model_pivot)
  611. #endif
  612. };
  613. struct starpu_codelet cl_pivot =
  614. {
  615. .cpu_funcs = {STARPU_LU(cpu_pivot)},
  616. .cpu_funcs_name = {STRINGIFY(STARPU_LU(cpu_pivot))},
  617. #ifdef STARPU_USE_CUDA
  618. .cuda_funcs = {STARPU_LU(cublas_pivot)},
  619. CAN_EXECUTE
  620. #elif defined(STARPU_SIMGRID)
  621. .cuda_funcs = {(void*)1},
  622. #endif
  623. .cuda_flags = {STARPU_CUDA_ASYNC},
  624. .nbuffers = 1,
  625. .modes = {STARPU_RW},
  626. .model = &STARPU_LU(model_pivot)
  627. };