Quelle  iosm_ipc_task_queue.h   Sprache: C

/* SPDX-License-Identifier: GPL-2.0-only
 *
 * Copyright (C) 2020-21 Intel Corporation.
 */

#ifndef IOSM_IPC_TASK_QUEUE_H
#define IOSM_IPC_TASK_QUEUE_H

/* Number of available element for the input message queue of the IPC
 * ipc_task
 */
#define IPC_THREAD_QUEUE_SIZE 256

/**
 * struct ipc_task_queue_args - Struct for Task queue elements
 * @ipc_imem:   Pointer to struct iosm_imem
 * @msg:        Message argument for tasklet function. (optional, can be NULL)
 * @completion: OS object used to wait for the tasklet function to finish for
 *              synchronous calls
 * @func:       Function to be called in tasklet (tl) context
 * @arg:        Generic integer argument for tasklet function (optional)
 * @size:       Message size argument for tasklet function (optional)
 * @response:   Return code of tasklet function for synchronous calls
 * @is_copy:    Is true if msg contains a pointer to a copy of the original msg
 *              for async. calls that needs to be freed once the tasklet returns
 */
struct ipc_task_queue_args {
 struct iosm_imem *ipc_imem;
 void *msg;
 struct completion *completion;
 int (*func)(struct iosm_imem *ipc_imem, int arg, void *msg,
      size_t size);
 int arg;
 size_t size;
 int response;
 u8 is_copy:1;
};

/**
 * struct ipc_task_queue - Struct for Task queue
 * @q_lock:     Protect the message queue of the ipc ipc_task
 * @args:       Message queue of the IPC ipc_task
 * @q_rpos:     First queue element to process.
 * @q_wpos:     First free element of the input queue.
 */
struct ipc_task_queue {
 spinlock_t q_lock; /* for atomic operation on queue */
 struct ipc_task_queue_args args[IPC_THREAD_QUEUE_SIZE];
 unsigned int q_rpos;
 unsigned int q_wpos;
};

/**
 * struct ipc_task - Struct for Task
 * @dev:  Pointer to device structure
 * @ipc_tasklet: Tasklet for serialized work offload
 *  from interrupts and OS callbacks
 * @ipc_queue:  Task for entry into ipc task queue
 */
struct ipc_task {
 struct device *dev;
 struct tasklet_struct *ipc_tasklet;
 struct ipc_task_queue ipc_queue;
};

/**
 * ipc_task_init - Allocate a tasklet
 * @ipc_task: Pointer to ipc_task structure
 * Returns: 0 on success and failure value on error.
 */
int ipc_task_init(struct ipc_task *ipc_task);

/**
 * ipc_task_deinit - Free a tasklet, invalidating its pointer.
 * @ipc_task: Pointer to ipc_task structure
 */
void ipc_task_deinit(struct ipc_task *ipc_task);

/**
 * ipc_task_queue_send_task - Synchronously/Asynchronously call a function in
 *       tasklet context.
 * @imem: Pointer to iosm_imem struct
 * @func: Function to be called in tasklet context
 * @arg: Integer argument for func
 * @msg: Message pointer argument for func
 * @size: Size argument for func
 * @wait: if true wait for result
 *
 * Returns: Result value returned by func or failure value if func could not
 *     be called.
 */
int ipc_task_queue_send_task(struct iosm_imem *imem,
        int (*func)(struct iosm_imem *ipc_imem, int arg,
      void *msg, size_t size),
        int arg, void *msg, size_t size, bool wait);

#endif