Home
last modified time | relevance | path

Searched refs:zbus_sub_wait (Results 1 – 21 of 21) sorted by relevance

/Zephyr-latest/samples/subsys/zbus/runtime_obs_registration/src/
Dmain.c52 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()
Dconsumer.c17 while (!zbus_sub_wait(&consumer_sub, &chan, K_FOREVER)) { in consumer_subscriber_thread()
/Zephyr-latest/samples/subsys/zbus/confirmed_channel/src/
Dmain.c41 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/
Dmain.c135 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/
Dperipheral.c28 while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) { in peripheral_thread()
/Zephyr-latest/tests/subsys/zbus/unittests/src/
Dmain.c736 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/
Dperipheral.c40 while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) { in peripheral_thread()
Dbridge.c36 if (!zbus_sub_wait(&bridge_sub, &chan, K_FOREVER)) { in bridge_tx_thread()
/Zephyr-latest/samples/subsys/zbus/dyn_channel/src/
Dproducer.c34 if (zbus_sub_wait(&producer_sub, &chan, K_FOREVER)) { in producer_thread()
Dconsumer.c20 while (!zbus_sub_wait(&consumer_sub, &chan, K_FOREVER)) { in consumer_thread()
/Zephyr-latest/samples/subsys/zbus/benchmark/src/
Dsub.c41 if (zbus_sub_wait(sub, &chan, K_FOREVER) == 0) { in sub_thread()
/Zephyr-latest/tests/subsys/zbus/integration/src/
Dmain.c38 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/
Dmain.c30 err = zbus_sub_wait(&s1, &chan, K_FOREVER); in s1_thread()
/Zephyr-latest/samples/subsys/zbus/hello_world/src/
Dmain.c81 while (!zbus_sub_wait(&bar_sub, &chan, K_FOREVER)) { in subscriber_task()
/Zephyr-latest/tests/subsys/zbus/hlp_priority_boost/src/
Dmain.c49 if (zbus_sub_wait(sub, &chan, K_FOREVER) != 0) { in consumer_sub_thread()
/Zephyr-latest/samples/subsys/llext/edk/app/src/
Dpubsub.c103 while (zbus_sub_wait(&default_sub, &chan, K_FOREVER) == 0) { in subscriber_thread_fn()
/Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/
Dmain.c143 while (!zbus_sub_wait(subscriber, &chan, K_FOREVER)) { in subscriber_task()
/Zephyr-latest/include/zephyr/zbus/
Dzbus.h1045 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan,
/Zephyr-latest/subsys/zbus/
Dzbus.c488 int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan, in zbus_sub_wait() function
/Zephyr-latest/doc/services/zbus/
Dindex.rst347 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/
Drelease-notes-3.3.rst2524 * :c:func:`zbus_sub_wait`