OrgACRN
/
sof
mirror of https://github.com/thesofproject/sof.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

ll_schedule: implement schedule_task_before and schedule_task_after 

Add support for order-enforcing scheduling to the ll-scheduler.

Signed-off-by: Guennadi Liakhovetski <guennadi.liakhovetski@linux.intel.com>
This commit is contained in:
Guennadi Liakhovetski 2021-11-24 13:09:40 +01:00 committed by Liam Girdwood
parent ae1975660b
commit 03b24ba660
1 changed files with 45 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/schedule/ll_schedule.c
View File

@ -407,10 +407,20 @@ static void schedule_ll_task_insert(struct task *task, struct list_item *tasks)
list_item_append(&task->list, tasks);
}
static int schedule_ll_task(void *data, struct task *task, uint64_t start,
uint64_t period)
static void schedule_ll_task_insert_before(struct task *task, struct task *before)
{
list_item_append(&task->list, &before->list);
}
static void schedule_ll_task_insert_after(struct task *task, struct task *after)
{
list_item_prepend(&task->list, &after->list);
}
static int schedule_ll_task_common(struct ll_schedule_data *sch, struct task *task,
uint64_t start, uint64_t period,
struct task *reference, bool before)
{
struct ll_schedule_data *sch = data;
struct ll_task_pdata *pdata;
struct ll_task_pdata *reg_pdata;
struct list_item *tlist;
@ -486,7 +496,12 @@ static int schedule_ll_task(void *data, struct task *task, uint64_t start,
}
/* insert task into the list */
schedule_ll_task_insert(task, &sch->tasks);
if (!reference)
schedule_ll_task_insert(task, &sch->tasks);
else if (before)
schedule_ll_task_insert_before(task, reference);
else
schedule_ll_task_insert_after(task, reference);
task->state = SOF_TASK_STATE_QUEUED;
/* set schedule domain */
@ -503,6 +518,30 @@ out:
return ret;
}
static int schedule_ll_task(void *data, struct task *task, uint64_t start,
uint64_t period)
{
struct ll_schedule_data *sch = data;
return schedule_ll_task_common(sch, task, start, period, NULL, false);
}
static int schedule_ll_task_before(void *data, struct task *task, uint64_t start,
uint64_t period, struct task *before)
{
struct ll_schedule_data *sch = data;
return schedule_ll_task_common(sch, task, start, period, before, true);
}
static int schedule_ll_task_after(void *data, struct task *task, uint64_t start,
uint64_t period, struct task *after)
{
struct ll_schedule_data *sch = data;
return schedule_ll_task_common(sch, task, start, period, after, false);
}
int schedule_task_init_ll(struct task *task,
const struct sof_uuid_entry *uid, uint16_t type,
uint16_t priority, enum task_state (*run)(void *data),
@ -693,6 +732,8 @@ int scheduler_init_ll(struct ll_schedule_domain *domain)
static const struct scheduler_ops schedule_ll_ops = {
.schedule_task = schedule_ll_task,
.schedule_task_before = schedule_ll_task_before,
.schedule_task_after = schedule_ll_task_after,
.schedule_task_free = schedule_ll_task_free,
.schedule_task_cancel = schedule_ll_task_cancel,
.reschedule_task = reschedule_ll_task,