mpipe_bin.h

Go to the documentation of this file.

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

 
#ifndef ZEPHYR_INCLUDE_MPIPE_MPIPE_BIN_H_
#define ZEPHYR_INCLUDE_MPIPE_MPIPE_BIN_H_

 
#include <stdint.h>
 
#include <zephyr/sys/dlist.h>
#include <zephyr/zbus/zbus.h>
 
#include <zephyr/mpipe/mpipe_element.h>
#include <zephyr/mpipe/mpipe_message.h>

struct mpipe_bin {
        struct mpipe_element element;
        int children_num;
        sys_dlist_t children;
        struct zbus_runtime_channel bus;

        /* Bus channel mutable runtime state: observer bookkeeping, lock, counters. */
        struct zbus_channel_data chan_data;
        /* Bus channel message buffer: holds the last published mpipe_message. */
        struct mpipe_message chan_msg;
};

int mpipe_bin_init(struct mpipe_bin *bin, uint8_t id);

int mpipe_bin_set_bus_validator(struct mpipe_bin *bin, zbus_validator bus_validator,
                                void *user_data);

int mpipe_bin_add(struct mpipe_bin *bin, struct mpipe_element *element, ...);

int mpipe_bin_change_state_func(struct mpipe_element *element, enum mpipe_state_change transition);

 
#endif /* ZEPHYR_INCLUDE_MPIPE_MPIPE_BIN_H_ */