channels.h

Go to the documentation of this file.

 
#ifndef INFUSE_SDK_INCLUDE_INFUSE_ZBUS_CHANNELS_H_
#define INFUSE_SDK_INCLUDE_INFUSE_ZBUS_CHANNELS_H_
 
#include <zephyr/zbus/zbus.h>
 
#include <infuse/zbus/types.h>
 
#ifdef __cplusplus
extern "C" {
#endif


#define INFUSE_ZBUS_CHAN_DEFINE(channel)                                                           \
        ZBUS_CHAN_DEFINE_WITH_ID(INFUSE_ZBUS_NAME(channel), channel, INFUSE_ZBUS_TYPE(channel),    \
                                 NULL, NULL, ZBUS_OBSERVERS_EMPTY, ZBUS_MSG_INIT(0));

#define _INFUSE_ZBUS_CHAN_EXTERN(channel) _ZBUS_CHAN_EXTERN(INFUSE_ZBUS_NAME(channel))

#define INFUSE_ZBUS_CHAN_DECLARE(...) FOR_EACH(_INFUSE_ZBUS_CHAN_EXTERN, (;), __VA_ARGS__)

#define INFUSE_ZBUS_CHAN_GET(channel) (&INFUSE_ZBUS_NAME(channel))

static inline uint64_t infuse_zbus_channel_data_age(const struct zbus_channel *chan)
{
#ifdef CONFIG_ZBUS_CHANNEL_PUBLISH_STATS
        if (zbus_chan_pub_stats_count(chan) == 0) {
                return UINT64_MAX;
        }
        return k_ticks_to_ms_floor64(k_uptime_ticks() - zbus_chan_pub_stats_last_time(chan));
#else
        return UINT64_MAX;
#endif /* CONFIG_ZBUS_CHANNEL_PUBLISH_STATS */
}

 
#ifdef __cplusplus
}
#endif
 
#endif /* INFUSE_SDK_INCLUDE_INFUSE_ZBUS_CHANNELS_H_ */