Home
last modified time | relevance | path

Searched refs:subscriber (Results 1 – 13 of 13) sorted by relevance

/Zephyr-latest/samples/subsys/zbus/msg_subscriber/
DREADME.rst1 .. zephyr:code-sample:: zbus-msg-subscriber
2 :name: Message subscriber
9 This sample illustrates how to use a message subscriber in different ways with other types of
36 I: From msg subscriber bar_msg_sub1 -> Acc x=1, y=10, z=100
37 I: From msg subscriber bar_msg_sub2 -> Acc x=1, y=10, z=100
38 I: From msg subscriber bar_msg_sub3 -> Acc x=1, y=10, z=100
39 I: From msg subscriber bar_msg_sub4 -> Acc x=1, y=10, z=100
40 I: From msg subscriber bar_msg_sub5 -> Acc x=1, y=10, z=100
41 I: From msg subscriber bar_msg_sub6 -> Acc x=1, y=10, z=100
42 I: From msg subscriber bar_msg_sub7 -> Acc x=1, y=10, z=100
[all …]
/Zephyr-latest/samples/subsys/zbus/confirmed_channel/
DREADME.rst30 I: From bar_sub2 subscriber -> Confirmed message payload = 0
31 I: From bar_sub1 subscriber -> Confirmed message payload = 0
32 I: From bar_sub3 subscriber -> Confirmed message payload = 0
34 I: From bar_sub2 subscriber -> Confirmed message payload = 1
35 I: From bar_sub1 subscriber -> Confirmed message payload = 1
36 I: From bar_sub3 subscriber -> Confirmed message payload = 1
38 I: From bar_sub2 subscriber -> Confirmed message payload = 2
39 I: From bar_sub1 subscriber -> Confirmed message payload = 2
40 I: From bar_sub3 subscriber -> Confirmed message payload = 2
42 I: From bar_sub2 subscriber -> Confirmed message payload = 3
[all …]
/Zephyr-latest/samples/subsys/zbus/msg_subscriber/src/
Dmain.c89 const struct zbus_observer *subscriber = sub; in msg_subscriber_task() local
91 while (!zbus_sub_wait_msg(subscriber, &chan, &acc, K_FOREVER)) { in msg_subscriber_task()
97 LOG_INF("From msg subscriber %s -> Acc x=%d, y=%d, z=%d", zbus_obs_name(subscriber), in msg_subscriber_task()
141 const struct zbus_observer *subscriber = sub; in subscriber_task() local
143 while (!zbus_sub_wait(subscriber, &chan, K_FOREVER)) { in subscriber_task()
151 LOG_INF("From subscriber %s -> Acc x=%d, y=%d, z=%d", zbus_obs_name(subscriber), in subscriber_task()
/Zephyr-latest/samples/subsys/zbus/hello_world/
DREADME.rst44 D: From subscriber -> Acc x=1, y=1, z=1
48 D: From subscriber -> Acc x=2, y=2, z=2
/Zephyr-latest/doc/services/zbus/
Dindex.rst105 message subscriber, processes the sensor data, and stores it in an internal sample buffer. It
108 thread receives that because it is a ``Payload`` channel message subscriber and sends the payload to
328 subscriber is attached to a thread, it assumes its priority, and the priority boost algorithm will
391 message reading depends on the subscriber's implementation. It is possible to increase the delivery
408 at the :zephyr:code-sample:`zbus-msg-subscriber` to see the isolation in action.
412 if the channel is published twice before the subscriber reads it. The second publication
413 overwrites the value from the first. Thus, the subscriber will receive two notifications, but
439 observer can be a subscriber (asynchronous), a message subscriber (asynchronous), or a listener
489 LOG_DBG("From subscriber -> Acc x=%d, y=%d, z=%d", acc.x, acc.y, acc.z);
507 … LOG_INF("From msg subscriber -> Acc x=%d, y=%d, z=%d", acc.x, acc.y, acc.z);
[all …]
/Zephyr-latest/samples/subsys/zbus/work_queue/
DREADME.rst9 …, pushing that to the system work queue. Last, it can wait and execute that in a subscriber thread.
/Zephyr-latest/samples/subsys/llext/edk/
DREADME.rst16 The application is composed of a subscriber thread, which listens for events
/Zephyr-latest/samples/net/mqtt_sn_publisher/
DREADME.rst37 - Mosquitto subscriber
/Zephyr-latest/samples/net/mqtt_publisher/
DREADME.rst30 - Mosquitto subscriber
296 This is the information that the subscriber will receive:
/Zephyr-latest/doc/releases/
Drelease-notes-1.5.rst115 - Added MQTT publisher and subscriber samples.
Drelease-notes-3.5.rst2331 * Created the zbus message subscriber sample to demonstrate how to use message subscribers.
Drelease-notes-3.7.rst1876 during the message subscriber delivery notification.
Drelease-notes-2.4.rst1056 * :github:`28012` - tests/net/lib/mqtt_subscriber/net.mqtt.subscriber fails to build on cc3220sf_la…