1 // Copyright (c) 2017-2024, Lawrence Livermore National Security, LLC and other CEED contributors. 2 // All Rights Reserved. See the top-level LICENSE and NOTICE files for details. 3 // 4 // SPDX-License-Identifier: BSD-2-Clause 5 // 6 // This file is part of CEED: http://github.com/ceed 7 8 #include <ceed.h> 9 #include <ceed/backend.h> 10 #include <cuda_runtime.h> 11 #include <math.h> 12 #include <stdbool.h> 13 #include <string.h> 14 15 #include "../cuda/ceed-cuda-common.h" 16 #include "ceed-cuda-ref.h" 17 18 //------------------------------------------------------------------------------ 19 // Check if host/device sync is needed 20 //------------------------------------------------------------------------------ 21 static inline int CeedVectorNeedSync_Cuda(const CeedVector vec, CeedMemType mem_type, bool *need_sync) { 22 bool has_valid_array = false; 23 CeedVector_Cuda *impl; 24 25 CeedCallBackend(CeedVectorGetData(vec, &impl)); 26 CeedCallBackend(CeedVectorHasValidArray(vec, &has_valid_array)); 27 switch (mem_type) { 28 case CEED_MEM_HOST: 29 *need_sync = has_valid_array && !impl->h_array; 30 break; 31 case CEED_MEM_DEVICE: 32 *need_sync = has_valid_array && !impl->d_array; 33 break; 34 } 35 return CEED_ERROR_SUCCESS; 36 } 37 38 //------------------------------------------------------------------------------ 39 // Sync host to device 40 //------------------------------------------------------------------------------ 41 static inline int CeedVectorSyncH2D_Cuda(const CeedVector vec) { 42 CeedSize length; 43 size_t bytes; 44 CeedVector_Cuda *impl; 45 46 CeedCallBackend(CeedVectorGetData(vec, &impl)); 47 48 CeedCheck(impl->h_array, CeedVectorReturnCeed(vec), CEED_ERROR_BACKEND, "No valid host data to sync to device"); 49 50 CeedCallBackend(CeedVectorGetLength(vec, &length)); 51 bytes = length * sizeof(CeedScalar); 52 if (impl->d_array_borrowed) { 53 impl->d_array = impl->d_array_borrowed; 54 } else if (impl->d_array_owned) { 55 impl->d_array = impl->d_array_owned; 56 } else { 57 CeedCallCuda(CeedVectorReturnCeed(vec), cudaMalloc((void **)&impl->d_array_owned, bytes)); 58 impl->d_array = impl->d_array_owned; 59 } 60 CeedCallCuda(CeedVectorReturnCeed(vec), cudaMemcpy(impl->d_array, impl->h_array, bytes, cudaMemcpyHostToDevice)); 61 return CEED_ERROR_SUCCESS; 62 } 63 64 //------------------------------------------------------------------------------ 65 // Sync device to host 66 //------------------------------------------------------------------------------ 67 static inline int CeedVectorSyncD2H_Cuda(const CeedVector vec) { 68 CeedSize length; 69 CeedVector_Cuda *impl; 70 71 CeedCallBackend(CeedVectorGetData(vec, &impl)); 72 73 CeedCheck(impl->d_array, CeedVectorReturnCeed(vec), CEED_ERROR_BACKEND, "No valid device data to sync to host"); 74 75 if (impl->h_array_borrowed) { 76 impl->h_array = impl->h_array_borrowed; 77 } else if (impl->h_array_owned) { 78 impl->h_array = impl->h_array_owned; 79 } else { 80 CeedSize length; 81 82 CeedCallBackend(CeedVectorGetLength(vec, &length)); 83 CeedCallBackend(CeedCalloc(length, &impl->h_array_owned)); 84 impl->h_array = impl->h_array_owned; 85 } 86 87 CeedCallBackend(CeedVectorGetLength(vec, &length)); 88 size_t bytes = length * sizeof(CeedScalar); 89 90 CeedCallCuda(CeedVectorReturnCeed(vec), cudaMemcpy(impl->h_array, impl->d_array, bytes, cudaMemcpyDeviceToHost)); 91 return CEED_ERROR_SUCCESS; 92 } 93 94 //------------------------------------------------------------------------------ 95 // Sync arrays 96 //------------------------------------------------------------------------------ 97 static int CeedVectorSyncArray_Cuda(const CeedVector vec, CeedMemType mem_type) { 98 bool need_sync = false; 99 100 // Check whether device/host sync is needed 101 CeedCallBackend(CeedVectorNeedSync_Cuda(vec, mem_type, &need_sync)); 102 if (!need_sync) return CEED_ERROR_SUCCESS; 103 104 switch (mem_type) { 105 case CEED_MEM_HOST: 106 return CeedVectorSyncD2H_Cuda(vec); 107 case CEED_MEM_DEVICE: 108 return CeedVectorSyncH2D_Cuda(vec); 109 } 110 return CEED_ERROR_UNSUPPORTED; 111 } 112 113 //------------------------------------------------------------------------------ 114 // Set all pointers as invalid 115 //------------------------------------------------------------------------------ 116 static inline int CeedVectorSetAllInvalid_Cuda(const CeedVector vec) { 117 CeedVector_Cuda *impl; 118 119 CeedCallBackend(CeedVectorGetData(vec, &impl)); 120 impl->h_array = NULL; 121 impl->d_array = NULL; 122 return CEED_ERROR_SUCCESS; 123 } 124 125 //------------------------------------------------------------------------------ 126 // Check if CeedVector has any valid pointer 127 //------------------------------------------------------------------------------ 128 static inline int CeedVectorHasValidArray_Cuda(const CeedVector vec, bool *has_valid_array) { 129 CeedVector_Cuda *impl; 130 131 CeedCallBackend(CeedVectorGetData(vec, &impl)); 132 *has_valid_array = impl->h_array || impl->d_array; 133 return CEED_ERROR_SUCCESS; 134 } 135 136 //------------------------------------------------------------------------------ 137 // Check if has array of given type 138 //------------------------------------------------------------------------------ 139 static inline int CeedVectorHasArrayOfType_Cuda(const CeedVector vec, CeedMemType mem_type, bool *has_array_of_type) { 140 CeedVector_Cuda *impl; 141 142 CeedCallBackend(CeedVectorGetData(vec, &impl)); 143 switch (mem_type) { 144 case CEED_MEM_HOST: 145 *has_array_of_type = impl->h_array_borrowed || impl->h_array_owned; 146 break; 147 case CEED_MEM_DEVICE: 148 *has_array_of_type = impl->d_array_borrowed || impl->d_array_owned; 149 break; 150 } 151 return CEED_ERROR_SUCCESS; 152 } 153 154 //------------------------------------------------------------------------------ 155 // Check if has borrowed array of given type 156 //------------------------------------------------------------------------------ 157 static inline int CeedVectorHasBorrowedArrayOfType_Cuda(const CeedVector vec, CeedMemType mem_type, bool *has_borrowed_array_of_type) { 158 CeedVector_Cuda *impl; 159 160 CeedCallBackend(CeedVectorGetData(vec, &impl)); 161 switch (mem_type) { 162 case CEED_MEM_HOST: 163 *has_borrowed_array_of_type = impl->h_array_borrowed; 164 break; 165 case CEED_MEM_DEVICE: 166 *has_borrowed_array_of_type = impl->d_array_borrowed; 167 break; 168 } 169 return CEED_ERROR_SUCCESS; 170 } 171 172 //------------------------------------------------------------------------------ 173 // Set array from host 174 //------------------------------------------------------------------------------ 175 static int CeedVectorSetArrayHost_Cuda(const CeedVector vec, const CeedCopyMode copy_mode, CeedScalar *array) { 176 CeedSize length; 177 CeedVector_Cuda *impl; 178 179 CeedCallBackend(CeedVectorGetData(vec, &impl)); 180 CeedCallBackend(CeedVectorGetLength(vec, &length)); 181 182 CeedCallBackend(CeedSetHostCeedScalarArray(array, copy_mode, length, (const CeedScalar **)&impl->h_array_owned, 183 (const CeedScalar **)&impl->h_array_borrowed, (const CeedScalar **)&impl->h_array)); 184 return CEED_ERROR_SUCCESS; 185 } 186 187 //------------------------------------------------------------------------------ 188 // Set array from device 189 //------------------------------------------------------------------------------ 190 static int CeedVectorSetArrayDevice_Cuda(const CeedVector vec, const CeedCopyMode copy_mode, CeedScalar *array) { 191 CeedSize length; 192 Ceed ceed; 193 CeedVector_Cuda *impl; 194 195 CeedCallBackend(CeedVectorGetCeed(vec, &ceed)); 196 CeedCallBackend(CeedVectorGetData(vec, &impl)); 197 CeedCallBackend(CeedVectorGetLength(vec, &length)); 198 199 CeedCallBackend(CeedSetDeviceCeedScalarArray_Cuda(ceed, array, copy_mode, length, (const CeedScalar **)&impl->d_array_owned, 200 (const CeedScalar **)&impl->d_array_borrowed, (const CeedScalar **)&impl->d_array)); 201 CeedCallBackend(CeedDestroy(&ceed)); 202 return CEED_ERROR_SUCCESS; 203 } 204 205 //------------------------------------------------------------------------------ 206 // Set the array used by a vector, 207 // freeing any previously allocated array if applicable 208 //------------------------------------------------------------------------------ 209 static int CeedVectorSetArray_Cuda(const CeedVector vec, const CeedMemType mem_type, const CeedCopyMode copy_mode, CeedScalar *array) { 210 CeedVector_Cuda *impl; 211 212 CeedCallBackend(CeedVectorGetData(vec, &impl)); 213 CeedCallBackend(CeedVectorSetAllInvalid_Cuda(vec)); 214 switch (mem_type) { 215 case CEED_MEM_HOST: 216 return CeedVectorSetArrayHost_Cuda(vec, copy_mode, array); 217 case CEED_MEM_DEVICE: 218 return CeedVectorSetArrayDevice_Cuda(vec, copy_mode, array); 219 } 220 return CEED_ERROR_UNSUPPORTED; 221 } 222 223 //------------------------------------------------------------------------------ 224 // Copy host array to value strided 225 //------------------------------------------------------------------------------ 226 static int CeedHostCopyStrided_Cuda(CeedScalar *h_array, CeedSize start, CeedSize step, CeedSize length, CeedScalar *h_copy_array) { 227 for (CeedSize i = start; i < length; i += step) h_copy_array[i] = h_array[i]; 228 return CEED_ERROR_SUCCESS; 229 } 230 231 //------------------------------------------------------------------------------ 232 // Copy device array to value strided (impl in .cu file) 233 //------------------------------------------------------------------------------ 234 int CeedDeviceCopyStrided_Cuda(CeedScalar *d_array, CeedSize start, CeedSize step, CeedSize length, CeedScalar *d_copy_array); 235 236 //------------------------------------------------------------------------------ 237 // Copy a vector to a value strided 238 //------------------------------------------------------------------------------ 239 static int CeedVectorCopyStrided_Cuda(CeedVector vec, CeedSize start, CeedSize step, CeedVector vec_copy) { 240 CeedSize length; 241 CeedVector_Cuda *impl; 242 243 CeedCallBackend(CeedVectorGetData(vec, &impl)); 244 { 245 CeedSize length_vec, length_copy; 246 247 CeedCallBackend(CeedVectorGetLength(vec, &length_vec)); 248 CeedCallBackend(CeedVectorGetLength(vec_copy, &length_copy)); 249 length = length_vec < length_copy ? length_vec : length_copy; 250 } 251 // Set value for synced device/host array 252 if (impl->d_array) { 253 CeedScalar *copy_array; 254 255 CeedCallBackend(CeedVectorGetArray(vec_copy, CEED_MEM_DEVICE, ©_array)); 256 CeedCallBackend(CeedDeviceCopyStrided_Cuda(impl->d_array, start, step, length, copy_array)); 257 CeedCallBackend(CeedVectorRestoreArray(vec_copy, ©_array)); 258 } else if (impl->h_array) { 259 CeedScalar *copy_array; 260 261 CeedCallBackend(CeedVectorGetArray(vec_copy, CEED_MEM_HOST, ©_array)); 262 CeedCallBackend(CeedHostCopyStrided_Cuda(impl->h_array, start, step, length, copy_array)); 263 CeedCallBackend(CeedVectorRestoreArray(vec_copy, ©_array)); 264 } else { 265 return CeedError(CeedVectorReturnCeed(vec), CEED_ERROR_BACKEND, "CeedVector must have valid data set"); 266 } 267 return CEED_ERROR_SUCCESS; 268 } 269 270 //------------------------------------------------------------------------------ 271 // Set host array to value 272 //------------------------------------------------------------------------------ 273 static int CeedHostSetValue_Cuda(CeedScalar *h_array, CeedSize length, CeedScalar val) { 274 for (CeedSize i = 0; i < length; i++) h_array[i] = val; 275 return CEED_ERROR_SUCCESS; 276 } 277 278 //------------------------------------------------------------------------------ 279 // Set device array to value (impl in .cu file) 280 //------------------------------------------------------------------------------ 281 int CeedDeviceSetValue_Cuda(CeedScalar *d_array, CeedSize length, CeedScalar val); 282 283 //------------------------------------------------------------------------------ 284 // Set a vector to a value 285 //------------------------------------------------------------------------------ 286 static int CeedVectorSetValue_Cuda(CeedVector vec, CeedScalar val) { 287 CeedSize length; 288 CeedVector_Cuda *impl; 289 290 CeedCallBackend(CeedVectorGetData(vec, &impl)); 291 CeedCallBackend(CeedVectorGetLength(vec, &length)); 292 // Set value for synced device/host array 293 if (!impl->d_array && !impl->h_array) { 294 if (impl->d_array_borrowed) { 295 impl->d_array = impl->d_array_borrowed; 296 } else if (impl->h_array_borrowed) { 297 impl->h_array = impl->h_array_borrowed; 298 } else if (impl->d_array_owned) { 299 impl->d_array = impl->d_array_owned; 300 } else if (impl->h_array_owned) { 301 impl->h_array = impl->h_array_owned; 302 } else { 303 CeedCallBackend(CeedVectorSetArray(vec, CEED_MEM_DEVICE, CEED_COPY_VALUES, NULL)); 304 } 305 } 306 if (impl->d_array) { 307 if (val == 0) { 308 CeedCallCuda(CeedVectorReturnCeed(vec), cudaMemset(impl->d_array, 0, length * sizeof(CeedScalar))); 309 } else { 310 CeedCallBackend(CeedDeviceSetValue_Cuda(impl->d_array, length, val)); 311 } 312 impl->h_array = NULL; 313 } else if (impl->h_array) { 314 CeedCallBackend(CeedHostSetValue_Cuda(impl->h_array, length, val)); 315 impl->d_array = NULL; 316 } 317 return CEED_ERROR_SUCCESS; 318 } 319 320 //------------------------------------------------------------------------------ 321 // Set host array to value strided 322 //------------------------------------------------------------------------------ 323 static int CeedHostSetValueStrided_Cuda(CeedScalar *h_array, CeedSize start, CeedSize step, CeedSize length, CeedScalar val) { 324 for (CeedSize i = start; i < length; i += step) h_array[i] = val; 325 return CEED_ERROR_SUCCESS; 326 } 327 328 //------------------------------------------------------------------------------ 329 // Set device array to value strided (impl in .cu file) 330 //------------------------------------------------------------------------------ 331 int CeedDeviceSetValueStrided_Cuda(CeedScalar *d_array, CeedSize start, CeedSize step, CeedSize length, CeedScalar val); 332 333 //------------------------------------------------------------------------------ 334 // Set a vector to a value strided 335 //------------------------------------------------------------------------------ 336 static int CeedVectorSetValueStrided_Cuda(CeedVector vec, CeedSize start, CeedSize step, CeedScalar val) { 337 CeedSize length; 338 CeedVector_Cuda *impl; 339 340 CeedCallBackend(CeedVectorGetData(vec, &impl)); 341 CeedCallBackend(CeedVectorGetLength(vec, &length)); 342 // Set value for synced device/host array 343 if (impl->d_array) { 344 CeedCallBackend(CeedDeviceSetValueStrided_Cuda(impl->d_array, start, step, length, val)); 345 impl->h_array = NULL; 346 } else if (impl->h_array) { 347 CeedCallBackend(CeedHostSetValueStrided_Cuda(impl->h_array, start, step, length, val)); 348 impl->d_array = NULL; 349 } else { 350 return CeedError(CeedVectorReturnCeed(vec), CEED_ERROR_BACKEND, "CeedVector must have valid data set"); 351 } 352 return CEED_ERROR_SUCCESS; 353 } 354 355 //------------------------------------------------------------------------------ 356 // Vector Take Array 357 //------------------------------------------------------------------------------ 358 static int CeedVectorTakeArray_Cuda(CeedVector vec, CeedMemType mem_type, CeedScalar **array) { 359 CeedVector_Cuda *impl; 360 361 CeedCallBackend(CeedVectorGetData(vec, &impl)); 362 // Sync array to requested mem_type 363 CeedCallBackend(CeedVectorSyncArray(vec, mem_type)); 364 // Update pointer 365 switch (mem_type) { 366 case CEED_MEM_HOST: 367 (*array) = impl->h_array_borrowed; 368 impl->h_array_borrowed = NULL; 369 impl->h_array = NULL; 370 break; 371 case CEED_MEM_DEVICE: 372 (*array) = impl->d_array_borrowed; 373 impl->d_array_borrowed = NULL; 374 impl->d_array = NULL; 375 break; 376 } 377 return CEED_ERROR_SUCCESS; 378 } 379 380 //------------------------------------------------------------------------------ 381 // Core logic for array syncronization for GetArray. 382 // If a different memory type is most up to date, this will perform a copy 383 //------------------------------------------------------------------------------ 384 static int CeedVectorGetArrayCore_Cuda(const CeedVector vec, const CeedMemType mem_type, CeedScalar **array) { 385 CeedVector_Cuda *impl; 386 387 CeedCallBackend(CeedVectorGetData(vec, &impl)); 388 // Sync array to requested mem_type 389 CeedCallBackend(CeedVectorSyncArray(vec, mem_type)); 390 // Update pointer 391 switch (mem_type) { 392 case CEED_MEM_HOST: 393 *array = impl->h_array; 394 break; 395 case CEED_MEM_DEVICE: 396 *array = impl->d_array; 397 break; 398 } 399 return CEED_ERROR_SUCCESS; 400 } 401 402 //------------------------------------------------------------------------------ 403 // Get read-only access to a vector via the specified mem_type 404 //------------------------------------------------------------------------------ 405 static int CeedVectorGetArrayRead_Cuda(const CeedVector vec, const CeedMemType mem_type, const CeedScalar **array) { 406 return CeedVectorGetArrayCore_Cuda(vec, mem_type, (CeedScalar **)array); 407 } 408 409 //------------------------------------------------------------------------------ 410 // Get read/write access to a vector via the specified mem_type 411 //------------------------------------------------------------------------------ 412 static int CeedVectorGetArray_Cuda(const CeedVector vec, const CeedMemType mem_type, CeedScalar **array) { 413 CeedVector_Cuda *impl; 414 415 CeedCallBackend(CeedVectorGetData(vec, &impl)); 416 CeedCallBackend(CeedVectorGetArrayCore_Cuda(vec, mem_type, array)); 417 CeedCallBackend(CeedVectorSetAllInvalid_Cuda(vec)); 418 switch (mem_type) { 419 case CEED_MEM_HOST: 420 impl->h_array = *array; 421 break; 422 case CEED_MEM_DEVICE: 423 impl->d_array = *array; 424 break; 425 } 426 return CEED_ERROR_SUCCESS; 427 } 428 429 //------------------------------------------------------------------------------ 430 // Get write access to a vector via the specified mem_type 431 //------------------------------------------------------------------------------ 432 static int CeedVectorGetArrayWrite_Cuda(const CeedVector vec, const CeedMemType mem_type, CeedScalar **array) { 433 bool has_array_of_type = true; 434 CeedVector_Cuda *impl; 435 436 CeedCallBackend(CeedVectorGetData(vec, &impl)); 437 CeedCallBackend(CeedVectorHasArrayOfType_Cuda(vec, mem_type, &has_array_of_type)); 438 if (!has_array_of_type) { 439 // Allocate if array is not yet allocated 440 CeedCallBackend(CeedVectorSetArray(vec, mem_type, CEED_COPY_VALUES, NULL)); 441 } else { 442 // Select dirty array 443 switch (mem_type) { 444 case CEED_MEM_HOST: 445 if (impl->h_array_borrowed) impl->h_array = impl->h_array_borrowed; 446 else impl->h_array = impl->h_array_owned; 447 break; 448 case CEED_MEM_DEVICE: 449 if (impl->d_array_borrowed) impl->d_array = impl->d_array_borrowed; 450 else impl->d_array = impl->d_array_owned; 451 } 452 } 453 return CeedVectorGetArray_Cuda(vec, mem_type, array); 454 } 455 456 //------------------------------------------------------------------------------ 457 // Get the norm of a CeedVector 458 //------------------------------------------------------------------------------ 459 static int CeedVectorNorm_Cuda(CeedVector vec, CeedNormType type, CeedScalar *norm) { 460 Ceed ceed; 461 CeedSize length; 462 #if CUDA_VERSION < 12000 463 CeedSize num_calls; 464 #endif 465 const CeedScalar *d_array; 466 CeedVector_Cuda *impl; 467 cublasHandle_t handle; 468 469 CeedCallBackend(CeedVectorGetCeed(vec, &ceed)); 470 CeedCallBackend(CeedVectorGetData(vec, &impl)); 471 CeedCallBackend(CeedVectorGetLength(vec, &length)); 472 CeedCallBackend(CeedGetCublasHandle_Cuda(ceed, &handle)); 473 474 #if CUDA_VERSION < 12000 475 // With CUDA 12, we can use the 64-bit integer interface. Prior to that, 476 // we need to check if the vector is too long to handle with int32, 477 // and if so, divide it into subsections for repeated cuBLAS calls. 478 num_calls = length / INT_MAX; 479 if (length % INT_MAX > 0) num_calls += 1; 480 #endif 481 482 // Compute norm 483 CeedCallBackend(CeedVectorGetArrayRead(vec, CEED_MEM_DEVICE, &d_array)); 484 switch (type) { 485 case CEED_NORM_1: { 486 *norm = 0.0; 487 if (CEED_SCALAR_TYPE == CEED_SCALAR_FP32) { 488 #if CUDA_VERSION >= 12000 // We have CUDA 12, and can use 64-bit integers 489 CeedCallCublas(ceed, cublasSasum_64(handle, (int64_t)length, (float *)d_array, 1, (float *)norm)); 490 #else 491 float sub_norm = 0.0; 492 float *d_array_start; 493 494 for (CeedInt i = 0; i < num_calls; i++) { 495 d_array_start = (float *)d_array + (CeedSize)(i)*INT_MAX; 496 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 497 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 498 499 CeedCallCublas(ceed, cublasSasum(handle, (CeedInt)sub_length, (float *)d_array_start, 1, &sub_norm)); 500 *norm += sub_norm; 501 } 502 #endif 503 } else { 504 #if CUDA_VERSION >= 12000 505 CeedCallCublas(ceed, cublasDasum_64(handle, (int64_t)length, (double *)d_array, 1, (double *)norm)); 506 #else 507 double sub_norm = 0.0; 508 double *d_array_start; 509 510 for (CeedInt i = 0; i < num_calls; i++) { 511 d_array_start = (double *)d_array + (CeedSize)(i)*INT_MAX; 512 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 513 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 514 515 CeedCallCublas(ceed, cublasDasum(handle, (CeedInt)sub_length, (double *)d_array_start, 1, &sub_norm)); 516 *norm += sub_norm; 517 } 518 #endif 519 } 520 break; 521 } 522 case CEED_NORM_2: { 523 if (CEED_SCALAR_TYPE == CEED_SCALAR_FP32) { 524 #if CUDA_VERSION >= 12000 525 CeedCallCublas(ceed, cublasSnrm2_64(handle, (int64_t)length, (float *)d_array, 1, (float *)norm)); 526 #else 527 float sub_norm = 0.0, norm_sum = 0.0; 528 float *d_array_start; 529 530 for (CeedInt i = 0; i < num_calls; i++) { 531 d_array_start = (float *)d_array + (CeedSize)(i)*INT_MAX; 532 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 533 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 534 535 CeedCallCublas(ceed, cublasSnrm2(handle, (CeedInt)sub_length, (float *)d_array_start, 1, &sub_norm)); 536 norm_sum += sub_norm * sub_norm; 537 } 538 *norm = sqrt(norm_sum); 539 #endif 540 } else { 541 #if CUDA_VERSION >= 12000 542 CeedCallCublas(ceed, cublasDnrm2_64(handle, (int64_t)length, (double *)d_array, 1, (double *)norm)); 543 #else 544 double sub_norm = 0.0, norm_sum = 0.0; 545 double *d_array_start; 546 547 for (CeedInt i = 0; i < num_calls; i++) { 548 d_array_start = (double *)d_array + (CeedSize)(i)*INT_MAX; 549 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 550 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 551 552 CeedCallCublas(ceed, cublasDnrm2(handle, (CeedInt)sub_length, (double *)d_array_start, 1, &sub_norm)); 553 norm_sum += sub_norm * sub_norm; 554 } 555 *norm = sqrt(norm_sum); 556 #endif 557 } 558 break; 559 } 560 case CEED_NORM_MAX: { 561 if (CEED_SCALAR_TYPE == CEED_SCALAR_FP32) { 562 #if CUDA_VERSION >= 12000 563 int64_t index; 564 CeedScalar norm_no_abs; 565 566 CeedCallCublas(ceed, cublasIsamax_64(handle, (int64_t)length, (float *)d_array, 1, &index)); 567 CeedCallCuda(ceed, cudaMemcpy(&norm_no_abs, impl->d_array + index - 1, sizeof(CeedScalar), cudaMemcpyDeviceToHost)); 568 *norm = fabs(norm_no_abs); 569 #else 570 CeedInt index; 571 float sub_max = 0.0, current_max = 0.0; 572 float *d_array_start; 573 574 for (CeedInt i = 0; i < num_calls; i++) { 575 d_array_start = (float *)d_array + (CeedSize)(i)*INT_MAX; 576 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 577 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 578 579 CeedCallCublas(ceed, cublasIsamax(handle, (CeedInt)sub_length, (float *)d_array_start, 1, &index)); 580 CeedCallCuda(ceed, cudaMemcpy(&sub_max, d_array_start + index - 1, sizeof(CeedScalar), cudaMemcpyDeviceToHost)); 581 if (fabs(sub_max) > current_max) current_max = fabs(sub_max); 582 } 583 *norm = current_max; 584 #endif 585 } else { 586 #if CUDA_VERSION >= 12000 587 int64_t index; 588 CeedScalar norm_no_abs; 589 590 CeedCallCublas(ceed, cublasIdamax_64(handle, (int64_t)length, (double *)d_array, 1, &index)); 591 CeedCallCuda(ceed, cudaMemcpy(&norm_no_abs, impl->d_array + index - 1, sizeof(CeedScalar), cudaMemcpyDeviceToHost)); 592 *norm = fabs(norm_no_abs); 593 #else 594 CeedInt index; 595 double sub_max = 0.0, current_max = 0.0; 596 double *d_array_start; 597 598 for (CeedInt i = 0; i < num_calls; i++) { 599 d_array_start = (double *)d_array + (CeedSize)(i)*INT_MAX; 600 CeedSize remaining_length = length - (CeedSize)(i)*INT_MAX; 601 CeedInt sub_length = (i == num_calls - 1) ? (CeedInt)(remaining_length) : INT_MAX; 602 603 CeedCallCublas(ceed, cublasIdamax(handle, (CeedInt)sub_length, (double *)d_array_start, 1, &index)); 604 CeedCallCuda(ceed, cudaMemcpy(&sub_max, d_array_start + index - 1, sizeof(CeedScalar), cudaMemcpyDeviceToHost)); 605 if (fabs(sub_max) > current_max) current_max = fabs(sub_max); 606 } 607 *norm = current_max; 608 #endif 609 } 610 break; 611 } 612 } 613 CeedCallBackend(CeedVectorRestoreArrayRead(vec, &d_array)); 614 CeedCallBackend(CeedDestroy(&ceed)); 615 return CEED_ERROR_SUCCESS; 616 } 617 618 //------------------------------------------------------------------------------ 619 // Take reciprocal of a vector on host 620 //------------------------------------------------------------------------------ 621 static int CeedHostReciprocal_Cuda(CeedScalar *h_array, CeedSize length) { 622 for (CeedSize i = 0; i < length; i++) { 623 if (fabs(h_array[i]) > CEED_EPSILON) h_array[i] = 1. / h_array[i]; 624 } 625 return CEED_ERROR_SUCCESS; 626 } 627 628 //------------------------------------------------------------------------------ 629 // Take reciprocal of a vector on device (impl in .cu file) 630 //------------------------------------------------------------------------------ 631 int CeedDeviceReciprocal_Cuda(CeedScalar *d_array, CeedSize length); 632 633 //------------------------------------------------------------------------------ 634 // Take reciprocal of a vector 635 //------------------------------------------------------------------------------ 636 static int CeedVectorReciprocal_Cuda(CeedVector vec) { 637 CeedSize length; 638 CeedVector_Cuda *impl; 639 640 CeedCallBackend(CeedVectorGetData(vec, &impl)); 641 CeedCallBackend(CeedVectorGetLength(vec, &length)); 642 // Set value for synced device/host array 643 if (impl->d_array) CeedCallBackend(CeedDeviceReciprocal_Cuda(impl->d_array, length)); 644 if (impl->h_array) CeedCallBackend(CeedHostReciprocal_Cuda(impl->h_array, length)); 645 return CEED_ERROR_SUCCESS; 646 } 647 648 //------------------------------------------------------------------------------ 649 // Compute x = alpha x on the host 650 //------------------------------------------------------------------------------ 651 static int CeedHostScale_Cuda(CeedScalar *x_array, CeedScalar alpha, CeedSize length) { 652 for (CeedSize i = 0; i < length; i++) x_array[i] *= alpha; 653 return CEED_ERROR_SUCCESS; 654 } 655 656 //------------------------------------------------------------------------------ 657 // Compute x = alpha x on device (impl in .cu file) 658 //------------------------------------------------------------------------------ 659 int CeedDeviceScale_Cuda(CeedScalar *x_array, CeedScalar alpha, CeedSize length); 660 661 //------------------------------------------------------------------------------ 662 // Compute x = alpha x 663 //------------------------------------------------------------------------------ 664 static int CeedVectorScale_Cuda(CeedVector x, CeedScalar alpha) { 665 CeedSize length; 666 CeedVector_Cuda *x_impl; 667 668 CeedCallBackend(CeedVectorGetData(x, &x_impl)); 669 CeedCallBackend(CeedVectorGetLength(x, &length)); 670 // Set value for synced device/host array 671 if (x_impl->d_array) CeedCallBackend(CeedDeviceScale_Cuda(x_impl->d_array, alpha, length)); 672 if (x_impl->h_array) CeedCallBackend(CeedHostScale_Cuda(x_impl->h_array, alpha, length)); 673 return CEED_ERROR_SUCCESS; 674 } 675 676 //------------------------------------------------------------------------------ 677 // Compute y = alpha x + y on the host 678 //------------------------------------------------------------------------------ 679 static int CeedHostAXPY_Cuda(CeedScalar *y_array, CeedScalar alpha, CeedScalar *x_array, CeedSize length) { 680 for (CeedSize i = 0; i < length; i++) y_array[i] += alpha * x_array[i]; 681 return CEED_ERROR_SUCCESS; 682 } 683 684 //------------------------------------------------------------------------------ 685 // Compute y = alpha x + y on device (impl in .cu file) 686 //------------------------------------------------------------------------------ 687 int CeedDeviceAXPY_Cuda(CeedScalar *y_array, CeedScalar alpha, CeedScalar *x_array, CeedSize length); 688 689 //------------------------------------------------------------------------------ 690 // Compute y = alpha x + y 691 //------------------------------------------------------------------------------ 692 static int CeedVectorAXPY_Cuda(CeedVector y, CeedScalar alpha, CeedVector x) { 693 CeedSize length; 694 CeedVector_Cuda *y_impl, *x_impl; 695 696 CeedCallBackend(CeedVectorGetData(y, &y_impl)); 697 CeedCallBackend(CeedVectorGetData(x, &x_impl)); 698 CeedCallBackend(CeedVectorGetLength(y, &length)); 699 // Set value for synced device/host array 700 if (y_impl->d_array) { 701 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_DEVICE)); 702 CeedCallBackend(CeedDeviceAXPY_Cuda(y_impl->d_array, alpha, x_impl->d_array, length)); 703 } 704 if (y_impl->h_array) { 705 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_HOST)); 706 CeedCallBackend(CeedHostAXPY_Cuda(y_impl->h_array, alpha, x_impl->h_array, length)); 707 } 708 return CEED_ERROR_SUCCESS; 709 } 710 711 //------------------------------------------------------------------------------ 712 // Compute y = alpha x + beta y on the host 713 //------------------------------------------------------------------------------ 714 static int CeedHostAXPBY_Cuda(CeedScalar *y_array, CeedScalar alpha, CeedScalar beta, CeedScalar *x_array, CeedSize length) { 715 for (CeedSize i = 0; i < length; i++) y_array[i] = alpha * x_array[i] + beta * y_array[i]; 716 return CEED_ERROR_SUCCESS; 717 } 718 719 //------------------------------------------------------------------------------ 720 // Compute y = alpha x + beta y on device (impl in .cu file) 721 //------------------------------------------------------------------------------ 722 int CeedDeviceAXPBY_Cuda(CeedScalar *y_array, CeedScalar alpha, CeedScalar beta, CeedScalar *x_array, CeedSize length); 723 724 //------------------------------------------------------------------------------ 725 // Compute y = alpha x + beta y 726 //------------------------------------------------------------------------------ 727 static int CeedVectorAXPBY_Cuda(CeedVector y, CeedScalar alpha, CeedScalar beta, CeedVector x) { 728 CeedSize length; 729 CeedVector_Cuda *y_impl, *x_impl; 730 731 CeedCallBackend(CeedVectorGetData(y, &y_impl)); 732 CeedCallBackend(CeedVectorGetData(x, &x_impl)); 733 CeedCallBackend(CeedVectorGetLength(y, &length)); 734 // Set value for synced device/host array 735 if (y_impl->d_array) { 736 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_DEVICE)); 737 CeedCallBackend(CeedDeviceAXPBY_Cuda(y_impl->d_array, alpha, beta, x_impl->d_array, length)); 738 } 739 if (y_impl->h_array) { 740 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_HOST)); 741 CeedCallBackend(CeedHostAXPBY_Cuda(y_impl->h_array, alpha, beta, x_impl->h_array, length)); 742 } 743 return CEED_ERROR_SUCCESS; 744 } 745 746 //------------------------------------------------------------------------------ 747 // Compute the pointwise multiplication w = x .* y on the host 748 //------------------------------------------------------------------------------ 749 static int CeedHostPointwiseMult_Cuda(CeedScalar *w_array, CeedScalar *x_array, CeedScalar *y_array, CeedSize length) { 750 for (CeedSize i = 0; i < length; i++) w_array[i] = x_array[i] * y_array[i]; 751 return CEED_ERROR_SUCCESS; 752 } 753 754 //------------------------------------------------------------------------------ 755 // Compute the pointwise multiplication w = x .* y on device (impl in .cu file) 756 //------------------------------------------------------------------------------ 757 int CeedDevicePointwiseMult_Cuda(CeedScalar *w_array, CeedScalar *x_array, CeedScalar *y_array, CeedSize length); 758 759 //------------------------------------------------------------------------------ 760 // Compute the pointwise multiplication w = x .* y 761 //------------------------------------------------------------------------------ 762 static int CeedVectorPointwiseMult_Cuda(CeedVector w, CeedVector x, CeedVector y) { 763 CeedSize length; 764 CeedVector_Cuda *w_impl, *x_impl, *y_impl; 765 766 CeedCallBackend(CeedVectorGetData(w, &w_impl)); 767 CeedCallBackend(CeedVectorGetData(x, &x_impl)); 768 CeedCallBackend(CeedVectorGetData(y, &y_impl)); 769 CeedCallBackend(CeedVectorGetLength(w, &length)); 770 // Set value for synced device/host array 771 if (!w_impl->d_array && !w_impl->h_array) { 772 CeedCallBackend(CeedVectorSetValue(w, 0.0)); 773 } 774 if (w_impl->d_array) { 775 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_DEVICE)); 776 CeedCallBackend(CeedVectorSyncArray(y, CEED_MEM_DEVICE)); 777 CeedCallBackend(CeedDevicePointwiseMult_Cuda(w_impl->d_array, x_impl->d_array, y_impl->d_array, length)); 778 } 779 if (w_impl->h_array) { 780 CeedCallBackend(CeedVectorSyncArray(x, CEED_MEM_HOST)); 781 CeedCallBackend(CeedVectorSyncArray(y, CEED_MEM_HOST)); 782 CeedCallBackend(CeedHostPointwiseMult_Cuda(w_impl->h_array, x_impl->h_array, y_impl->h_array, length)); 783 } 784 return CEED_ERROR_SUCCESS; 785 } 786 787 //------------------------------------------------------------------------------ 788 // Destroy the vector 789 //------------------------------------------------------------------------------ 790 static int CeedVectorDestroy_Cuda(const CeedVector vec) { 791 CeedVector_Cuda *impl; 792 793 CeedCallBackend(CeedVectorGetData(vec, &impl)); 794 CeedCallCuda(CeedVectorReturnCeed(vec), cudaFree(impl->d_array_owned)); 795 CeedCallBackend(CeedFree(&impl->h_array_owned)); 796 CeedCallBackend(CeedFree(&impl)); 797 return CEED_ERROR_SUCCESS; 798 } 799 800 //------------------------------------------------------------------------------ 801 // Create a vector of the specified length (does not allocate memory) 802 //------------------------------------------------------------------------------ 803 int CeedVectorCreate_Cuda(CeedSize n, CeedVector vec) { 804 CeedVector_Cuda *impl; 805 Ceed ceed; 806 807 CeedCallBackend(CeedVectorGetCeed(vec, &ceed)); 808 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "HasValidArray", CeedVectorHasValidArray_Cuda)); 809 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "HasBorrowedArrayOfType", CeedVectorHasBorrowedArrayOfType_Cuda)); 810 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "SetArray", CeedVectorSetArray_Cuda)); 811 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "TakeArray", CeedVectorTakeArray_Cuda)); 812 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "CopyStrided", CeedVectorCopyStrided_Cuda)); 813 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "SetValue", CeedVectorSetValue_Cuda)); 814 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "SetValueStrided", CeedVectorSetValueStrided_Cuda)); 815 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "SyncArray", CeedVectorSyncArray_Cuda)); 816 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "GetArray", CeedVectorGetArray_Cuda)); 817 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "GetArrayRead", CeedVectorGetArrayRead_Cuda)); 818 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "GetArrayWrite", CeedVectorGetArrayWrite_Cuda)); 819 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "Norm", CeedVectorNorm_Cuda)); 820 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "Reciprocal", CeedVectorReciprocal_Cuda)); 821 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "Scale", CeedVectorScale_Cuda)); 822 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "AXPY", CeedVectorAXPY_Cuda)); 823 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "AXPBY", CeedVectorAXPBY_Cuda)); 824 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "PointwiseMult", CeedVectorPointwiseMult_Cuda)); 825 CeedCallBackend(CeedSetBackendFunction(ceed, "Vector", vec, "Destroy", CeedVectorDestroy_Cuda)); 826 CeedCallBackend(CeedDestroy(&ceed)); 827 CeedCallBackend(CeedCalloc(1, &impl)); 828 CeedCallBackend(CeedVectorSetData(vec, impl)); 829 return CEED_ERROR_SUCCESS; 830 } 831 832 //------------------------------------------------------------------------------ 833