|
@@ -128,6 +128,7 @@ inline void starpu_heteroprio_set_mapping(unsigned sched_ctx_id, enum starpu_het
|
|
|
hp->prio_mapping_per_arch_index[arch][source_prio] = dest_bucket_id;
|
|
|
|
|
|
hp->buckets[dest_bucket_id].valid_archs |= starpu_heteroprio_types_to_arch[arch];
|
|
|
+ _STARPU_DEBUG("Adding arch %d to bucket %d\n", arch, dest_bucket_id);
|
|
|
}
|
|
|
|
|
|
/** Tell which arch is the faster for the tasks of a bucket (optional) */
|
|
@@ -354,7 +355,7 @@ static int push_task_heteroprio_policy(struct starpu_task *task)
|
|
|
STARPU_ASSERT(task->priority < STARPU_HETEROPRIO_MAX_PRIO);
|
|
|
struct _heteroprio_bucket* bucket = &hp->buckets[task->priority];
|
|
|
/* Ensure that any worker that check that list can compute the task */
|
|
|
- STARPU_ASSERT(bucket->valid_archs);
|
|
|
+ STARPU_ASSERT_MSG(bucket->valid_archs, "The bucket %d does not have any archs\n", task->priority);
|
|
|
STARPU_ASSERT(((bucket->valid_archs ^ task->cl->where) & bucket->valid_archs) == 0);
|
|
|
|
|
|
/* save the task */
|