dp_schedule.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause */
/*
 * Copyright(c) 2023 Intel Corporation. All rights reserved.
 *
 * Author: Marcin Szkudlinski
 */
 
#ifndef __SOF_SCHEDULE_DP_SCHEDULE_H__
#define __SOF_SCHEDULE_DP_SCHEDULE_H__
 
#include <rtos/task.h>
#include <sof/trace/trace.h>
#include <user/trace.h>
#include <stdint.h>
#include <ipc4/base_fw.h>
#include <ipc4/module.h>
#include <ipc4/pipeline.h>
 
struct processing_module;


int scheduler_dp_init(void);

int scheduler_dp_task_init(struct task **task,
               const struct sof_uuid_entry *uid,
               const struct task_ops *ops,
               struct processing_module *mod,
               uint16_t core,
               size_t stack_size,
               uint32_t options);
void scheduler_dp_ll_tick(void);

void scheduler_get_task_info_dp(struct scheduler_props *scheduler_props,
                uint32_t *data_off_size);
 
enum {
    DP_TASK_EVENT_PROCESS   = BIT(0),   /* Need to process data */
    DP_TASK_EVENT_CANCEL    = BIT(1),   /* Thread cancellation */
    DP_TASK_EVENT_IPC   = BIT(2),   /* IPC message */
    DP_TASK_EVENT_IPC_DONE  = BIT(3),   /* IPC processing has completed. */
};
 
struct bind_info;
struct sof_source;
struct sof_sink;
/*
 * Keeps the scheduler_dp_thread_ipc() flow simple - just one call that does all
 * the IPC-message specific parameter packing internally. This is slightly
 * suboptimal because IPC parameters first have to be collected in this
 * structure and then packed in DP-accessible memory inside
 * scheduler_dp_thread_ipc(). This could be split into two levels, by adding
 * IPC-specific functions like ipc_flatten_pipeline_state() and similar, but
 * that would add multiple functions to the API.
 */
union scheduler_dp_thread_ipc_param {
    const struct bind_info *bind_data;
    struct {
        unsigned int trigger_cmd;
        enum ipc4_pipeline_state state;
        int n_sources;
        struct sof_source **sources;
        int n_sinks;
        struct sof_sink **sinks;
    } pipeline_state;
};
 
#if CONFIG_ZEPHYR_DP_SCHEDULER
int scheduler_dp_thread_ipc(struct processing_module *pmod, unsigned int cmd,
                const union scheduler_dp_thread_ipc_param *param);
#else
static inline int scheduler_dp_thread_ipc(struct processing_module *pmod,
                      unsigned int cmd,
                      const union scheduler_dp_thread_ipc_param *param)
{
    return 0;
}
#endif
 
#endif /* __SOF_SCHEDULE_DP_SCHEDULE_H__ */