Lines Matching refs:obs
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
3005 obs = engine_observe_node_discover(&msg->ctx->observer, &prev_node, NULL, in notify_message_reply_cb()
3008 if (obs) { in notify_message_reply_cb()
3009 obs->active_notify = NULL; in notify_message_reply_cb()
3012 lwm2m_read_first_path_ptr(&obs->path_list), in notify_message_reply_cb()
3015 notify_cached_pending_data_trig(obs); in notify_message_reply_cb()
3084 int generate_notify_message(struct lwm2m_ctx *ctx, struct observe_node *obs, void *user_data) in generate_notify_message() argument
3104 if (!obs->composite) { in generate_notify_message()
3105 path = lwm2m_read_first_path_ptr(&obs->path_list); in generate_notify_message()
3114 obs->resource_update ? "MANUAL" : "AUTO", path->obj_id, path->obj_inst_id, in generate_notify_message()
3115 path->res_id, path->level, sprint_token(obs->token, obs->tkl), in generate_notify_message()
3127 obs->resource_update ? "MANUAL" : "AUTO", in generate_notify_message()
3128 sprint_token(obs->token, obs->tkl), lwm2m_sprint_ip_addr(&ctx->remote_addr), in generate_notify_message()
3136 msg->token = obs->token; in generate_notify_message()
3137 msg->tkl = obs->tkl; in generate_notify_message()
3155 obs->counter++; in generate_notify_message()
3156 ret = coap_append_option_int(&msg->cpkt, COAP_OPTION_OBSERVE, obs->counter); in generate_notify_message()
3163 select_writer(&msg->out, obs->format); in generate_notify_message()
3164 if (obs->composite) { in generate_notify_message()
3166 ret = do_send_op(msg, obs->format, &obs->path_list); in generate_notify_message()
3168 ret = do_read_op(msg, obs->format); in generate_notify_message()
3182 obs->active_notify = msg; in generate_notify_message()
3183 obs->resource_update = false; in generate_notify_message()