| /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`
|
