Restore the parsec flushes

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()

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);