diff --git a/runtime/parsec/codelets/codelet_dataflush.c b/runtime/parsec/codelets/codelet_dataflush.c index d9ebc1c864c7f2abd51f511222494a26169531b5..a065cedf48fc5734a7bd17adac79d1955faa97f3 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 3b3c98f4d10fd7661d6cc221f0da0b7d3dd3a88f..7df5d0bcf2b086a2c6e28c2b3136a150a3a555d8 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);