Skip to content

Commit

Permalink
PaRSEC backend: Restore priorities
Browse files Browse the repository at this point in the history
Signed-off-by: Joseph Schuchart <[email protected]>
  • Loading branch information
devreal committed May 26, 2023
1 parent 5a1b4e8 commit 0433454
Showing 1 changed file with 2 additions and 7 deletions.
9 changes: 2 additions & 7 deletions ttg/ttg/parsec/ttg.h
Original file line number Diff line number Diff line change
Expand Up @@ -584,7 +584,6 @@ namespace ttg_parsec {
: data_count(data_count)
, defer_writer(defer_writer)
, release_task_cb(release_fn) {
int32_t p = priority;
PARSEC_LIST_ITEM_SINGLETON(&parsec_task.super);
parsec_task.mempool_owner = mempool;
parsec_task.task_class = task_class;
Expand Down Expand Up @@ -796,10 +795,6 @@ namespace ttg_parsec {
return PARSEC_HOOK_RETURN_DONE;
}

static parsec_key_fn_t parsec_tasks_hash_fcts = {.key_equal = parsec_hash_table_generic_64bits_key_equal,
.key_print = parsec_hash_table_generic_64bits_key_print,
.key_hash = parsec_hash_table_generic_64bits_key_hash};

template <typename KeyT, typename ActivationCallbackT>
class rma_delayed_activate {
std::vector<KeyT> _keylist;
Expand Down Expand Up @@ -1713,11 +1708,11 @@ namespace ttg_parsec {
char *taskobj = (char *)parsec_thread_mempool_allocate(mempool);
int32_t priority = 0;
if constexpr (!keyT_is_Void) {
//priority = priomap(key);
priority = priomap(key);
/* placement-new the task */
newtask = new (taskobj) task_t(key, mempool, &this->self, world_impl.taskpool(), this, priority);
} else {
//priority = priomap();
priority = priomap();
/* placement-new the task */
newtask = new (taskobj) task_t(mempool, &this->self, world_impl.taskpool(), this, priority);
}
Expand Down

0 comments on commit 0433454

Please sign in to comment.