Home
last modified time | relevance | path

Searched refs:zbus_chan_pub (Results 1 – 25 of 26) sorted by relevance

12

/Zephyr-latest/tests/subsys/zbus/integration/src/
Dmain.c50 zbus_chan_pub(&net_pkt_chan, &pkt, K_MSEC(200)); in core_thread()
76 zbus_chan_pub(&net_log_chan, &log_msg, K_MSEC(500)); in net_thread()
128 zbus_chan_pub(&sensor_data_chan, &sd, K_MSEC(250)); in peripheral_thread()
181 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
192 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
203 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
225 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
238 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
251 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
264 zassert_equal(0, zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(200)), NULL); in ZTEST()
[all …]
/Zephyr-latest/tests/subsys/zbus/runtime_observers_registration/src/
Dmain.c76 zassert_equal(0, zbus_chan_pub(&chan1, &sd, K_MSEC(500)), NULL); in ZTEST()
83 zassert_equal(0, zbus_chan_pub(&chan1, &sd, K_MSEC(500)), NULL); in ZTEST()
92 zassert_equal(0, zbus_chan_pub(&chan1, &sd, K_MSEC(500)), NULL); in ZTEST()
98 zassert_equal(0, zbus_chan_pub(&chan2, &sd, K_MSEC(500)), NULL); in ZTEST()
106 zassert_equal(0, zbus_chan_pub(&chan2, &sd, K_MSEC(500)), NULL); in ZTEST()
125 zassert_equal(0, zbus_chan_pub(&chan2, &sd, K_MSEC(500)), NULL); in ZTEST()
130 zassert_equal(-ENOMSG, zbus_chan_pub(&chan2, &sd, K_MSEC(500)), NULL); in ZTEST()
201 zassert_equal(0, zbus_chan_pub(&chan4, &sd, K_MSEC(500)), NULL); in ZTEST()
/Zephyr-latest/samples/subsys/zbus/runtime_obs_registration/src/
Dproducer.c25 zbus_chan_pub(&state_chan, &change_state, K_MSEC(200)); in producer_thread()
35 zbus_chan_pub(&raw_data_chan, &acc, K_MSEC(200)); in producer_thread()
Dmain.c35 zbus_chan_pub(&processed_data_chan, &proc_msg, K_MSEC(200)); in filter_callback()
/Zephyr-latest/samples/subsys/zbus/hello_world/src/
Dmain.c156 zbus_chan_pub(&acc_data_chan, &acc1, K_SECONDS(1)); in main()
163 zbus_chan_pub(&acc_data_chan, &(acc1), K_SECONDS(1)); in main()
166 err = zbus_chan_pub(&simple_chan, &value, K_MSEC(200)); in main()
173 err = zbus_chan_pub(&simple_chan, &value, K_MSEC(200)); in main()
/Zephyr-latest/tests/subsys/zbus/unittests/src/
Dmain.c144 isr_return = zbus_chan_pub(&aux2_chan, &ga, K_MSEC(500)); in isr_handler()
165 isr_return = zbus_chan_pub(&aux2_chan, &ga, K_NO_WAIT); in isr_handler()
214 zassert_equal(-EBUSY, zbus_chan_pub(&aux2_chan, &a, K_NO_WAIT), "It must not be invalid"); in wq_dh_cb()
250 zassert_equal(-EFAULT, zbus_chan_pub(NULL, &a, K_NO_WAIT), "It must be -EFAULT"); in ZTEST()
254 zassert_equal(-EFAULT, zbus_chan_pub(&aux2_chan, NULL, K_NO_WAIT), "It must be -EFAULT"); in ZTEST()
280 zassert_equal(0, zbus_chan_pub(&aux2_chan, &a, K_NO_WAIT), "It must be valid"); in ZTEST()
297 zassert_equal(-EBUSY, zbus_chan_pub(&aux2_chan, &a, K_NO_WAIT), "It must not be valid"); in ZTEST()
308 int err = zbus_chan_pub(&msg_sub_fail_chan, &fail, K_MSEC(200)); in ZTEST()
315 zbus_chan_pub(&aux3_on_change_chan, &repeated, K_NO_WAIT); in ZTEST()
319 zbus_chan_pub(&aux3_on_change_chan, &repeated, K_NO_WAIT); in ZTEST()
[all …]
/Zephyr-latest/samples/subsys/zbus/work_queue/src/
Dsensors.c24 zbus_chan_pub(&sensor_data_chan, &sm, K_MSEC(250)); in peripheral_thread()
/Zephyr-latest/tests/subsys/zbus/publish_stats/src/
Dmain.c34 zassert_equal(0, zbus_chan_pub(&chan, &val, K_NO_WAIT)); in ZTEST()
41 zassert_equal(0, zbus_chan_pub(&chan, &val, K_NO_WAIT)); in ZTEST()
/Zephyr-latest/samples/subsys/zbus/remote_mock/src/
Dperipheral.c32 zbus_chan_pub(&sensor_data_chan, &sd, K_MSEC(250))); in peripheral_thread()
/Zephyr-latest/samples/subsys/zbus/uart_bridge/src/
Dcore.c31 zbus_chan_pub(&start_measurement_chan, &start, K_MSEC(500)); in core_thread()
Dperipheral.c46 zbus_chan_pub(&sensor_data_chan, &sd, K_MSEC(250)); in peripheral_thread()
/Zephyr-latest/tests/subsys/zbus/dyn_channel/src/
Dmain.c81 int err = zbus_chan_pub(&dyn_chan, &static_external_data, K_MSEC(500)); in ZTEST()
112 int err = zbus_chan_pub(&dyn_chan, &static_external_data, K_NO_WAIT); in ZTEST()
/Zephyr-latest/samples/subsys/zbus/dyn_channel/src/
Dproducer.c31 zbus_chan_pub(&pkt_chan, &dyn_alloc_msg, K_MSEC(250)); in producer_thread()
Dconsumer.c40 zbus_chan_pub(&ack, &a, K_MSEC(250)); in consumer_thread()
Dmain.c70 zbus_chan_pub(&data_ready_chan, &dr, K_NO_WAIT); in filter_cb()
/Zephyr-latest/samples/subsys/zbus/benchmark/src/
Dbenchmark.c59 zbus_chan_pub(&bm_channel, &msg, K_FOREVER); in producer_thread()
/Zephyr-latest/samples/subsys/zbus/confirmed_channel/src/
Dmain.c122 zbus_chan_pub(&confirmed_chan, cm, K_MSEC(500)); in pub_to_confirmed_channel()
/Zephyr-latest/tests/subsys/zbus/user_data/src/
Dmain.c91 zbus_chan_pub(&regular_chan, &sent, K_MSEC(100)); in ZTEST()
/Zephyr-latest/samples/subsys/zbus/priority_boost/src/
Dmain.c139 err = zbus_chan_pub(&chan_a, &a, K_FOREVER); in t1_thread()
/Zephyr-latest/tests/subsys/zbus/hlp_priority_boost/src/
Dmain.c102 zbus_chan_pub(&chan_testing_01, &msg, K_FOREVER); in publisher_thread()
/Zephyr-latest/samples/subsys/llext/edk/app/src/
Dpubsub.c132 return zbus_chan_pub(chan, data, K_NO_WAIT); in z_impl_publish()
/Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/
Dmain.c202 zbus_chan_pub(&acc_data_chan, &acc, K_NO_WAIT); in main()
/Zephyr-latest/include/zephyr/zbus/
Dzbus.h574 int zbus_chan_pub(const struct zbus_channel *chan, const void *msg, k_timeout_t timeout);
/Zephyr-latest/subsys/zbus/
Dzbus.c377 int zbus_chan_pub(const struct zbus_channel *chan, const void *msg, k_timeout_t timeout) in zbus_chan_pub() function
/Zephyr-latest/doc/services/zbus/
Dindex.rst568 Messages are published to a channel in zbus by calling :c:func:`zbus_chan_pub`. For example, the
577 zbus_chan_pub(&acc_chan, &acc1, K_SECONDS(1));

12