xlu_kernels.c 16 KB

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