| /Zephyr-latest/samples/subsys/zbus/confirmed_channel/src/ |
| D | main.c | 48 zbus_chan_read(&confirmed_chan, &cm, K_MSEC(500)); in bar_sub1_task()
73 zbus_chan_read(&confirmed_chan, &cm, K_MSEC(500)); in bar_sub2_task()
99 zbus_chan_read(&confirmed_chan, &cm, K_MSEC(500)); in bar_sub3_task()
|
| /Zephyr-latest/samples/subsys/zbus/work_queue/src/ |
| D | main.c | 83 zbus_chan_read(sens->chan, &msg, K_MSEC(200)); in wq_dh_cb()
138 zbus_chan_read(chan, &msg, K_MSEC(200)); in thread_handler1_task()
157 zbus_chan_read(chan, &msg, K_MSEC(200)); in thread_handler2_task()
176 zbus_chan_read(chan, &msg, K_MSEC(200)); in thread_handler3_task()
|
| /Zephyr-latest/samples/subsys/zbus/runtime_obs_registration/src/ |
| D | consumer.c | 20 zbus_chan_read(chan, &acc, K_MSEC(500)); in consumer_subscriber_thread()
|
| /Zephyr-latest/tests/subsys/zbus/integration/src/ |
| D | main.c | 43 zbus_chan_read(&sensor_data_chan, &data, K_FOREVER); in core_thread()
69 zbus_chan_read(&net_pkt_chan, &pkt, K_FOREVER); in net_thread()
297 int err = zbus_chan_read(&busy_chan, &read, K_NO_WAIT); in ZTEST()
312 err = zbus_chan_read(&busy_chan, &read, K_MSEC(200)); in ZTEST()
321 err = zbus_chan_read(&busy_chan, &read, K_MSEC(2000)); in ZTEST()
344 err = zbus_chan_read(&start_measurement_chan, &read, K_NO_WAIT); in ZTEST()
|
| /Zephyr-latest/tests/subsys/zbus/dyn_channel/src/ |
| D | main.c | 93 zbus_chan_read(&dyn_chan, &edm, K_NO_WAIT); in ZTEST()
138 zbus_chan_read(&dyn_chan, &expected_to_be_clean, K_NO_WAIT); in ZTEST()
|
| /Zephyr-latest/tests/subsys/zbus/unittests/src/ |
| D | main.c | 147 isr_return = zbus_chan_read(&aux2_chan, &ga, K_MSEC(500)); in isr_handler()
168 isr_return = zbus_chan_read(&aux2_chan, &ga, K_NO_WAIT); in isr_handler()
216 zassert_equal(-EBUSY, zbus_chan_read(&aux2_chan, &a, K_NO_WAIT), "It must not be invalid"); in wq_dh_cb()
258 zassert_equal(-EFAULT, zbus_chan_read(NULL, &a, K_NO_WAIT), "It must be -EFAULT"); in ZTEST()
262 zassert_equal(-EFAULT, zbus_chan_read(&aux2_chan, NULL, K_NO_WAIT), "It must be -EFAULT"); in ZTEST()
284 zassert_equal(0, zbus_chan_read(&aux2_chan, &a, K_NO_WAIT), "It must be valid"); in ZTEST()
299 zassert_equal(-EBUSY, zbus_chan_read(&aux2_chan, &a, K_NO_WAIT), "It must not be valid"); in ZTEST()
580 zbus_chan_read(&hard_chan, ¤t, K_NO_WAIT); in ZTEST()
|
| /Zephyr-latest/tests/subsys/zbus/user_data/src/ |
| D | main.c | 95 zbus_chan_read(®ular_chan, &received, K_MSEC(100)); in ZTEST()
|
| /Zephyr-latest/samples/subsys/zbus/priority_boost/src/ |
| D | main.c | 40 err = zbus_chan_read(chan, &a, K_FOREVER); in s1_thread()
|
| /Zephyr-latest/samples/subsys/zbus/hello_world/src/ |
| D | main.c | 85 zbus_chan_read(&acc_data_chan, &acc, K_MSEC(500)); in subscriber_task()
|
| /Zephyr-latest/tests/subsys/zbus/hlp_priority_boost/src/ |
| D | main.c | 52 zbus_chan_read(chan, &msg, K_FOREVER); in consumer_sub_thread()
|
| /Zephyr-latest/samples/subsys/llext/edk/app/src/ |
| D | pubsub.c | 170 return zbus_chan_read(channel_subscribers[channel].chan, data, in z_impl_receive()
|
| /Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/ |
| D | main.c | 149 zbus_chan_read(chan, &acc, K_MSEC(250)); in subscriber_task()
|
| /Zephyr-latest/include/zephyr/zbus/ |
| D | zbus.h | 593 int zbus_chan_read(const struct zbus_channel *chan, void *msg, k_timeout_t timeout);
|
| /Zephyr-latest/subsys/zbus/ |
| D | zbus.c | 415 int zbus_chan_read(const struct zbus_channel *chan, void *msg, k_timeout_t timeout) in zbus_chan_read() function
|
| /Zephyr-latest/doc/services/zbus/ |
| D | index.rst | 488 zbus_chan_read(&acc_chan, &acc, K_NO_WAIT);
587 Messages are read from a channel in zbus by calling :c:func:`zbus_chan_read`. So, for example, the
594 zbus_chan_read(&acc_chan, &acc, K_MSEC(500));
600 Choose the timeout of :c:func:`zbus_chan_read` after receiving a notification from
752 // instead of zbus_chan_read(chan, &acc, K_MSEC(200))
|
| /Zephyr-latest/doc/releases/ |
| D | release-notes-3.3.rst | 2510 * :c:func:`zbus_chan_read`
|
