/Zephyr-latest/samples/subsys/zbus/runtime_obs_registration/src/ |
D | main.c | 52 zbus_sub_wait(&state_change_sub, &chan, K_FOREVER); in main() 60 zbus_sub_wait(&state_change_sub, &chan, K_FOREVER); in main() 65 zbus_sub_wait(&state_change_sub, &chan, K_FOREVER); in main()
|
D | consumer.c | 17 while (!zbus_sub_wait(&consumer_sub, &chan, K_FOREVER)) { in consumer_subscriber_thread()
|
/Zephyr-latest/samples/subsys/zbus/confirmed_channel/src/ |
D | main.c | 41 while (!zbus_sub_wait(&bar_sub1, &chan, K_FOREVER)) { in bar_sub1_task() 66 while (!zbus_sub_wait(&bar_sub2, &chan, K_FOREVER)) { in bar_sub2_task() 92 while (!zbus_sub_wait(&bar_sub3, &chan, K_FOREVER)) { in bar_sub3_task()
|
/Zephyr-latest/samples/subsys/zbus/work_queue/src/ |
D | main.c | 135 while (!zbus_sub_wait(&thread_handler1_sub, &chan, K_FOREVER)) { in thread_handler1_task() 154 while (!zbus_sub_wait(&thread_handler2_sub, &chan, K_FOREVER)) { in thread_handler2_task() 173 while (!zbus_sub_wait(&thread_handler3_sub, &chan, K_FOREVER)) { in thread_handler3_task()
|
/Zephyr-latest/samples/subsys/zbus/remote_mock/src/ |
D | peripheral.c | 28 while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) { in peripheral_thread()
|
/Zephyr-latest/tests/subsys/zbus/unittests/src/ |
D | main.c | 736 zassert_equal(-EFAULT, zbus_sub_wait(NULL, NULL, K_NO_WAIT), NULL); in isr_sub_wait() 737 zassert_equal(-EFAULT, zbus_sub_wait(&foo_sub, NULL, K_NO_WAIT), NULL); in isr_sub_wait() 738 zassert_equal(-EFAULT, zbus_sub_wait(&foo_sub, &chan, K_NO_WAIT), NULL); in isr_sub_wait() 739 zassert_equal(-EFAULT, zbus_sub_wait(&invalid_sub, &chan, K_NO_WAIT), NULL); in isr_sub_wait() 747 zassert_equal(-EFAULT, zbus_sub_wait(NULL, NULL, K_NO_WAIT), NULL); in ZTEST() 748 zassert_equal(-EFAULT, zbus_sub_wait(&foo_sub, NULL, K_NO_WAIT), NULL); in ZTEST() 749 zassert_equal(-EFAULT, zbus_sub_wait(&foo_msg_sub, NULL, K_NO_WAIT), NULL); in ZTEST() 752 zassert_equal(-ENOMSG, zbus_sub_wait(&foo_sub, &chan, K_NO_WAIT), NULL); in ZTEST() 753 zassert_equal(-EAGAIN, zbus_sub_wait(&foo_sub, &chan, K_MSEC(200)), NULL); in ZTEST() 765 zassert_equal(-EFAULT, zbus_sub_wait(&foo_msg_sub, NULL, K_NO_WAIT), NULL); in isr_sub_wait_msg()
|
/Zephyr-latest/samples/subsys/zbus/uart_bridge/src/ |
D | peripheral.c | 40 while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) { in peripheral_thread()
|
D | bridge.c | 36 if (!zbus_sub_wait(&bridge_sub, &chan, K_FOREVER)) { in bridge_tx_thread()
|
/Zephyr-latest/samples/subsys/zbus/dyn_channel/src/ |
D | producer.c | 34 if (zbus_sub_wait(&producer_sub, &chan, K_FOREVER)) { in producer_thread()
|
D | consumer.c | 20 while (!zbus_sub_wait(&consumer_sub, &chan, K_FOREVER)) { in consumer_thread()
|
/Zephyr-latest/samples/subsys/zbus/benchmark/src/ |
D | sub.c | 41 if (zbus_sub_wait(sub, &chan, K_FOREVER) == 0) { in sub_thread()
|
/Zephyr-latest/tests/subsys/zbus/integration/src/ |
D | main.c | 38 if (!zbus_sub_wait(&core_sub, &chan, K_FOREVER)) { in core_thread() 67 if (!zbus_sub_wait(&net_sub, &chan, K_FOREVER)) { in net_thread() 116 while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) { in peripheral_thread()
|
/Zephyr-latest/samples/subsys/zbus/priority_boost/src/ |
D | main.c | 30 err = zbus_sub_wait(&s1, &chan, K_FOREVER); in s1_thread()
|
/Zephyr-latest/samples/subsys/zbus/hello_world/src/ |
D | main.c | 81 while (!zbus_sub_wait(&bar_sub, &chan, K_FOREVER)) { in subscriber_task()
|
/Zephyr-latest/tests/subsys/zbus/hlp_priority_boost/src/ |
D | main.c | 49 if (zbus_sub_wait(sub, &chan, K_FOREVER) != 0) { in consumer_sub_thread()
|
/Zephyr-latest/samples/subsys/llext/edk/app/src/ |
D | pubsub.c | 103 while (zbus_sub_wait(&default_sub, &chan, K_FOREVER) == 0) { in subscriber_thread_fn()
|
/Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/ |
D | main.c | 143 while (!zbus_sub_wait(subscriber, &chan, K_FOREVER)) { in subscriber_task()
|
/Zephyr-latest/include/zephyr/zbus/ |
D | zbus.h | 1045 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan,
|
/Zephyr-latest/subsys/zbus/ |
D | zbus.c | 488 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan, in zbus_sub_wait() function
|
/Zephyr-latest/doc/services/zbus/ |
D | index.rst | 347 zbus_sub_wait(&s1, &chan, K_FOREVER); 483 while (!zbus_sub_wait(&my_subscriber, &chan, K_FOREVER)) { 601 :c:func:`zbus_sub_wait` carefully because the channel will always be unavailable during the VDED
|
/Zephyr-latest/doc/releases/ |
D | release-notes-3.3.rst | 2524 * :c:func:`zbus_sub_wait`
|