Lines Matching refs:zbus_channel
80 struct zbus_channel { struct
164 void (*callback)(const struct zbus_channel *chan);
181 const struct zbus_channel *chan;
233 #define _ZBUS_CHAN_EXTERN(_name) extern const struct zbus_channel _name
285 _ZBUS_CPP_EXTERN const STRUCT_SECTION_ITERABLE(zbus_channel, _name) = { \
442 sizeof(struct zbus_channel *), \
443 _queue_size, sizeof(struct zbus_channel *) \
574 int zbus_chan_pub(const struct zbus_channel *chan, const void *msg, k_timeout_t timeout);
593 int zbus_chan_read(const struct zbus_channel *chan, void *msg, k_timeout_t timeout);
616 int zbus_chan_claim(const struct zbus_channel *chan, k_timeout_t timeout);
632 int zbus_chan_finish(const struct zbus_channel *chan);
652 int zbus_chan_notify(const struct zbus_channel *chan, k_timeout_t timeout);
665 static inline const char *zbus_chan_name(const struct zbus_channel *chan) in zbus_chan_name()
684 const struct zbus_channel *zbus_chan_from_id(uint32_t channel_id);
700 static inline void *zbus_chan_msg(const struct zbus_channel *chan) in zbus_chan_msg()
721 static inline const void *zbus_chan_const_msg(const struct zbus_channel *chan) in zbus_chan_const_msg()
737 static inline uint16_t zbus_chan_msg_size(const struct zbus_channel *chan) in zbus_chan_msg_size()
753 static inline void *zbus_chan_user_data(const struct zbus_channel *chan) in zbus_chan_user_data()
768 static inline void zbus_chan_set_msg_sub_pool(const struct zbus_channel *chan, in zbus_chan_set_msg_sub_pool()
792 static inline void zbus_chan_pub_stats_update(const struct zbus_channel *chan) in zbus_chan_pub_stats_update()
809 static inline k_ticks_t zbus_chan_pub_stats_last_time(const struct zbus_channel *chan) in zbus_chan_pub_stats_last_time()
825 static inline uint32_t zbus_chan_pub_stats_count(const struct zbus_channel *chan) in zbus_chan_pub_stats_count()
841 static inline uint32_t zbus_chan_pub_stats_avg_period(const struct zbus_channel *chan) in zbus_chan_pub_stats_avg_period()
855 static inline void zbus_chan_pub_stats_update(const struct zbus_channel *chan) in zbus_chan_pub_stats_update()
880 int zbus_chan_add_obs(const struct zbus_channel *chan, const struct zbus_observer *obs,
900 int zbus_chan_rm_obs(const struct zbus_channel *chan, const struct zbus_observer *obs,
964 const struct zbus_channel *chan, bool masked);
979 const struct zbus_channel *chan, bool *masked);
1045 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan,
1068 int zbus_sub_wait_msg(const struct zbus_observer *sub, const struct zbus_channel **chan, void *msg,
1086 bool zbus_iterate_over_channels(bool (*iterator_func)(const struct zbus_channel *chan));
1102 bool (*iterator_func)(const struct zbus_channel *chan, void *user_data), void *user_data);