| /Zephyr-Core-3.7.0/include/zephyr/zbus/ |
| D | zbus.h | 73 struct zbus_channel { struct
153 void (*const callback)(const struct zbus_channel *chan);
170 const struct zbus_channel *const chan;
222 #define _ZBUS_CHAN_EXTERN(_name) extern const struct zbus_channel _name
354 _ZBUS_CPP_EXTERN const STRUCT_SECTION_ITERABLE(zbus_channel, _name) = { \
399 sizeof(const struct zbus_channel *), \
400 _queue_size, sizeof(const struct zbus_channel *) \
529 int zbus_chan_pub(const struct zbus_channel *chan, const void *msg, k_timeout_t timeout);
548 int zbus_chan_read(const struct zbus_channel *chan, void *msg, k_timeout_t timeout);
571 int zbus_chan_claim(const struct zbus_channel *chan, k_timeout_t timeout);
[all …]
|
| /Zephyr-Core-3.7.0/subsys/zbus/ |
| D | zbus_iterable_sections.c | 10 bool zbus_iterate_over_channels(bool (*iterator_func)(const struct zbus_channel *chan)) in zbus_iterate_over_channels()
12 STRUCT_SECTION_FOREACH(zbus_channel, chan) { in zbus_iterate_over_channels()
21 bool (*iterator_func)(const struct zbus_channel *chan, void *user_data), void *user_data) in zbus_iterate_over_channels_with_user_data()
23 STRUCT_SECTION_FOREACH(zbus_channel, chan) { in zbus_iterate_over_channels_with_user_data()
|
| D | zbus.c | 27 sizeof(struct zbus_channel *), NULL);
42 sizeof(struct zbus_channel *), NULL);
60 const struct zbus_channel *curr = NULL; in _zbus_init()
61 const struct zbus_channel *prev = NULL; in _zbus_init()
84 static inline int _zbus_notify_observer(const struct zbus_channel *chan, in _zbus_notify_observer()
116 static inline int _zbus_vded_exec(const struct zbus_channel *chan, k_timepoint_t end_time) in _zbus_vded_exec()
136 memcpy(net_buf_user_data(buf), &chan, sizeof(struct zbus_channel *)); in _zbus_vded_exec()
201 static inline void chan_update_hop(const struct zbus_channel *chan) in chan_update_hop()
282 static inline int chan_lock(const struct zbus_channel *chan, k_timeout_t timeout, int *prio) in chan_lock()
322 static inline void chan_unlock(const struct zbus_channel *chan, int prio) in chan_unlock()
[all …]
|
| D | zbus_runtime_observers.c | 11 int zbus_chan_add_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, in zbus_chan_add_obs()
68 int zbus_chan_rm_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, in zbus_chan_rm_obs()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/work_queue/src/ |
| D | main.c | 38 static void fh1_cb(const struct zbus_channel *chan) in fh1_cb()
48 static void fh2_cb(const struct zbus_channel *chan) in fh2_cb()
58 static void fh3_cb(const struct zbus_channel *chan) in fh3_cb()
70 const struct zbus_channel *chan;
90 static void dh1_cb(const struct zbus_channel *chan) in dh1_cb()
99 static void dh2_cb(const struct zbus_channel *chan) in dh2_cb()
108 static void dh3_cb(const struct zbus_channel *chan) in dh3_cb()
133 const struct zbus_channel *chan; in thread_handler1_task()
152 const struct zbus_channel *chan; in thread_handler2_task()
171 const struct zbus_channel *chan; in thread_handler3_task()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/priority_boost/src/ |
| D | main.c | 25 const struct zbus_channel *chan; in s1_thread()
57 const struct zbus_channel *chan; in ms1_thread()
84 const struct zbus_channel *chan; in ms2_thread()
103 static void l1_callback(const struct zbus_channel *chan) in l1_callback()
110 static void l2_callback(const struct zbus_channel *chan) in l2_callback()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/confirmed_channel/src/ |
| D | main.c | 26 static void listener_callback_example(const struct zbus_channel *chan) in listener_callback_example()
39 const struct zbus_channel *chan; in bar_sub1_task()
64 const struct zbus_channel *chan; in bar_sub2_task()
90 const struct zbus_channel *chan; in bar_sub3_task()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/remote_mock/src/ |
| D | mock_proxy.c | 41 static uint8_t encoder(const struct zbus_channel *chan) in encoder()
51 static const struct zbus_channel *decoder(uint8_t chan_idx) in decoder()
61 static void proxy_callback(const struct zbus_channel *chan) in proxy_callback()
105 const struct zbus_channel *chan = decoder(net_buf_simple_pull_u8(rx_buf)); in decode_sentence()
|
| D | peripheral.c | 25 const struct zbus_channel *chan; in peripheral_thread()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/benchmark/src/ |
| D | lis.c | 16 static void s_cb(const struct zbus_channel *chan);
34 static void s_cb(const struct zbus_channel *chan) in s_cb()
|
| D | msg_sub.c | 37 const struct zbus_channel *chan; in msg_sub_thread()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/msg_subscriber/src/ |
| D | main.c | 54 static void listener_callback_example(const struct zbus_channel *chan) in listener_callback_example()
85 const struct zbus_channel *chan; in msg_subscriber_task()
137 const struct zbus_channel *chan; in subscriber_task()
177 (sizeof(struct zbus_channel *)), NULL);
181 sizeof(struct zbus_channel *), NULL);
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/runtime_obs_registration/src/ |
| D | main.c | 20 static void filter_callback(const struct zbus_channel *chan) in filter_callback()
46 const struct zbus_channel *chan; in main()
|
| D | consumer.c | 15 const struct zbus_channel *chan; in consumer_subscriber_thread()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/hello_world/src/ |
| D | main.c | 66 static void listener_callback_example(const struct zbus_channel *chan) in listener_callback_example()
79 const struct zbus_channel *chan; in subscriber_task()
95 static bool print_channel_data_iterator(const struct zbus_channel *chan, void *user_data) in print_channel_data_iterator()
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/unittests/src/ |
| D | main.c | 105 static void callback(const struct zbus_channel *chan) in callback()
190 static void busy_callback(const struct zbus_channel *chan) in busy_callback()
355 const struct zbus_channel *chan; in ZTEST()
368 static bool always_true_chan_iterator(const struct zbus_channel *chan) in always_true_chan_iterator()
378 static bool always_false_chan_iterator(const struct zbus_channel *chan) in always_false_chan_iterator()
388 static bool check_chan_iterator(const struct zbus_channel *chan, void *user_data) in check_chan_iterator()
484 static bool count_false_chan_iterator(const struct zbus_channel *chan, void *user_data) in count_false_chan_iterator()
533 STRUCT_SECTION_COUNT(zbus_channel, &chan_count); in ZTEST()
733 const struct zbus_channel *chan; in isr_sub_wait()
745 const struct zbus_channel *chan; in ZTEST()
[all …]
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/hlp_priority_boost/src/ |
| D | main.c | 45 const struct zbus_channel *chan; in consumer_sub_thread()
72 const struct zbus_channel *chan; in consumer_msg_sub_thread()
118 static void listener_callback(const struct zbus_channel *chan) in listener_callback()
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/user_data/src/ |
| D | main.c | 52 static void urgent_callback(const struct zbus_channel *chan) in urgent_callback()
67 struct zbus_channel *chan = NULL; in foo_subscriber_thread()
|
| /Zephyr-Core-3.7.0/samples/subsys/llext/edk/app/src/ |
| D | pubsub.c | 39 const struct zbus_channel *chan;
99 const struct zbus_channel *chan; in subscriber_thread_fn()
126 const struct zbus_channel *chan = channel_subscribers[channel].chan; in z_impl_publish()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/uart_bridge/src/ |
| D | peripheral.c | 37 const struct zbus_channel *chan; in peripheral_thread()
|
| /Zephyr-Core-3.7.0/samples/subsys/zbus/dyn_channel/src/ |
| D | producer.c | 17 const struct zbus_channel *chan; in producer_thread()
|
| D | consumer.c | 18 const struct zbus_channel *chan; in consumer_thread()
|
| D | main.c | 51 static void filter_cb(const struct zbus_channel *chan) in filter_cb()
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/runtime_observers_registration/src/ |
| D | main.c | 48 static void callback1(const struct zbus_channel *chan) in callback1()
56 static void callback2(const struct zbus_channel *chan) in callback2()
173 static void _CONCAT(prio_cb, _idx)(const struct zbus_channel *chan) \
|
| /Zephyr-Core-3.7.0/tests/subsys/zbus/integration/src/ |
| D | main.c | 20 static void urgent_callback(const struct zbus_channel *chan) in urgent_callback()
35 const struct zbus_channel *chan = NULL; in core_thread()
64 const struct zbus_channel *chan; in net_thread()
89 const struct zbus_channel *chan; in net_log_thread()
114 const struct zbus_channel *chan; in peripheral_thread()
|
