Searched refs:zbus_sub_wait_msg (Results 1 – 9 of 9) sorted by relevance
| /Zephyr-latest/tests/subsys/zbus/unittests/src/ |
| D | main.c | 363 zassert_equal(0, zbus_sub_wait_msg(&foo_msg_sub, &chan, &msg, K_MSEC(500)), NULL); in ZTEST()
763 zassert_equal(-EFAULT, zbus_sub_wait_msg(NULL, NULL, NULL, K_NO_WAIT), NULL); in isr_sub_wait_msg()
764 zassert_equal(-EFAULT, zbus_sub_wait_msg(&foo_sub, NULL, NULL, K_NO_WAIT), NULL); in isr_sub_wait_msg()
768 zassert_equal(-EFAULT, zbus_sub_wait_msg(&foo_msg_sub, &chan, &a, K_NO_WAIT), NULL); in isr_sub_wait_msg()
775 zassert_equal(-EFAULT, zbus_sub_wait_msg(NULL, NULL, NULL, K_NO_WAIT), NULL); in ZTEST()
776 zassert_equal(-EFAULT, zbus_sub_wait_msg(&foo_sub, NULL, NULL, K_NO_WAIT), NULL); in ZTEST()
777 zassert_equal(-EFAULT, zbus_sub_wait_msg(&foo_msg_sub, NULL, NULL, K_NO_WAIT), NULL); in ZTEST()
778 zassert_equal(-EFAULT, zbus_sub_wait_msg(&foo_msg_sub, &chan, NULL, K_NO_WAIT), NULL); in ZTEST()
781 zassert_equal(-ENOMSG, zbus_sub_wait_msg(&foo_msg_sub, &chan, &a, K_NO_WAIT), NULL); in ZTEST()
782 zassert_equal(-ENOMSG, zbus_sub_wait_msg(&foo_msg_sub, &chan, &a, K_MSEC(200)), NULL); in ZTEST()
|
| /Zephyr-latest/samples/subsys/zbus/priority_boost/src/ |
| D | main.c | 63 err = zbus_sub_wait_msg(&ms1, &chan, &a, K_FOREVER); in ms1_thread()
90 err = zbus_sub_wait_msg(&ms2, &chan, &a, K_FOREVER); in ms2_thread()
|
| /Zephyr-latest/samples/subsys/zbus/benchmark/src/ |
| D | msg_sub.c | 42 if (zbus_sub_wait_msg(msub, &chan, &msg_received, K_FOREVER) == 0) { in msg_sub_thread()
|
| /Zephyr-latest/tests/subsys/zbus/hlp_priority_boost/src/ |
| D | main.c | 76 if (zbus_sub_wait_msg(msub, &chan, &msg, K_FOREVER) != 0) { in consumer_msg_sub_thread()
|
| /Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/ |
| D | main.c | 91 while (!zbus_sub_wait_msg(subscriber, &chan, &acc, K_FOREVER)) { in msg_subscriber_task()
|
| /Zephyr-latest/tests/subsys/zbus/integration/src/ |
| D | main.c | 93 if (!zbus_sub_wait_msg(&net_log_sub, &chan, &log_msg, K_FOREVER)) { in net_log_thread()
|
| /Zephyr-latest/include/zephyr/zbus/ |
| D | zbus.h | 1068 int zbus_sub_wait_msg(const struct zbus_observer *sub, const struct zbus_channel **chan, void *msg,
|
| /Zephyr-latest/subsys/zbus/ |
| D | zbus.c | 510 int zbus_sub_wait_msg(const struct zbus_observer *sub, const struct zbus_channel **chan, void *msg, in zbus_sub_wait_msg() function
|
| /Zephyr-latest/doc/services/zbus/ |
| D | index.rst | 505 while (!zbus_sub_wait_msg(&my_msg_subscriber, &chan, &acc, K_FOREVER)) {
|
