/** * * @file starpu/codelet_zhemm.c * * @copyright 2009-2014 The University of Tennessee and The University of * Tennessee Research Foundation. All rights reserved. * @copyright 2012-2024 Bordeaux INP, CNRS (LaBRI UMR 5800), Inria, * Univ. Bordeaux. All rights reserved. * *** * * @brief Chameleon zhemm StarPU codelet * * @version 1.3.0 * @author Hatem Ltaief * @author Jakub Kurzak * @author Mathieu Faverge * @author Emmanuel Agullo * @author Cedric Castagnede * @author Lucas Barros de Assis * @author Florent Pruvost * @author Loris Lucido * @date 2024-03-11 * @precisions normal z -> c * */ #include "chameleon_starpu.h" #include "runtime_codelet_z.h" struct cl_zhemm_args_s { cham_side_t side; cham_uplo_t uplo; int m; int n; CHAMELEON_Complex64_t alpha; CHAMELEON_Complex64_t beta; }; #if !defined(CHAMELEON_SIMULATION) static void cl_zhemm_cpu_func( void *descr[], void *cl_arg ) { struct cl_zhemm_args_s *clargs = (struct cl_zhemm_args_s *)cl_arg; CHAM_tile_t *tileA; CHAM_tile_t *tileB; CHAM_tile_t *tileC; tileA = cti_interface_get(descr[0]); tileB = cti_interface_get(descr[1]); tileC = cti_interface_get(descr[2]); TCORE_zhemm( clargs->side, clargs->uplo, clargs->m, clargs->n, clargs->alpha, tileA, tileB, clargs->beta, tileC ); } #if defined(CHAMELEON_USE_CUDA) static void cl_zhemm_cuda_func( void *descr[], void *cl_arg ) { struct cl_zhemm_args_s *clargs = (struct cl_zhemm_args_s *)cl_arg; cublasHandle_t handle = starpu_cublas_get_local_handle(); CHAM_tile_t *tileA; CHAM_tile_t *tileB; CHAM_tile_t *tileC; tileA = cti_interface_get(descr[0]); tileB = cti_interface_get(descr[1]); tileC = cti_interface_get(descr[2]); assert( tileA->format & CHAMELEON_TILE_FULLRANK ); assert( tileB->format & CHAMELEON_TILE_FULLRANK ); assert( tileC->format & CHAMELEON_TILE_FULLRANK ); CUDA_zhemm( clargs->side, clargs->uplo, clargs->m, clargs->n, (cuDoubleComplex*)&(clargs->alpha), tileA->mat, tileA->ld, tileB->mat, tileB->ld, (cuDoubleComplex*)&(clargs->beta), tileC->mat, tileC->ld, handle ); } #endif /* defined(CHAMELEON_USE_CUDA) */ #if defined(CHAMELEON_USE_HIP) static void cl_zhemm_hip_func( void *descr[], void *cl_arg ) { struct cl_zhemm_args_s *clargs = (struct cl_zhemm_args_s *)cl_arg; hipblasHandle_t handle = starpu_hipblas_get_local_handle(); CHAM_tile_t *tileA; CHAM_tile_t *tileB; CHAM_tile_t *tileC; tileA = cti_interface_get(descr[0]); tileB = cti_interface_get(descr[1]); tileC = cti_interface_get(descr[2]); assert( tileA->format & CHAMELEON_TILE_FULLRANK ); assert( tileB->format & CHAMELEON_TILE_FULLRANK ); assert( tileC->format & CHAMELEON_TILE_FULLRANK ); HIP_zhemm( clargs->side, clargs->uplo, clargs->m, clargs->n, (hipblasDoubleComplex*)&(clargs->alpha), tileA->mat, tileA->ld, tileB->mat, tileB->ld, (hipblasDoubleComplex*)&(clargs->beta), tileC->mat, tileC->ld, handle ); } #endif /* defined(CHAMELEON_USE_HIP) */ #endif /* !defined(CHAMELEON_SIMULATION) */ /* * Codelet definition */ #if defined(CHAMELEON_USE_HIP) CODELETS_GPU( zhemm, cl_zhemm_cpu_func, cl_zhemm_hip_func, STARPU_HIP_ASYNC ) #else CODELETS( zhemm, cl_zhemm_cpu_func, cl_zhemm_cuda_func, STARPU_CUDA_ASYNC ) #endif void INSERT_TASK_zhemm_Astat( const RUNTIME_option_t *options, cham_side_t side, cham_uplo_t uplo, int m, int n, int nb, CHAMELEON_Complex64_t alpha, const CHAM_desc_t *A, int Am, int An, const CHAM_desc_t *B, int Bm, int Bn, CHAMELEON_Complex64_t beta, const CHAM_desc_t *C, int Cm, int Cn ) { if ( alpha == 0. ) { INSERT_TASK_zlascal( options, ChamUpperLower, m, n, nb, beta, C, Cm, Cn ); return; } struct cl_zhemm_args_s *clargs = NULL; void (*callback)(void*); int accessC; int exec = 0; const char *cl_name = "zhemm_Astat"; /* Handle cache */ CHAMELEON_BEGIN_ACCESS_DECLARATION; /* Check A as write, since it will be the owner of the computation */ CHAMELEON_ACCESS_W(A, Am, An); CHAMELEON_ACCESS_R(B, Bm, Bn); /* Check C as read, since it will be used in a reduction */ CHAMELEON_ACCESS_R(C, Cm, Cn); exec = __chameleon_need_exec; CHAMELEON_END_ACCESS_DECLARATION; if ( exec ) { clargs = malloc( sizeof( struct cl_zhemm_args_s ) ); clargs->side = side; clargs->uplo = uplo; clargs->m = m; clargs->n = n; clargs->alpha = alpha; clargs->beta = beta; } /* Callback for profiling information */ callback = options->profiling ? cl_zhemm_callback : NULL; /* Reduce the C access if needed */ if ( beta == 0. ) { accessC = STARPU_W; } #if defined(HAVE_STARPU_MPI_REDUX) else if ( beta == 1. ) { accessC = STARPU_MPI_REDUX; } #endif else { accessC = STARPU_RW; } /* Refine name */ cl_name = chameleon_codelet_name( cl_name, 3, A->get_blktile( A, Am, An ), B->get_blktile( B, Bm, Bn ), C->get_blktile( C, Cm, Cn ) ); /* Insert the task */ rt_starpu_insert_task( &cl_zhemm, /* Task codelet arguments */ STARPU_CL_ARGS, clargs, sizeof(struct cl_zhemm_args_s), /* Task handles */ STARPU_R, RTBLKADDR(A, ChamComplexDouble, Am, An), STARPU_R, RTBLKADDR(B, ChamComplexDouble, Bm, Bn), accessC, RTBLKADDR(C, ChamComplexDouble, Cm, Cn), /* Common task arguments */ STARPU_PRIORITY, options->priority, STARPU_CALLBACK, callback, STARPU_EXECUTE_ON_NODE, A->get_rankof(A, Am, An), #if defined(CHAMELEON_CODELETS_HAVE_NAME) STARPU_NAME, cl_name, #endif 0 ); } void INSERT_TASK_zhemm( const RUNTIME_option_t *options, cham_side_t side, cham_uplo_t uplo, int m, int n, int nb, CHAMELEON_Complex64_t alpha, const CHAM_desc_t *A, int Am, int An, const CHAM_desc_t *B, int Bm, int Bn, CHAMELEON_Complex64_t beta, const CHAM_desc_t *C, int Cm, int Cn ) { if ( alpha == 0. ) { INSERT_TASK_zlascal( options, ChamUpperLower, m, n, nb, beta, C, Cm, Cn ); return; } struct cl_zhemm_args_s *clargs = NULL; void (*callback)(void*); int accessC; int exec = 0; const char *cl_name = "zhemm"; /* Handle cache */ CHAMELEON_BEGIN_ACCESS_DECLARATION; CHAMELEON_ACCESS_R(A, Am, An); CHAMELEON_ACCESS_R(B, Bm, Bn); CHAMELEON_ACCESS_RW(C, Cm, Cn); exec = __chameleon_need_exec; CHAMELEON_END_ACCESS_DECLARATION; if ( exec ) { clargs = malloc( sizeof( struct cl_zhemm_args_s ) ); clargs->side = side; clargs->uplo = uplo; clargs->m = m; clargs->n = n; clargs->alpha = alpha; clargs->beta = beta; } /* Callback for profiling information */ callback = options->profiling ? cl_zhemm_callback : NULL; /* Reduce the C access if needed */ accessC = ( beta == 0. ) ? STARPU_W : (STARPU_RW | ((beta == 1.) ? STARPU_COMMUTE : 0)); /* Refine name */ cl_name = chameleon_codelet_name( cl_name, 3, A->get_blktile( A, Am, An ), B->get_blktile( B, Bm, Bn ), C->get_blktile( C, Cm, Cn ) ); /* Insert the task */ rt_starpu_insert_task( &cl_zhemm, /* Task codelet arguments */ STARPU_CL_ARGS, clargs, sizeof(struct cl_zhemm_args_s), /* Task handles */ STARPU_R, RTBLKADDR(A, ChamComplexDouble, Am, An), STARPU_R, RTBLKADDR(B, ChamComplexDouble, Bm, Bn), accessC, RTBLKADDR(C, ChamComplexDouble, Cm, Cn), /* Common task arguments */ STARPU_PRIORITY, options->priority, STARPU_CALLBACK, callback, STARPU_EXECUTE_ON_WORKER, options->workerid, #if defined(CHAMELEON_CODELETS_HAVE_NAME) STARPU_NAME, cl_name, #endif 0 ); }