|
@@ -0,0 +1,450 @@
|
|
|
|
+/* StarPU --- Runtime system for heterogeneous multicore architectures.
|
|
|
|
+ *
|
|
|
|
+ * Copyright (C) 2009, 2010 Université de Bordeaux 1
|
|
|
|
+ * Copyright (C) 2010 Centre National de la Recherche Scientifique
|
|
|
|
+ *
|
|
|
|
+ * StarPU is free software; you can redistribute it and/or modify
|
|
|
|
+ * it under the terms of the GNU Lesser General Public License as published by
|
|
|
|
+ * the Free Software Foundation; either version 2.1 of the License, or (at
|
|
|
|
+ * your option) any later version.
|
|
|
|
+ *
|
|
|
|
+ * StarPU is distributed in the hope that it will be useful, but
|
|
|
|
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
|
|
+ *
|
|
|
|
+ * See the GNU Lesser General Public License in COPYING.LGPL for more details.
|
|
|
|
+ */
|
|
|
|
+
|
|
|
|
+#include "xlu.h"
|
|
|
|
+#include "xlu_kernels.h"
|
|
|
|
+
|
|
|
|
+#define TAG11(k) ((starpu_tag_t)( (1ULL<<60) | (unsigned long long)(k)))
|
|
|
|
+#define TAG12(k,i) ((starpu_tag_t)(((2ULL<<60) | (((unsigned long long)(k))<<32) \
|
|
|
|
+ | (unsigned long long)(i))))
|
|
|
|
+#define TAG21(k,j) ((starpu_tag_t)(((3ULL<<60) | (((unsigned long long)(k))<<32) \
|
|
|
|
+ | (unsigned long long)(j))))
|
|
|
|
+#define TAG22(k,i,j) ((starpu_tag_t)(((4ULL<<60) | ((unsigned long long)(k)<<32) \
|
|
|
|
+ | ((unsigned long long)(i)<<16) \
|
|
|
|
+ | (unsigned long long)(j))))
|
|
|
|
+#define PIVOT(k,i) ((starpu_tag_t)(((5ULL<<60) | (((unsigned long long)(k))<<32) \
|
|
|
|
+ | (unsigned long long)(i))))
|
|
|
|
+
|
|
|
|
+static unsigned no_prio = 0;
|
|
|
|
+starpu_data_handle xlu_pivot_dataA;
|
|
|
|
+starpu_data_handle *xlu_pivot_dataAp;
|
|
|
|
+struct timeval xlu_pivot_start;
|
|
|
|
+struct timeval xlu_pivot_end;
|
|
|
|
+struct timeval xlu_pivot_no_stride_start;
|
|
|
|
+struct timeval xlu_pivot_no_stride_end;
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+/*
|
|
|
|
+ * Construct the DAG
|
|
|
|
+ */
|
|
|
|
+
|
|
|
|
+static struct starpu_task *create_task(starpu_tag_t id)
|
|
|
|
+{
|
|
|
|
+ struct starpu_task *task = starpu_task_create();
|
|
|
|
+ task->cl_arg = NULL;
|
|
|
|
+
|
|
|
|
+ task->use_tag = 1;
|
|
|
|
+ task->tag_id = id;
|
|
|
|
+
|
|
|
|
+ return task;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void create_task_pivot(starpu_data_handle *dataAp, unsigned nblocks,
|
|
|
|
+ struct piv_s *piv_description,
|
|
|
|
+ unsigned k, unsigned i,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned), struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+ struct starpu_task *task = create_task(PIVOT(k, i));
|
|
|
|
+
|
|
|
|
+ task->cl = &cl_pivot;
|
|
|
|
+
|
|
|
|
+ /* which sub-data is manipulated ? */
|
|
|
|
+ task->buffers[0].handle = get_block(dataAp, nblocks, k, i);
|
|
|
|
+ task->buffers[0].mode = STARPU_RW;
|
|
|
|
+
|
|
|
|
+ task->cl_arg = &piv_description[k];
|
|
|
|
+
|
|
|
|
+ /* this is an important task */
|
|
|
|
+ if (!no_prio && (i == k+1))
|
|
|
|
+ task->priority = STARPU_MAX_PRIO;
|
|
|
|
+
|
|
|
|
+ /* enforce dependencies ... */
|
|
|
|
+ if (k == 0) {
|
|
|
|
+ starpu_tag_declare_deps(PIVOT(k, i), 1, TAG11(k));
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ if (i > k) {
|
|
|
|
+ starpu_tag_declare_deps(PIVOT(k, i), 2, TAG11(k), TAG22(k-1, i, k));
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ starpu_tag_t *tags = malloc((nblocks - k)*sizeof(starpu_tag_t));
|
|
|
|
+
|
|
|
|
+ tags[0] = TAG11(k);
|
|
|
|
+ unsigned ind, ind2;
|
|
|
|
+ for (ind = k + 1, ind2 = 0; ind < nblocks; ind++, ind2++)
|
|
|
|
+ {
|
|
|
|
+ tags[1 + ind2] = TAG22(k-1, ind, k);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* perhaps we could do better ... :/ */
|
|
|
|
+ starpu_tag_declare_deps_array(PIVOT(k, i), (nblocks-k), tags);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ starpu_task_submit_to_ctx(task, sched_ctx);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static struct starpu_task *create_task_11_pivot(starpu_data_handle *dataAp, unsigned nblocks,
|
|
|
|
+ unsigned k, struct piv_s *piv_description,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned))
|
|
|
|
+{
|
|
|
|
+ struct starpu_task *task = create_task(TAG11(k));
|
|
|
|
+
|
|
|
|
+ task->cl = &cl11_pivot;
|
|
|
|
+
|
|
|
|
+ task->cl_arg = &piv_description[k];
|
|
|
|
+
|
|
|
|
+ /* which sub-data is manipulated ? */
|
|
|
|
+ task->buffers[0].handle = get_block(dataAp, nblocks, k, k);
|
|
|
|
+ task->buffers[0].mode = STARPU_RW;
|
|
|
|
+
|
|
|
|
+ /* this is an important task */
|
|
|
|
+ if (!no_prio)
|
|
|
|
+ task->priority = STARPU_MAX_PRIO;
|
|
|
|
+
|
|
|
|
+ /* enforce dependencies ... */
|
|
|
|
+ if (k > 0) {
|
|
|
|
+ starpu_tag_declare_deps(TAG11(k), 1, TAG22(k-1, k, k));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return task;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void create_task_12(starpu_data_handle *dataAp, unsigned nblocks, unsigned k, unsigned j,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned), struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+// printf("task 12 k,i = %d,%d TAG = %llx\n", k,i, TAG12(k,i));
|
|
|
|
+
|
|
|
|
+ struct starpu_task *task = create_task(TAG12(k, j));
|
|
|
|
+
|
|
|
|
+ task->cl = &cl12;
|
|
|
|
+
|
|
|
|
+ task->cl_arg = (void *)(task->tag_id);
|
|
|
|
+
|
|
|
|
+ /* which sub-data is manipulated ? */
|
|
|
|
+ task->buffers[0].handle = get_block(dataAp, nblocks, k, k);
|
|
|
|
+ task->buffers[0].mode = STARPU_R;
|
|
|
|
+ task->buffers[1].handle = get_block(dataAp, nblocks, j, k);
|
|
|
|
+ task->buffers[1].mode = STARPU_RW;
|
|
|
|
+
|
|
|
|
+ if (!no_prio && (j == k+1)) {
|
|
|
|
+ task->priority = STARPU_MAX_PRIO;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* enforce dependencies ... */
|
|
|
|
+#if 0
|
|
|
|
+ starpu_tag_declare_deps(TAG12(k, i), 1, PIVOT(k, i));
|
|
|
|
+#endif
|
|
|
|
+ if (k > 0) {
|
|
|
|
+ starpu_tag_declare_deps(TAG12(k, j), 2, TAG11(k), TAG22(k-1, k, j));
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ starpu_tag_declare_deps(TAG12(k, j), 1, TAG11(k));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ starpu_task_submit_to_ctx(task, sched_ctx);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void create_task_21(starpu_data_handle *dataAp, unsigned nblocks, unsigned k, unsigned i,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned), struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+ struct starpu_task *task = create_task(TAG21(k, i));
|
|
|
|
+
|
|
|
|
+ task->cl = &cl21;
|
|
|
|
+
|
|
|
|
+ /* which sub-data is manipulated ? */
|
|
|
|
+ task->buffers[0].handle = get_block(dataAp, nblocks, k, k);
|
|
|
|
+ task->buffers[0].mode = STARPU_R;
|
|
|
|
+ task->buffers[1].handle = get_block(dataAp, nblocks, k, i);
|
|
|
|
+ task->buffers[1].mode = STARPU_RW;
|
|
|
|
+
|
|
|
|
+ if (!no_prio && (i == k+1)) {
|
|
|
|
+ task->priority = STARPU_MAX_PRIO;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ task->cl_arg = (void *)(task->tag_id);
|
|
|
|
+
|
|
|
|
+ /* enforce dependencies ... */
|
|
|
|
+ starpu_tag_declare_deps(TAG21(k, i), 1, PIVOT(k, i));
|
|
|
|
+
|
|
|
|
+ starpu_task_submit_to_ctx(task, sched_ctx);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void create_task_22(starpu_data_handle *dataAp, unsigned nblocks, unsigned k, unsigned i, unsigned j,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned), struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+// printf("task 22 k,i,j = %d,%d,%d TAG = %llx\n", k,i,j, TAG22(k,i,j));
|
|
|
|
+
|
|
|
|
+ struct starpu_task *task = create_task(TAG22(k, i, j));
|
|
|
|
+
|
|
|
|
+ task->cl = &cl22;
|
|
|
|
+
|
|
|
|
+ task->cl_arg = (void *)(task->tag_id);
|
|
|
|
+
|
|
|
|
+ /* which sub-data is manipulated ? */
|
|
|
|
+ task->buffers[0].handle = get_block(dataAp, nblocks, k, i); /* produced by TAG21(k, i) */
|
|
|
|
+ task->buffers[0].mode = STARPU_R;
|
|
|
|
+ task->buffers[1].handle = get_block(dataAp, nblocks, j, k); /* produced by TAG12(k, j) */
|
|
|
|
+ task->buffers[1].mode = STARPU_R;
|
|
|
|
+ task->buffers[2].handle = get_block(dataAp, nblocks, j, i); /* produced by TAG22(k-1, i, j) */
|
|
|
|
+ task->buffers[2].mode = STARPU_RW;
|
|
|
|
+
|
|
|
|
+ if (!no_prio && (i == k + 1) && (j == k +1) ) {
|
|
|
|
+ task->priority = STARPU_MAX_PRIO;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* enforce dependencies ... */
|
|
|
|
+ if (k > 0) {
|
|
|
|
+ starpu_tag_declare_deps(TAG22(k, i, j), 3, TAG22(k-1, i, j), TAG12(k, j), TAG21(k, i));
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ starpu_tag_declare_deps(TAG22(k, i, j), 2, TAG12(k, j), TAG21(k, i));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ starpu_task_submit_to_ctx(task, sched_ctx);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+/*
|
|
|
|
+ * code to bootstrap the factorization
|
|
|
|
+ */
|
|
|
|
+
|
|
|
|
+static double dw_codelet_facto_pivot(starpu_data_handle *dataAp,
|
|
|
|
+ struct piv_s *piv_description,
|
|
|
|
+ unsigned nblocks,
|
|
|
|
+ starpu_data_handle (* get_block)(starpu_data_handle *, unsigned, unsigned, unsigned), struct starpu_sched_ctx *sched_ctx,
|
|
|
|
+ struct timeval *start)
|
|
|
|
+{
|
|
|
|
+ struct starpu_task *entry_task = NULL;
|
|
|
|
+
|
|
|
|
+ /* create all the DAG nodes */
|
|
|
|
+ unsigned i,j,k;
|
|
|
|
+
|
|
|
|
+ for (k = 0; k < nblocks; k++)
|
|
|
|
+ {
|
|
|
|
+ struct starpu_task *task = create_task_11_pivot(dataAp, nblocks, k, piv_description, get_block);
|
|
|
|
+
|
|
|
|
+ /* we defer the launch of the first task */
|
|
|
|
+ if (k == 0) {
|
|
|
|
+ entry_task = task;
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ starpu_task_submit_to_ctx(task, sched_ctx);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ for (i = 0; i < nblocks; i++)
|
|
|
|
+ {
|
|
|
|
+ if (i != k)
|
|
|
|
+ create_task_pivot(dataAp, nblocks, piv_description, k, i, get_block, sched_ctx);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ for (i = k+1; i<nblocks; i++)
|
|
|
|
+ {
|
|
|
|
+ create_task_12(dataAp, nblocks, k, i, get_block, sched_ctx);
|
|
|
|
+ create_task_21(dataAp, nblocks, k, i, get_block, sched_ctx);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ for (i = k+1; i<nblocks; i++)
|
|
|
|
+ {
|
|
|
|
+ for (j = k+1; j<nblocks; j++)
|
|
|
|
+ {
|
|
|
|
+ create_task_22(dataAp, nblocks, k, i, j, get_block, sched_ctx);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* schedule the codelet */
|
|
|
|
+ gettimeofday(start, NULL);
|
|
|
|
+ int ret = starpu_task_submit_to_ctx(entry_task, sched_ctx);
|
|
|
|
+ if (STARPU_UNLIKELY(ret == -ENODEV))
|
|
|
|
+ {
|
|
|
|
+ fprintf(stderr, "No worker may execute this task\n");
|
|
|
|
+ exit(-1);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return 0;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+starpu_data_handle get_block_with_striding(starpu_data_handle *dataAp,
|
|
|
|
+ unsigned nblocks __attribute__((unused)), unsigned j, unsigned i)
|
|
|
|
+{
|
|
|
|
+ /* we use filters */
|
|
|
|
+ return starpu_data_get_sub_data(*dataAp, 2, j, i);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+void STARPU_LU(lu_decomposition_pivot)(TYPE *matA, unsigned *ipiv, unsigned size, unsigned ld, unsigned nblocks, struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+
|
|
|
|
+ /* monitor and partition the A matrix into blocks :
|
|
|
|
+ * one block is now determined by 2 unsigned (i,j) */
|
|
|
|
+ starpu_matrix_data_register(&xlu_pivot_dataA, 0, (uintptr_t)matA, ld, size, size, sizeof(TYPE));
|
|
|
|
+
|
|
|
|
+ /* We already enforce deps by hand */
|
|
|
|
+ starpu_data_set_sequential_consistency_flag(xlu_pivot_dataA, 0);
|
|
|
|
+
|
|
|
|
+ struct starpu_data_filter f;
|
|
|
|
+ f.filter_func = starpu_vertical_block_filter_func;
|
|
|
|
+ f.nchildren = nblocks;
|
|
|
|
+
|
|
|
|
+ struct starpu_data_filter f2;
|
|
|
|
+ f2.filter_func = starpu_block_filter_func;
|
|
|
|
+ f2.nchildren = nblocks;
|
|
|
|
+
|
|
|
|
+ starpu_data_map_filters(xlu_pivot_dataA, 2, &f, &f2);
|
|
|
|
+
|
|
|
|
+ unsigned i;
|
|
|
|
+ for (i = 0; i < size; i++)
|
|
|
|
+ ipiv[i] = i;
|
|
|
|
+
|
|
|
|
+ struct piv_s *piv_description = malloc(nblocks*sizeof(struct piv_s));
|
|
|
|
+ unsigned block;
|
|
|
|
+ for (block = 0; block < nblocks; block++)
|
|
|
|
+ {
|
|
|
|
+ piv_description[block].piv = ipiv;
|
|
|
|
+ piv_description[block].first = block * (size / nblocks);
|
|
|
|
+ piv_description[block].last = (block + 1) * (size / nblocks);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+#if 0
|
|
|
|
+ unsigned j;
|
|
|
|
+ for (j = 0; j < nblocks; j++)
|
|
|
|
+ for (i = 0; i < nblocks; i++)
|
|
|
|
+ {
|
|
|
|
+ printf("BLOCK %d %d %p\n", i, j, &matA[i*(size/nblocks) + j * (size/nblocks)*ld]);
|
|
|
|
+ }
|
|
|
|
+#endif
|
|
|
|
+
|
|
|
|
+ dw_codelet_facto_pivot(&xlu_pivot_dataA, piv_description, nblocks, get_block_with_striding, sched_ctx, &xlu_pivot_start);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+starpu_data_handle get_block_with_no_striding(starpu_data_handle *dataAp, unsigned nblocks, unsigned j, unsigned i)
|
|
|
|
+{
|
|
|
|
+ /* dataAp is an array of data handle */
|
|
|
|
+ return dataAp[i+j*nblocks];
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+void STARPU_LU(lu_decomposition_pivot_no_stride)(TYPE **matA, unsigned *ipiv, unsigned size, unsigned ld, unsigned nblocks, struct starpu_sched_ctx *sched_ctx)
|
|
|
|
+{
|
|
|
|
+ xlu_pivot_dataAp = malloc(nblocks*nblocks*sizeof(starpu_data_handle));
|
|
|
|
+
|
|
|
|
+ /* monitor and partition the A matrix into blocks :
|
|
|
|
+ * one block is now determined by 2 unsigned (i,j) */
|
|
|
|
+ unsigned bi, bj;
|
|
|
|
+ for (bj = 0; bj < nblocks; bj++)
|
|
|
|
+ for (bi = 0; bi < nblocks; bi++)
|
|
|
|
+ {
|
|
|
|
+ starpu_matrix_data_register(&xlu_pivot_dataAp[bi+nblocks*bj], 0,
|
|
|
|
+ (uintptr_t)matA[bi+nblocks*bj], size/nblocks,
|
|
|
|
+ size/nblocks, size/nblocks, sizeof(TYPE));
|
|
|
|
+
|
|
|
|
+ /* We already enforce deps by hand */
|
|
|
|
+ starpu_data_set_sequential_consistency_flag(xlu_pivot_dataAp[bi+nblocks*bj], 0);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ unsigned i;
|
|
|
|
+ for (i = 0; i < size; i++)
|
|
|
|
+ ipiv[i] = i;
|
|
|
|
+
|
|
|
|
+ struct piv_s *piv_description = malloc(nblocks*sizeof(struct piv_s));
|
|
|
|
+ unsigned block;
|
|
|
|
+ for (block = 0; block < nblocks; block++)
|
|
|
|
+ {
|
|
|
|
+ piv_description[block].piv = ipiv;
|
|
|
|
+ piv_description[block].first = block * (size / nblocks);
|
|
|
|
+ piv_description[block].last = (block + 1) * (size / nblocks);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ dw_codelet_facto_pivot(xlu_pivot_dataAp, piv_description, nblocks, get_block_with_no_striding, sched_ctx, &xlu_pivot_no_stride_start);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+void finish_lu_decomposition_pivot(unsigned nblocks)
|
|
|
|
+{
|
|
|
|
+ /* we wait the last task (TAG11(nblocks - 1)) and all the pivot tasks */
|
|
|
|
+ starpu_tag_t *tags = malloc(nblocks*nblocks*sizeof(starpu_tag_t));
|
|
|
|
+ unsigned ndeps = 0;
|
|
|
|
+
|
|
|
|
+ tags[ndeps++] = TAG11(nblocks - 1);
|
|
|
|
+
|
|
|
|
+ unsigned i, j;
|
|
|
|
+ for (j = 0; j < nblocks; j++)
|
|
|
|
+ {
|
|
|
|
+ for (i = 0; i < j; i++)
|
|
|
|
+ {
|
|
|
|
+ tags[ndeps++] = PIVOT(j, i);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* stall the application until the end of computations */
|
|
|
|
+ starpu_tag_wait_array(ndeps, tags);
|
|
|
|
+// starpu_task_wait_for_all();
|
|
|
|
+
|
|
|
|
+ gettimeofday(&xlu_pivot_end, NULL);
|
|
|
|
+
|
|
|
|
+ double timing = (double)((&xlu_pivot_end.tv_sec - &xlu_pivot_start.tv_sec)*1000000 + (&xlu_pivot_end.tv_usec - &xlu_pivot_start.tv_usec));
|
|
|
|
+
|
|
|
|
+ fprintf(stderr, "Computation took (in ms)\n");
|
|
|
|
+ fprintf(stderr, "%2.2f\n", timing/1000);
|
|
|
|
+
|
|
|
|
+ unsigned n = starpu_matrix_get_nx(xlu_pivot_dataA);
|
|
|
|
+ double flop = (2.0f*n*n*n)/3.0f;
|
|
|
|
+ fprintf(stderr, "Synthetic GFlops : %2.2f\n", (flop/timing/1000.0f));
|
|
|
|
+
|
|
|
|
+ /* gather all the data */
|
|
|
|
+ starpu_data_unpartition(xlu_pivot_dataA, 0);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+void finish_lu_decomposition_pivot_no_stride(unsigned nblocks)
|
|
|
|
+{
|
|
|
|
+ /* we wait the last task (TAG11(nblocks - 1)) and all the pivot tasks */
|
|
|
|
+ starpu_tag_t *tags = malloc(nblocks*nblocks*sizeof(starpu_tag_t));
|
|
|
|
+ unsigned ndeps = 0;
|
|
|
|
+
|
|
|
|
+ tags[ndeps++] = TAG11(nblocks - 1);
|
|
|
|
+
|
|
|
|
+ unsigned i, j;
|
|
|
|
+ for (j = 0; j < nblocks; j++)
|
|
|
|
+ {
|
|
|
|
+ for (i = 0; i < j; i++)
|
|
|
|
+ {
|
|
|
|
+ tags[ndeps++] = PIVOT(j, i);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /* stall the application until the end of computations */
|
|
|
|
+ starpu_tag_wait_array(ndeps, tags);
|
|
|
|
+// starpu_task_wait_for_all();
|
|
|
|
+
|
|
|
|
+ gettimeofday(&xlu_pivot_no_stride_end, NULL);
|
|
|
|
+
|
|
|
|
+ double timing = (double)((&xlu_pivot_no_stride_end.tv_sec - &xlu_pivot_no_stride_start.tv_sec)*1000000 + (&xlu_pivot_no_stride_end.tv_usec - &xlu_pivot_no_stride_start.tv_usec));
|
|
|
|
+
|
|
|
|
+ fprintf(stderr, "Computation took (in ms)\n");
|
|
|
|
+ fprintf(stderr, "%2.2f\n", timing/1000);
|
|
|
|
+
|
|
|
|
+ unsigned n = starpu_matrix_get_nx(xlu_pivot_dataAp[0])*nblocks;
|
|
|
|
+ double flop = (2.0f*n*n*n)/3.0f;
|
|
|
|
+ fprintf(stderr, "Synthetic GFlops : %2.2f\n", (flop/timing/1000.0f));
|
|
|
|
+
|
|
|
|
+ unsigned bi, bj;
|
|
|
|
+ for (bj = 0; bj < nblocks; bj++)
|
|
|
|
+ for (bi = 0; bi < nblocks; bi++)
|
|
|
|
+ {
|
|
|
|
+ starpu_data_unregister(xlu_pivot_dataAp[bi+nblocks*bj]);
|
|
|
|
+ }
|
|
|
|
+}
|