Home
last modified time | relevance | path

Searched refs:observers (Results 1 – 18 of 18) sorted by relevance

/Zephyr-latest/subsys/zbus/
Dzbus_runtime_observers.c41 SYS_SLIST_FOR_EACH_CONTAINER_SAFE(&chan->data->observers, obs_nd, tmp, node) { in zbus_chan_add_obs()
61 sys_slist_append(&chan->data->observers, &new_obs_nd->node); in zbus_chan_add_obs()
84 SYS_SLIST_FOR_EACH_CONTAINER_SAFE(&chan->data->observers, obs_nd, tmp, node) { in zbus_chan_rm_obs()
86 sys_slist_remove(&chan->data->observers, &prev_obs_nd->node, &obs_nd->node); in zbus_chan_rm_obs()
DKconfig64 bool "Runtime observers support."
70 ZBus implements the Highest Locker Protocol that relies on the observers’ thread priority
Dzbus.c220 SYS_SLIST_FOR_EACH_CONTAINER_SAFE(&chan->data->observers, obs_nd, tmp, node) { in _zbus_vded_exec()
/Zephyr-latest/doc/services/zbus/
Dindex.rst21 Threads can send messages to one or more observers using zbus. It makes the many-to-many
28 published channel's observers. Based on the observer's type, it can access the message directly,
46 …notifications/messages to the observers. The VDED logic runs inside the publishing action in the s…
48 channel, it also propagates the notifications to the observers;
62 Another essential aspect of zbus is the observers. There are three types of observers:
65 :alt: ZBus observers type
68 ZBus observers.
79 Channel observation structures define the relationship between a channel and its observers. For
81 :c:macro:`ZBUS_CHAN_DEFINE` or :c:macro:`ZBUS_CHAN_ADD_OBS`. There are also runtime observers,
83 or observations individually. The event dispatcher will ignore disabled observers and observations.
[all …]
/Zephyr-latest/include/zephyr/net/
Dcoap.h290 sys_slist_t observers; member
1038 struct coap_observer *observers, size_t len,
1056 struct coap_observer *observers, size_t len,
1074 struct coap_observer *observers, size_t len,
1087 struct coap_observer *observers, size_t len);
Dcoap_service.h47 struct coap_observer observers[CONFIG_COAP_SERVICE_OBSERVERS]; member
/Zephyr-latest/include/zephyr/zbus/
Dzbus.h57 sys_slist_t observers; member
263 #define _ZBUS_RUNTIME_OBSERVERS(_name) .observers = &(_CONCAT(_observers_, _name)),
281 (.observers = SYS_SLIST_STATIC_INIT( \
282 &_CONCAT(_zbus_chan_data_, _name).observers),)) \
/Zephyr-latest/subsys/net/lib/coap/
Dcoap.c1662 struct coap_observer *observers, size_t len) in coap_observer_next_unused() argument
1667 for (i = 0, o = observers; i < len; i++, o++) { in coap_observer_next_unused()
1896 if (sys_slist_is_empty(&resource->observers)) { in coap_resource_notify()
1902 SYS_SLIST_FOR_EACH_CONTAINER(&resource->observers, o, list) { in coap_resource_notify()
1947 sys_slist_append(&resource->observers, &observer->list); in coap_register_observer()
1962 if (!sys_slist_find_and_remove(&resource->observers, &observer->list)) { in coap_remove_observer()
2008 struct coap_observer *observers, size_t len, in coap_find_observer() argument
2017 struct coap_observer *o = &observers[i]; in coap_find_observer()
2030 struct coap_observer *observers, size_t len, in coap_find_observer_by_addr() argument
2036 struct coap_observer *o = &observers[i]; in coap_find_observer_by_addr()
[all …]
Dcoap_server.c93 obs = coap_find_observer(service->data->observers, MAX_OBSERVERS, addr, token, tkl); in coap_service_remove_observer()
96 obs = coap_find_observer_by_token(service->data->observers, MAX_OBSERVERS, token, in coap_service_remove_observer()
99 obs = coap_find_observer_by_addr(service->data->observers, MAX_OBSERVERS, addr); in coap_service_remove_observer()
641 observer = coap_find_observer(service->data->observers, MAX_OBSERVERS, addr, token, in coap_resource_parse_observe()
649 observer = coap_observer_next_unused(service->data->observers, MAX_OBSERVERS); in coap_resource_parse_observe()
DKconfig214 int "CoAP service observers"
217 Maximum number of CoAP observers per active service.
/Zephyr-latest/samples/subsys/zbus/hello_world/src/
Dmain.c118 SYS_SLIST_FOR_EACH_CONTAINER_SAFE(&chan->data->observers, obs_nd, tmp, node) { in print_channel_data_iterator()
/Zephyr-latest/doc/connectivity/networking/api/
Dcoap_server.rst198 /* Let the CoAP server parse the request and add/remove observers if needed */
223 if (sys_slist_is_empty(&temp_resource.observers)) {
/Zephyr-latest/samples/subsys/zbus/msg_subscriber/
DREADME.rst10 observers. It is possible to explore the pool isolation feature by setting the pool size and if it
/Zephyr-latest/samples/subsys/zbus/priority_boost/
DREADME.rst122 The developer must enable the priority boost and properly attach all the observers to their threads.
/Zephyr-latest/doc/releases/
Dmigration-guide-3.5.rst330 * ZBus runtime observers implementation now relies on the HEAP memory instead of a memory slab.
331 Thus, zbus' configuration (kconfig) related to runtime observers has changed. To keep your runtime
332 observers code working correctly, you need to:
Drelease-notes-3.5.rst2171 * Changed channels' and observers' metadata to comply with the data/config approach. ZBus stores
2173 * The relationship between channels and observers is mapped using a new entity called
2175 Developers can mask individual observations, disable the observer, or use runtime observers.
2176 * Added API :c:macro:`ZBUS_CHAN_ADD_OBS` macro for adding post-definition static observers of a
2178 observers after the channel definition in different files. It increases the composability of
2184 * ZBus runtime observers now rely on the heap instead of a memory pool.
2185 * Added new iterable section iterators APIs (for channels and observers) can now receive a
2188 :c:macro:`ZBUS_SUBSCRIBER_DEFINE_WITH_ENABLE` that allows developers to define observers'
2189 statuses (enabled/disabled) programmatically. With the API, developers can create observers
Drelease-notes-2.7.rst1100 * :github:`38702` - Coap server not properly removing observers
1102 * :github:`38700` - Observable resource of coap server seems to not support 2 observers simultaneou…
/Zephyr-latest/tests/net/lib/coap/src/
Dmain.c34 static struct coap_observer observers[NUM_OBSERVERS]; variable
873 observer = coap_observer_next_unused(observers, NUM_OBSERVERS); in server_resource_1_get()
1839 CONTAINER_OF(sys_slist_peek_head(&resource->observers), struct coap_observer, list); in ZTEST()