From f8b229e3f0d629dfcdeb8216d30c6e32e9bf8014 Mon Sep 17 00:00:00 2001
From: Mathieu Faverge <mathieu.faverge@inria.fr>
Date: Wed, 13 Dec 2017 14:13:12 +0100
Subject: [PATCH] Restore the parsec flushes
---
runtime/parsec/codelets/codelet_dataflush.c | 20 ++++++++------------
runtime/parsec/control/runtime_async.c | 2 +-
2 files changed, 9 insertions(+), 13 deletions(-)
diff --git a/runtime/parsec/codelets/codelet_dataflush.c b/runtime/parsec/codelets/codelet_dataflush.c
index d9ebc1c86..a065cedf4 100644
--- a/runtime/parsec/codelets/codelet_dataflush.c
+++ b/runtime/parsec/codelets/codelet_dataflush.c
@@ -23,25 +23,21 @@
#include "chameleon/morse_tasks.h"
void MORSE_TASK_flush_data( const MORSE_option_t *options,
- const MORSE_desc_t *A, int Am, int An )
+ const MORSE_desc_t *A, int Am, int An )
{
- (void)options; (void)A; (void)Am; (void)An;
+ parsec_taskpool_t* PARSEC_dtd_taskpool = (parsec_taskpool_t *)(options->sequence->schedopt);
- /*
- * This is useful for StarPU and PaRSEC MPI implementation, if it happens in
- * Quark, it will need to be done carefuly to not break other runtimes.
- */
+ parsec_dtd_data_flush( PARSEC_dtd_taskpool, RTBLKADDR( A, MORSE_Complex64_t, Am, An ) );
}
void MORSE_TASK_flush_desc( const MORSE_option_t *options,
- MORSE_enum uplo, const MORSE_desc_t *A )
+ MORSE_enum uplo, const MORSE_desc_t *A )
{
- (void)options; (void)uplo; (void)A;
+ parsec_taskpool_t* PARSEC_dtd_taskpool = (parsec_taskpool_t *)(options->sequence->schedopt);
- /*
- * This is useful for StarPU and PaRSEC MPI implementation, if it happens in
- * Quark, it will need to be done carefuly to not break other runtimes.
- */
+ parsec_dtd_data_flush_all( PARSEC_dtd_taskpool, (parsec_data_collection_t*)(A->schedopt) );
+
+ (void)uplo;
}
void MORSE_TASK_flush_all()
diff --git a/runtime/parsec/control/runtime_async.c b/runtime/parsec/control/runtime_async.c
index 3b3c98f4d..7df5d0bcf 100644
--- a/runtime/parsec/control/runtime_async.c
+++ b/runtime/parsec/control/runtime_async.c
@@ -37,7 +37,7 @@ int RUNTIME_sequence_destroy(MORSE_context_t *morse, MORSE_sequence_t *sequence)
assert( parsec_dtd_tp );
- // TODO: switch to a patial wait
+ // TODO: switch to a partial wait
//parsec_dtd_taskpool_wait(parsec, parsec_dtd_tp);
parsec_context_wait(parsec);
--
GitLab