xlu_kernels.c 17 KB

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