mpipe_app_sink.h

Go to the documentation of this file.

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

 
#ifndef ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SINK_H_
#define ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SINK_H_

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

enum {
        MPIPE_PROP_BASE_APP_SINK_CAPS = MPIPE_PROP_SINK_LAST,
        MPIPE_PROP_BASE_APP_SINK_CB,
};

typedef void (*mpipe_app_sink_cb_t)(const struct net_buf *buf, void *user_data);

struct mpipe_app_sink_cb {
        mpipe_app_sink_cb_t fn;
        void *user_data;
};

struct mpipe_app_sink {
        struct mpipe_sink sink;
        struct mpipe_structure caps;
        struct mpipe_app_sink_cb cb;
        struct k_msgq msgq;
        char msgq_buffer[CONFIG_MPIPE_BASE_APP_SINK_QUEUE_DEPTH * sizeof(void *)];
};

int mpipe_app_sink_init(struct mpipe_app_sink *app_sink, uint8_t id);

int mpipe_app_sink_pull(struct mpipe_app_sink *app_sink, struct net_buf **buf, k_timeout_t timeout);

 
#endif /* ZEPHYR_INCLUDE_MPIPE_BASE_MPIPE_APP_SINK_H_ */