| /Zephyr-latest/subsys/zbus/ |
| D | zbus.c | 126 const struct zbus_observer *obs, k_timepoint_t end_time, in _zbus_notify_observer() argument
129 switch (obs->type) { in _zbus_notify_observer()
131 obs->callback(chan); in _zbus_notify_observer()
135 return k_msgq_put(obs->queue, &chan, sys_timepoint_timeout(end_time)); in _zbus_notify_observer()
145 k_fifo_put(obs->message_fifo, cloned_buf); in _zbus_notify_observer()
193 const struct zbus_observer *obs = observation->obs; in _zbus_vded_exec() local
195 if (!obs->data->enabled || observation_mask->enabled) { in _zbus_vded_exec()
199 err = _zbus_notify_observer(chan, obs, end_time, buf); in _zbus_vded_exec()
204 _ZBUS_OBS_NAME(obs), err); in _zbus_vded_exec()
213 LOG_DBG(" %d -> %s", index++, _ZBUS_OBS_NAME(obs)); in _zbus_vded_exec()
[all …]
|
| D | zbus_runtime_observers.c | 11 int zbus_chan_add_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, in zbus_chan_add_obs() argument
20 _ZBUS_ASSERT(obs != NULL, "obs is required"); in zbus_chan_add_obs()
33 if (observation->obs == obs) { in zbus_chan_add_obs()
42 if (obs_nd->obs == obs) { in zbus_chan_add_obs()
59 new_obs_nd->obs = obs; in zbus_chan_add_obs()
68 int zbus_chan_rm_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, in zbus_chan_rm_obs() argument
77 _ZBUS_ASSERT(obs != NULL, "obs is required"); in zbus_chan_rm_obs()
85 if (obs_nd->obs == obs) { in zbus_chan_rm_obs()
|
| D | zbus_iterable_sections.c | 31 bool zbus_iterate_over_observers(bool (*iterator_func)(const struct zbus_observer *obs)) in zbus_iterate_over_observers() argument
33 STRUCT_SECTION_FOREACH(zbus_observer, obs) { in zbus_iterate_over_observers()
34 if (!(*iterator_func)(obs)) { in zbus_iterate_over_observers()
42 bool (*iterator_func)(const struct zbus_observer *obs, void *user_data), void *user_data) in zbus_iterate_over_observers_with_user_data() argument
44 STRUCT_SECTION_FOREACH(zbus_observer, obs) { in zbus_iterate_over_observers_with_user_data()
45 if (!(*iterator_func)(obs, user_data)) { in zbus_iterate_over_observers_with_user_data()
|
| /Zephyr-latest/subsys/net/lib/lwm2m/ |
| D | lwm2m_observation.c | 356 struct observe_node *obs; in lwm2m_notify_observer_path() local
369 SYS_SLIST_FOR_EACH_CONTAINER(&sock_ctx[i]->observer, obs, node) { in lwm2m_notify_observer_path()
370 if (lwm2m_notify_observer_list(&obs->path_list, path)) { in lwm2m_notify_observer_path()
372 ret = engine_observe_attribute_list_get(&obs->path_list, &nattrs, in lwm2m_notify_observer_path()
380 obs->last_timestamp + MSEC_PER_SEC * nattrs.pmin; in lwm2m_notify_observer_path()
386 if (!obs->event_timestamp || obs->event_timestamp > timestamp) { in lwm2m_notify_observer_path()
387 obs->resource_update = true; in lwm2m_notify_observer_path()
388 obs->event_timestamp = timestamp; in lwm2m_notify_observer_path()
406 struct observe_node *obs = NULL; in engine_allocate_observer() local
412 obs = &observe_node_data[i]; in engine_allocate_observer()
[all …]
|
| D | lwm2m_observation.h | 37 int64_t engine_observe_shedule_next_event(struct observe_node *obs, uint16_t srv_obj_inst,
41 struct observe_node *obs);
|
| D | lwm2m_message_handling.c | 450 struct observe_node *obs; in lwm2m_engine_context_close() local
458 obs = SYS_SLIST_CONTAINER(obs_node, obs, node); in lwm2m_engine_context_close()
459 remove_observer_from_list(client_ctx, NULL, obs); in lwm2m_engine_context_close()
2929 struct observe_node *obs; in notify_message_timeout_cb() local
2933 obs = engine_observe_node_discover(&client_ctx->observer, &prev_node, NULL, in notify_message_timeout_cb()
2936 if (obs) { in notify_message_timeout_cb()
2937 obs->active_notify = NULL; in notify_message_timeout_cb()
2958 static void notify_cached_pending_data_trig(struct observe_node *obs) in notify_cached_pending_data_trig() argument
2964 SYS_SLIST_FOR_EACH_CONTAINER(&obs->path_list, entry, node) { in notify_cached_pending_data_trig()
2982 struct observe_node *obs; in notify_message_reply_cb() local
[all …]
|
| D | lwm2m_engine.c | 597 struct observe_node *obs; in check_notifications() local
602 SYS_SLIST_FOR_EACH_CONTAINER(&ctx->observer, obs, node) { in check_notifications()
603 if (!obs->event_timestamp) { in check_notifications()
607 if (obs->event_timestamp < next) { in check_notifications()
608 next = obs->event_timestamp; in check_notifications()
611 if (timestamp < obs->event_timestamp) { in check_notifications()
615 if (obs->active_notify != NULL) { in check_notifications()
619 rc = generate_notify_message(ctx, obs, NULL); in check_notifications()
624 obs->event_timestamp = in check_notifications()
625 engine_observe_shedule_next_event(obs, ctx->srv_obj_inst, timestamp); in check_notifications()
[all …]
|
| D | lwm2m_message_handling.h | 55 int generate_notify_message(struct lwm2m_ctx *ctx, struct observe_node *obs, void *user_data);
|
| D | lwm2m_shell.c | 668 struct observe_node *obs; in cmd_observations() local
691 SYS_SLIST_FOR_EACH_CONTAINER(&ctx->observer, obs, node) { in cmd_observations()
692 shell_fprintf(sh, SHELL_NORMAL, "%2u %10c ", i, obs->composite ? 'y' : 'n'); in cmd_observations()
694 SYS_SLIST_FOR_EACH_CONTAINER(&obs->path_list, o_p, node) { in cmd_observations()
856 SHELL_CMD_ARG(obs, NULL, LWM2M_HELP_OBSERV, cmd_observations, 1, 0),
|
| /Zephyr-latest/samples/sensor/lps22hb/src/ |
| D | main.c | 15 static unsigned int obs; in process_sample() local
33 ++obs; in process_sample()
34 printf("Observation:%u\n", obs); in process_sample()
|
| /Zephyr-latest/include/zephyr/zbus/ |
| D | zbus.h | 182 const struct zbus_observer *obs; member
257 .obs = &_obs}; \
317 .obs = &_obs, \
880 int zbus_chan_add_obs(const struct zbus_channel *chan, const struct zbus_observer *obs,
900 int zbus_chan_rm_obs(const struct zbus_channel *chan, const struct zbus_observer *obs,
907 const struct zbus_observer *obs; member
927 int zbus_obs_set_enable(const struct zbus_observer *obs, bool enabled);
939 static inline int zbus_obs_is_enabled(const struct zbus_observer *obs, bool *enable) in zbus_obs_is_enabled() argument
941 _ZBUS_ASSERT(obs != NULL, "obs is required"); in zbus_obs_is_enabled()
944 *enable = obs->data->enabled; in zbus_obs_is_enabled()
[all …]
|
| /Zephyr-latest/samples/sensor/hts221/src/ |
| D | main.c | 15 static unsigned int obs; in process_sample() local
32 ++obs; in process_sample()
33 printf("Observation:%u\n", obs); in process_sample()
|
| /Zephyr-latest/samples/sensor/lps22hh/src/ |
| D | main.c | 16 static unsigned int obs; in process_sample() local
34 ++obs; in process_sample()
35 printf("Observation: %u\n", obs); in process_sample()
|
| /Zephyr-latest/samples/subsys/zbus/hello_world/src/ |
| D | main.c | 113 LOG_INF(" - %s", observation->obs->name); in print_channel_data_iterator()
119 LOG_INF(" - %s", obs_nd->obs->name); in print_channel_data_iterator()
125 static bool print_observer_data_iterator(const struct zbus_observer *obs, void *user_data) in print_observer_data_iterator() argument
130 obs->type == ZBUS_OBSERVER_LISTENER_TYPE ? "Listener" : "Subscriber", in print_observer_data_iterator()
131 zbus_obs_name(obs)); in print_observer_data_iterator()
|
| /Zephyr-latest/tests/subsys/zbus/unittests/src/ |
| D | main.c | 373 static bool always_true_obs_iterator(const struct zbus_observer *obs) in always_true_obs_iterator() argument
383 static bool always_false_obs_iterator(const struct zbus_observer *obs) in always_false_obs_iterator() argument
433 static bool check_obs_iterator(const struct zbus_observer *obs, void *user_data) in check_obs_iterator() argument
437 LOG_DBG("Idx %d - Observer %s", *obs_idx, obs->name); in check_obs_iterator()
441 zassert_mem_equal__(zbus_obs_name(obs), "busy_lis", 8, "Must be equal"); in check_obs_iterator()
444 zassert_mem_equal__(zbus_obs_name(obs), "fast_lis", 8, "Must be equal"); in check_obs_iterator()
447 zassert_mem_equal__(zbus_obs_name(obs), "foo2_msg_sub", sizeof("foo2_msg_sub"), in check_obs_iterator()
451 zassert_mem_equal__(zbus_obs_name(obs), "foo_msg_sub", 11, "Must be equal"); in check_obs_iterator()
454 zassert_mem_equal__(zbus_obs_name(obs), "foo_sub", 7, "Must be equal"); in check_obs_iterator()
457 zassert_mem_equal__(zbus_obs_name(obs), "invalid_obs", strlen("invalid_obs"), in check_obs_iterator()
[all …]
|
| /Zephyr-latest/subsys/net/lib/coap/ |
| D | coap_server.c | 89 struct coap_observer *obs; in coap_service_remove_observer() local
93 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()
105 if (obs == NULL) { in coap_service_remove_observer()
111 if (coap_remove_observer(it, obs)) { in coap_service_remove_observer()
112 memset(obs, 0, sizeof(*obs)); in coap_service_remove_observer()
116 } else if (coap_remove_observer(resource, obs)) { in coap_service_remove_observer()
117 memset(obs, 0, sizeof(*obs)); in coap_service_remove_observer()
|
| /Zephyr-latest/samples/net/sockets/coap_server/src/ |
| D | observer.c | 126 COAP_RESOURCE_DEFINE(obs, coap_server,
137 coap_resource_notify(&obs); in update_counter()
|
| /Zephyr-latest/tests/net/lib/lwm2m/lwm2m_engine/src/ |
| D | main.c | 232 struct observe_node obs; in ZTEST() local
241 obs.last_timestamp = k_uptime_get(); in ZTEST()
242 obs.event_timestamp = k_uptime_get() + 1000U; in ZTEST()
243 obs.resource_update = false; in ZTEST()
244 obs.active_notify = NULL; in ZTEST()
246 sys_slist_append(&ctx.observer, &obs.node); in ZTEST()
|
| /Zephyr-latest/soc/intel/intel_adsp/common/include/ |
| D | manifest.h | 100 uint32_t obs; /* output buffer size (bytes) */ member
|
| /Zephyr-latest/samples/subsys/zbus/runtime_obs_registration/ |
| D | README.rst | 1 .. zephyr:code-sample:: zbus-runtime-obs-registration
|
| /Zephyr-latest/doc/services/zbus/ |
| D | index.rst | 669 LOG_INF(" - %s", observation->obs->name);
675 LOG_INF(" - %s", obs_nd->obs->name);
681 static bool print_observer_data_iterator(const struct zbus_observer *obs, void *user_data)
685 LOG_INF("%d - %s %s", *count, obs->queue ? "Subscriber" : "Listener", zbus_obs_name(obs));
862 * :zephyr:code-sample:`zbus-runtime-obs-registration` illustrates a way of using the runtime
|
| /Zephyr-latest/doc/connectivity/networking/api/ |
| D | lwm2m.rst | 792 obs : List observations
|
| /Zephyr-latest/doc/releases/ |
| D | release-notes-3.3.rst | 2504 * :zephyr:code-sample:`zbus-runtime-obs-registration`
|
