mirror of
https://github.com/TREX-CoE/irpjast.git
synced 2025-01-10 21:18:38 +01:00
StarPU OK
This commit is contained in:
parent
a43ef7893e
commit
af8705d22c
4
Makefile
4
Makefile
@ -1,7 +1,7 @@
|
||||
IRPF90 = irpf90/bin/irpf90 --codelet=factor_een:2 --align=4096 # -s nelec_8:504 -s nnuc:100 -s ncord:5 #-a -d
|
||||
#FC = ifort -xCORE-AVX512 -g -mkl=sequential -qopt-zmm-usage=high
|
||||
FC = ifort -xCORE-AVX2 -g
|
||||
CC = gcc -fopenmp
|
||||
CC = gcc -fopenmp $(shell pkg-config --cflags starpu-1.3)
|
||||
FCFLAGS= -O3 -I .
|
||||
NINJA = ninja
|
||||
ARCHIVE = ar crs
|
||||
@ -9,7 +9,7 @@ RANLIB = ranlib
|
||||
|
||||
SRC= qmckl_blas_f.f90 qmckl_dgemm.c
|
||||
OBJ= IRPF90_temp/qmckl_blas_f.o IRPF90_temp/qmckl_dgemm.o
|
||||
LIB= -mkl=sequential -lgomp
|
||||
LIB= -mkl=sequential -lgomp $(shell pkg-config --libs starpu-1.3)
|
||||
|
||||
-include irpf90.make
|
||||
export
|
||||
|
||||
148
qmckl_dgemm.c
148
qmckl_dgemm.c
@ -1,9 +1,12 @@
|
||||
/* Generated from qmckl_dgemm.org */
|
||||
|
||||
#include <starpu.h>
|
||||
|
||||
#include <cblas.h>
|
||||
#include <stdint.h>
|
||||
#include <assert.h>
|
||||
#include <stdlib.h>
|
||||
#include <stdio.h>
|
||||
|
||||
|
||||
|
||||
@ -24,70 +27,36 @@ struct dgemm_args {
|
||||
};
|
||||
|
||||
|
||||
#define MIN_SIZE 512
|
||||
void qmckl_dgemm_cl(struct dgemm_args args, double* A, double* B, double* C);
|
||||
|
||||
void dgemm_codelet(void *buffers[], void* cl_arg)
|
||||
{
|
||||
struct dgemm_args *args = cl_arg;
|
||||
double* A = (double*) STARPU_MATRIX_GET_PTR(buffers[0]);
|
||||
double* B = (double*) STARPU_MATRIX_GET_PTR(buffers[1]);
|
||||
double* C = (double*) STARPU_MATRIX_GET_PTR(buffers[2]);
|
||||
qmckl_dgemm_cl(*args, A, B, C);
|
||||
free(args);
|
||||
}
|
||||
|
||||
struct starpu_codelet dgemm_cl =
|
||||
{
|
||||
.where = STARPU_CPU,
|
||||
.cpu_funcs = { dgemm_codelet },
|
||||
.cpu_funcs_name = { "dgemm_codelet" },
|
||||
.nbuffers = 3,
|
||||
.max_parallelism = 1,
|
||||
.modes = {STARPU_R, STARPU_R, STARPU_RW},
|
||||
|
||||
};
|
||||
|
||||
#include<stdio.h>
|
||||
|
||||
static void qmckl_dgemm_rec(struct dgemm_args args) {
|
||||
|
||||
// printf("%5d %5d\n", args.m, args.n);
|
||||
|
||||
if ( (args.m <= MIN_SIZE) || (args.n <= MIN_SIZE)) {
|
||||
#pragma omp task
|
||||
{
|
||||
printf("BLAS %5d %5d %5d\n", args.m, args.n, args.k);
|
||||
cblas_dgemm(CblasColMajor, args.transa, args.transb,
|
||||
args.m, args.n, args.k, args.alpha,
|
||||
args.A, args.lda, args.B, args.ldb,
|
||||
args.beta, args.C, args.ldc);
|
||||
}
|
||||
} else {
|
||||
|
||||
int m1 = args.m / 2;
|
||||
int m2 = args.m - m1;
|
||||
int n1 = args.n / 2;
|
||||
int n2 = args.n - n1;
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_1 = args;
|
||||
args_1.m = m1;
|
||||
args_1.n = n1;
|
||||
qmckl_dgemm_rec(args_1);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
// TODO: assuming 'N', 'N' here
|
||||
struct dgemm_args args_2 = args;
|
||||
args_2.B = args.B + args.ldb*n1;
|
||||
args_2.C = args.C + args.ldc*n1;
|
||||
args_2.m = m1;
|
||||
args_2.n = n2;
|
||||
qmckl_dgemm_rec(args_2);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_3 = args;
|
||||
args_3.A = args.A + m1;
|
||||
args_3.C = args.C + m1;
|
||||
args_3.m = m2;
|
||||
args_3.n = n1;
|
||||
qmckl_dgemm_rec(args_3);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_4 = args;
|
||||
args_4.A = args.A + m1;
|
||||
args_4.B = args.B + args.ldb*n1;
|
||||
args_4.C = args.C + m1 + args.ldc*n1;
|
||||
args_4.m = m2;
|
||||
args_4.n = n2;
|
||||
qmckl_dgemm_rec(args_4);
|
||||
}
|
||||
}
|
||||
|
||||
void qmckl_dgemm_cl(struct dgemm_args args, double* A, double* B, double* C) {
|
||||
cblas_dgemm(CblasColMajor, args.transa, args.transb,
|
||||
args.m, args.n, args.k, args.alpha,
|
||||
A, args.lda, B, args.ldb,
|
||||
args.beta, C, args.ldc);
|
||||
}
|
||||
|
||||
void qmckl_dgemm(char transa, char transb,
|
||||
@ -132,15 +101,52 @@ void qmckl_dgemm(char transa, char transb,
|
||||
|
||||
void qmckl_tasks_run(struct dgemm_args** gemms, int ngemms)
|
||||
{
|
||||
#pragma omp parallel
|
||||
{
|
||||
#pragma omp single
|
||||
starpu_init(NULL);
|
||||
|
||||
starpu_data_handle_t matrix_handle[ngemms][3];
|
||||
for (int i=0 ; i<ngemms ; ++i)
|
||||
{
|
||||
for (int i=0 ; i<ngemms ; ++i)
|
||||
{
|
||||
qmckl_dgemm_rec(*(gemms[i]));
|
||||
}
|
||||
starpu_matrix_data_register(&(matrix_handle[i][0]),
|
||||
STARPU_MAIN_RAM,
|
||||
(uintptr_t) gemms[i]->A,
|
||||
gemms[i]->lda,
|
||||
gemms[i]->k,
|
||||
gemms[i]->m,
|
||||
sizeof(double));
|
||||
|
||||
starpu_matrix_data_register(&(matrix_handle[i][1]),
|
||||
STARPU_MAIN_RAM,
|
||||
(uintptr_t) gemms[i]->B,
|
||||
gemms[i]->ldb,
|
||||
gemms[i]->n,
|
||||
gemms[i]->k,
|
||||
sizeof(double));
|
||||
|
||||
starpu_matrix_data_register(&(matrix_handle[i][2]),
|
||||
STARPU_MAIN_RAM,
|
||||
(uintptr_t) gemms[i]->C,
|
||||
gemms[i]->ldc,
|
||||
gemms[i]->n,
|
||||
gemms[i]->m,
|
||||
sizeof(double));
|
||||
|
||||
struct starpu_task *task = starpu_task_create();
|
||||
|
||||
task->cl = &dgemm_cl;
|
||||
task->cl_arg = gemms[i];
|
||||
task->cl_arg_size = sizeof(*gemms[0]);
|
||||
task->handles[0] = matrix_handle[i][0];
|
||||
task->handles[1] = matrix_handle[i][1];
|
||||
task->handles[2] = matrix_handle[i][2];
|
||||
starpu_task_submit(task);
|
||||
}
|
||||
#pragma omp taskwait
|
||||
}
|
||||
starpu_task_wait_for_all();
|
||||
|
||||
for (int i=0 ; i<ngemms ; ++i)
|
||||
{
|
||||
starpu_data_unregister(matrix_handle[i][0]);
|
||||
starpu_data_unregister(matrix_handle[i][1]);
|
||||
starpu_data_unregister(matrix_handle[i][2]);
|
||||
}
|
||||
starpu_shutdown();
|
||||
}
|
||||
|
||||
221
qmckl_dgemm.org
221
qmckl_dgemm.org
@ -1,221 +0,0 @@
|
||||
#+TITLE: QMCkl dgemm
|
||||
|
||||
#+NAME: header
|
||||
#+BEGIN_SRC text
|
||||
Generated from qmckl_dgemm.org
|
||||
#+END_SRC
|
||||
|
||||
#+BEGIN_SRC c :noweb yes :tangle qmckl_dgemm.c
|
||||
/* <<header>> */
|
||||
|
||||
#include <cblas.h>
|
||||
#include <stdint.h>
|
||||
#include <assert.h>
|
||||
#include <stdlib.h>
|
||||
|
||||
<<tasks_init>>
|
||||
|
||||
<<dgemm_args>>
|
||||
|
||||
<<dgemm_rec>>
|
||||
|
||||
<<dgemm>>
|
||||
|
||||
<<tasks_run>>
|
||||
|
||||
#+END_SRC
|
||||
|
||||
* Fortran interface
|
||||
|
||||
#+BEGIN_SRC f90 :noweb yes :tangle qmckl_blas_f.f90
|
||||
! <<header>>
|
||||
|
||||
module qmckl_blas
|
||||
use :: iso_c_binding
|
||||
|
||||
interface
|
||||
subroutine qmckl_dgemm(transa, transb, m, n, k, &
|
||||
alpha, A, lda, B, ldb, beta, C, ldc, res) bind(C)
|
||||
use :: iso_c_binding
|
||||
implicit none
|
||||
character(kind=c_char ), value :: transa, transb
|
||||
integer (kind=c_int ), value :: m, n, k, lda, ldb, ldc
|
||||
real (kind=c_double), value :: alpha, beta
|
||||
real (kind=c_double) :: A(lda,*), B(ldb,*), C(ldc,*)
|
||||
integer (kind=c_int64_t) :: res
|
||||
end subroutine qmckl_dgemm
|
||||
end interface
|
||||
|
||||
interface
|
||||
subroutine qmckl_tasks_run(gemms, ngemms) bind(C)
|
||||
use :: iso_c_binding
|
||||
implicit none
|
||||
integer (kind=c_int32_t), value :: ngemms
|
||||
integer (kind=c_int64_t) :: gemms(ngemms)
|
||||
end subroutine qmckl_tasks_run
|
||||
end interface
|
||||
|
||||
end module qmckl_blas
|
||||
#+END_SRC
|
||||
|
||||
* TODO C code
|
||||
|
||||
|
||||
The main function packs the arguments in the struct and returns
|
||||
the struct as a result.
|
||||
|
||||
#+NAME: dgemm_args
|
||||
#+BEGIN_SRC c
|
||||
struct dgemm_args {
|
||||
double alpha;
|
||||
double beta;
|
||||
double* A;
|
||||
double* B;
|
||||
double* C;
|
||||
int m;
|
||||
int n;
|
||||
int k;
|
||||
int lda;
|
||||
int ldb;
|
||||
int ldc;
|
||||
CBLAS_LAYOUT transa;
|
||||
CBLAS_LAYOUT transb;
|
||||
};
|
||||
|
||||
#+END_SRC
|
||||
|
||||
#+NAME: dgemm
|
||||
#+BEGIN_SRC c
|
||||
void qmckl_dgemm(char transa, char transb,
|
||||
int m, int n, int k,
|
||||
double alpha,
|
||||
double* A, int lda,
|
||||
double* B, int ldb,
|
||||
double beta,
|
||||
double* C, int ldc,
|
||||
int64_t* result)
|
||||
{
|
||||
struct dgemm_args* args = (struct dgemm_args*) malloc (sizeof(struct dgemm_args));
|
||||
assert (args != NULL);
|
||||
*result = (int64_t) args;
|
||||
|
||||
args->alpha = alpha;
|
||||
args->beta = beta ;
|
||||
args->A = A;
|
||||
args->B = B;
|
||||
args->C = C;
|
||||
args->m = m;
|
||||
args->n = n;
|
||||
args->k = k;
|
||||
args->lda = lda;
|
||||
args->ldb = ldb;
|
||||
args->ldc = ldc;
|
||||
|
||||
if (transa == 'T' || transa == 't') {
|
||||
args->transa = CblasTrans;
|
||||
} else {
|
||||
args->transa = CblasNoTrans;
|
||||
}
|
||||
|
||||
if (transa == 'T' || transa == 't') {
|
||||
args->transb = CblasTrans;
|
||||
} else {
|
||||
args->transb = CblasNoTrans;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#+END_SRC
|
||||
|
||||
To run the dgemms as tasks, pass all the dgemms to do to the
|
||||
following function. It call task-based the recursive dgemm defined below.
|
||||
|
||||
#+NAME: tasks_run
|
||||
#+BEGIN_SRC c
|
||||
void qmckl_tasks_run(struct dgemm_args** gemms, int ngemms)
|
||||
{
|
||||
#pragma omp parallel
|
||||
{
|
||||
#pragma omp single
|
||||
{
|
||||
for (int i=0 ; i<ngemms ; ++i)
|
||||
{
|
||||
qmckl_dgemm_rec(*(gemms[i]));
|
||||
}
|
||||
}
|
||||
#pragma omp taskwait
|
||||
}
|
||||
}
|
||||
#+END_SRC
|
||||
|
||||
|
||||
#+NAME: dgemm_rec
|
||||
#+BEGIN_SRC c
|
||||
#define MIN_SIZE 512
|
||||
#include<stdio.h>
|
||||
|
||||
static void qmckl_dgemm_rec(struct dgemm_args args) {
|
||||
|
||||
// printf("%5d %5d\n", args.m, args.n);
|
||||
|
||||
if ( (args.m <= MIN_SIZE) || (args.n <= MIN_SIZE)) {
|
||||
#pragma omp task
|
||||
{
|
||||
printf("BLAS %5d %5d %5d\n", args.m, args.n, args.k);
|
||||
cblas_dgemm(CblasColMajor, args.transa, args.transb,
|
||||
args.m, args.n, args.k, args.alpha,
|
||||
args.A, args.lda, args.B, args.ldb,
|
||||
args.beta, args.C, args.ldc);
|
||||
}
|
||||
} else {
|
||||
|
||||
int m1 = args.m / 2;
|
||||
int m2 = args.m - m1;
|
||||
int n1 = args.n / 2;
|
||||
int n2 = args.n - n1;
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_1 = args;
|
||||
args_1.m = m1;
|
||||
args_1.n = n1;
|
||||
qmckl_dgemm_rec(args_1);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
// TODO: assuming 'N', 'N' here
|
||||
struct dgemm_args args_2 = args;
|
||||
args_2.B = args.B + args.ldb*n1;
|
||||
args_2.C = args.C + args.ldc*n1;
|
||||
args_2.m = m1;
|
||||
args_2.n = n2;
|
||||
qmckl_dgemm_rec(args_2);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_3 = args;
|
||||
args_3.A = args.A + m1;
|
||||
args_3.C = args.C + m1;
|
||||
args_3.m = m2;
|
||||
args_3.n = n1;
|
||||
qmckl_dgemm_rec(args_3);
|
||||
}
|
||||
|
||||
#pragma omp task
|
||||
{
|
||||
struct dgemm_args args_4 = args;
|
||||
args_4.A = args.A + m1;
|
||||
args_4.B = args.B + args.ldb*n1;
|
||||
args_4.C = args.C + m1 + args.ldc*n1;
|
||||
args_4.m = m2;
|
||||
args_4.n = n2;
|
||||
qmckl_dgemm_rec(args_4);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
#+END_SRC
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user