mpipe_queue.h

Go to the documentation of this file.

/*
 * Copyright 2026 NXP
 *
 * SPDX-License-Identifier: Apache-2.0
 */

 
#ifndef ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_QUEUE_H_
#define ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_QUEUE_H_

 
#include <zephyr/kernel.h>
#include <zephyr/sys/atomic.h>
 
#include <zephyr/mpipe/mpipe_element.h>
#include <zephyr/mpipe/mpipe_thread.h>
#include <zephyr/mpipe/mpipe_transform.h>

enum {
        MPIPE_PROP_BASE_QUEUE_SIZE = MPIPE_PROP_TRANSFORM_LAST,
        MPIPE_PROP_BASE_QUEUE_THREAD_PRIORITY,
        MPIPE_PROP_BASE_QUEUE_LEAK,
};

enum mpipe_base_queue_leak {
        MPIPE_BASE_QUEUE_LEAK_NONE = 0,
        MPIPE_BASE_QUEUE_LEAK_OLDEST,
        MPIPE_BASE_QUEUE_LEAK_NEWEST,
};

struct mpipe_queue {
        struct mpipe_transform transform;
        struct mpipe_thread thread;
        struct k_msgq msgq;
        char msgq_buffer[(CONFIG_MPIPE_BASE_QUEUE_MAX_SIZE + 2) * sizeof(void *)];
        uint8_t size;
        uint8_t leak;
        atomic_t flushing;
};

int mpipe_queue_init(struct mpipe_queue *queue, uint8_t id);

 
#endif /* ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_QUEUE_H_ */