Lines Matching refs:msg
93 static void setup_out_fmt_data(struct lwm2m_message *msg) in setup_out_fmt_data() argument
100 engine_set_out_user_data(&msg->out, fd); in setup_out_fmt_data()
106 static void clear_out_fmt_data(struct lwm2m_message *msg) in clear_out_fmt_data() argument
108 engine_clear_out_user_data(&msg->out); in clear_out_fmt_data()
113 static void setup_in_fmt_data(struct lwm2m_message *msg) in setup_in_fmt_data() argument
120 engine_set_in_user_data(&msg->in, fd); in setup_in_fmt_data()
123 static void clear_in_fmt_data(struct lwm2m_message *msg) in clear_in_fmt_data() argument
125 engine_clear_in_user_data(&msg->in); in clear_in_fmt_data()
721 static int do_write_op_item(struct lwm2m_message *msg, struct record *rec) in do_write_op_item() argument
738 fd = engine_get_in_user_data(&msg->in); in do_write_op_item()
753 ret = lwm2m_string_to_path(fqn, &msg->path, '/'); in do_write_op_item()
761 ret = lwm2m_get_or_create_engine_obj(msg, &obj_inst, &created); in do_write_op_item()
766 ret = lwm2m_engine_validate_write_access(msg, obj_inst, &obj_field); in do_write_op_item()
771 ret = lwm2m_engine_get_create_res_inst(&msg->path, &res, &res_inst); in do_write_op_item()
774 if ((msg->ctx->bootstrap_mode || in do_write_op_item()
775 msg->operation == LWM2M_OP_CREATE) && in do_write_op_item()
785 ret = lwm2m_write_handler(obj_inst, res, res_inst, obj_field, msg); in do_write_op_item()
823 int do_read_op_senml_cbor(struct lwm2m_message *msg) in do_read_op_senml_cbor() argument
827 setup_out_fmt_data(msg); in do_read_op_senml_cbor()
829 ret = lwm2m_perform_read_op(msg, LWM2M_FORMAT_APP_SENML_CBOR); in do_read_op_senml_cbor()
831 clear_out_fmt_data(msg); in do_read_op_senml_cbor()
836 static uint8_t parse_composite_read_paths(struct lwm2m_message *msg, in parse_composite_read_paths() argument
856 setup_in_fmt_data(msg); in parse_composite_read_paths()
858 fd = engine_get_in_user_data(&msg->in); in parse_composite_read_paths()
859 payload = (char *)coap_packet_get_payload(msg->in.in_cpkt, &in_len); in parse_composite_read_paths()
868 msg->in.offset += isize; in parse_composite_read_paths()
916 clear_in_fmt_data(msg); in parse_composite_read_paths()
921 int do_composite_read_op_for_parsed_path_senml_cbor(struct lwm2m_message *msg, in do_composite_read_op_for_parsed_path_senml_cbor() argument
926 setup_out_fmt_data(msg); in do_composite_read_op_for_parsed_path_senml_cbor()
928 ret = lwm2m_perform_composite_read_op(msg, LWM2M_FORMAT_APP_SENML_CBOR, lwm_path_list); in do_composite_read_op_for_parsed_path_senml_cbor()
930 clear_out_fmt_data(msg); in do_composite_read_op_for_parsed_path_senml_cbor()
936 int do_composite_read_op_senml_cbor(struct lwm2m_message *msg) in do_composite_read_op_senml_cbor() argument
949 len = parse_composite_read_paths(msg, &lwm_path_list, &lwm_path_free_list); in do_composite_read_op_senml_cbor()
957 return do_composite_read_op_for_parsed_list(msg, LWM2M_FORMAT_APP_SENML_CBOR, in do_composite_read_op_senml_cbor()
961 int do_write_op_senml_cbor(struct lwm2m_message *msg) in do_write_op_senml_cbor() argument
971 if (msg->in.block_ctx != NULL && msg->in.block_ctx->ctx.current > 0) { in do_write_op_senml_cbor()
972 msg->path.res_id = msg->in.block_ctx->path.res_id; in do_write_op_senml_cbor()
973 msg->path.level = msg->in.block_ctx->path.level; in do_write_op_senml_cbor()
975 if (msg->path.level == LWM2M_PATH_LEVEL_RESOURCE_INST) { in do_write_op_senml_cbor()
976 msg->path.res_inst_id = msg->in.block_ctx->path.res_inst_id; in do_write_op_senml_cbor()
979 return do_write_op_item(msg, NULL); in do_write_op_senml_cbor()
982 setup_in_fmt_data(msg); in do_write_op_senml_cbor()
984 fd = engine_get_in_user_data(&msg->in); in do_write_op_senml_cbor()
986 dret = cbor_decode_lwm2m_senml(ICTX_BUF_R_PTR(&msg->in), ICTX_BUF_R_LEFT_SZ(&msg->in), in do_write_op_senml_cbor()
994 msg->in.offset += decoded_sz; in do_write_op_senml_cbor()
1024 ret = do_write_op_item(msg, rec); in do_write_op_senml_cbor()
1032 (msg->ctx->bootstrap_mode || msg->operation == LWM2M_OP_CREATE))) { in do_write_op_senml_cbor()
1040 clear_in_fmt_data(msg); in do_write_op_senml_cbor()
1045 int do_composite_observe_parse_path_senml_cbor(struct lwm2m_message *msg, in do_composite_observe_parse_path_senml_cbor() argument
1052 original_offset = msg->in.offset; in do_composite_observe_parse_path_senml_cbor()
1055 len = parse_composite_read_paths(msg, lwm2m_path_list, lwm2m_path_free_list); in do_composite_observe_parse_path_senml_cbor()
1062 msg->in.offset = original_offset; in do_composite_observe_parse_path_senml_cbor()
1066 int do_send_op_senml_cbor(struct lwm2m_message *msg, sys_slist_t *lwm2m_path_list) in do_send_op_senml_cbor() argument
1070 setup_out_fmt_data(msg); in do_send_op_senml_cbor()
1072 ret = lwm2m_perform_composite_read_op(msg, LWM2M_FORMAT_APP_SENML_CBOR, lwm2m_path_list); in do_send_op_senml_cbor()
1074 clear_out_fmt_data(msg); in do_send_op_senml_cbor()