212 		       struct mqtt_connack_param *param)  in connect_ack_decode()  argument
228 		param->session_present_flag =  in connect_ack_decode()
232 			 param->session_present_flag);  in connect_ack_decode()
235 	param->return_code = (enum mqtt_conn_return_code)ret_code;  in connect_ack_decode()
241 		   struct mqtt_publish_param *param)  in publish_decode()  argument
246 	param->dup_flag = flags & MQTT_HEADER_DUP_MASK;  in publish_decode()
247 	param->retain_flag = flags & MQTT_HEADER_RETAIN_MASK;  in publish_decode()
248 	param->message.topic.qos = ((flags & MQTT_HEADER_QOS_MASK) >> 1);  in publish_decode()
250 	err_code = unpack_utf8_str(buf, &param->message.topic.topic);  in publish_decode()
255 	var_header_length = param->message.topic.topic.size + sizeof(uint16_t);  in publish_decode()
257 	if (param->message.topic.qos > MQTT_QOS_0_AT_MOST_ONCE) {  in publish_decode()
258 		err_code = unpack_uint16(buf, &param->message_id);  in publish_decode()
273 	param->message.payload.data = NULL;  in publish_decode()
274 	param->message.payload.len = var_length - var_header_length;  in publish_decode()
279 int publish_ack_decode(struct buf_ctx *buf, struct mqtt_puback_param *param)  in publish_ack_decode()  argument
281 	return unpack_uint16(buf, &param->message_id);  in publish_ack_decode()
284 int publish_receive_decode(struct buf_ctx *buf, struct mqtt_pubrec_param *param)  in publish_receive_decode()  argument
286 	return unpack_uint16(buf, &param->message_id);  in publish_receive_decode()
289 int publish_release_decode(struct buf_ctx *buf, struct mqtt_pubrel_param *param)  in publish_release_decode()  argument
291 	return unpack_uint16(buf, &param->message_id);  in publish_release_decode()
295 			    struct mqtt_pubcomp_param *param)  in publish_complete_decode()  argument
297 	return unpack_uint16(buf, &param->message_id);  in publish_complete_decode()
300 int subscribe_ack_decode(struct buf_ctx *buf, struct mqtt_suback_param *param)  in subscribe_ack_decode()  argument
304 	err_code = unpack_uint16(buf, &param->message_id);  in subscribe_ack_decode()
309 	return unpack_data(buf->end - buf->cur, buf, &param->return_codes);  in subscribe_ack_decode()
313 			   struct mqtt_unsuback_param *param)  in unsubscribe_ack_decode()  argument
315 	return unpack_uint16(buf, &param->message_id);  in unsubscribe_ack_decode()