mpipe_app_src.h

Go to the documentation of this file.

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

 
#ifndef ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SRC_H_
#define ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SRC_H_

 
#include <stdint.h>
 
#include <zephyr/kernel.h>
#include <zephyr/net_buf.h>
 
#include <zephyr/mpipe/mpipe_buffer.h>
#include <zephyr/mpipe/mpipe_element.h>
#include <zephyr/mpipe/mpipe_src.h>
#include <zephyr/mpipe/mpipe_structure.h>

enum {
        MPIPE_PROP_BASE_APP_SRC_CAPS = MPIPE_PROP_SRC_LAST,
};

struct mpipe_app_src {
        struct mpipe_src src;
        struct mpipe_structure caps;
        struct mpipe_buffer_pool pool;
        struct k_msgq msgq;
        char msgq_buffer[(CONFIG_MPIPE_BASE_APP_SRC_QUEUE_DEPTH + 1) * sizeof(void *)];
};

int mpipe_app_src_init(struct mpipe_app_src *app_src, uint8_t id);

int mpipe_app_src_alloc(struct mpipe_app_src *app_src, uint32_t size, k_timeout_t timeout,
                        struct net_buf **buf);

int mpipe_app_src_push_buf(struct mpipe_app_src *app_src, struct net_buf *buf, uint32_t size,
                           k_timeout_t timeout);

int mpipe_app_src_push(struct mpipe_app_src *app_src, const void *data, uint32_t size,
                       k_timeout_t timeout);

int mpipe_app_src_eos(struct mpipe_app_src *app_src, k_timeout_t timeout);

 
#endif /* ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SRC_H_ */