398 int publish_encode(const struct mqtt_publish_param *param, struct buf_ctx *buf)  in publish_encode()  argument
401 			MQTT_PKT_TYPE_PUBLISH, param->dup_flag,  in publish_encode()
402 			param->message.topic.qos, param->retain_flag);  in publish_encode()
407 	if ((param->message.topic.qos) && (param->message_id == 0U)) {  in publish_encode()
415 	err_code = pack_utf8_str(&param->message.topic.topic, buf);  in publish_encode()
420 	if (param->message.topic.qos) {  in publish_encode()
421 		err_code = pack_uint16(param->message_id, buf);  in publish_encode()
430 	buf->cur += param->message.payload.len;  in publish_encode()
437 	buf->end -= param->message.payload.len;  in publish_encode()
442 int publish_ack_encode(const struct mqtt_puback_param *param,  in publish_ack_encode()  argument
448 	return mqtt_message_id_only_enc(message_type, param->message_id, buf);  in publish_ack_encode()
451 int publish_receive_encode(const struct mqtt_pubrec_param *param,  in publish_receive_encode()  argument
457 	return mqtt_message_id_only_enc(message_type, param->message_id, buf);  in publish_receive_encode()
460 int publish_release_encode(const struct mqtt_pubrel_param *param,  in publish_release_encode()  argument
466 	return mqtt_message_id_only_enc(message_type, param->message_id, buf);  in publish_release_encode()
469 int publish_complete_encode(const struct mqtt_pubcomp_param *param,  in publish_complete_encode()  argument
475 	return mqtt_message_id_only_enc(message_type, param->message_id, buf);  in publish_complete_encode()
493 int subscribe_encode(const struct mqtt_subscription_list *param,  in subscribe_encode()  argument
502 	if (param->message_id == 0U) {  in subscribe_encode()
510 	err_code = pack_uint16(param->message_id, buf);  in subscribe_encode()
515 	for (i = 0; i < param->list_count; i++) {  in subscribe_encode()
516 		err_code = pack_utf8_str(&param->list[i].topic, buf);  in subscribe_encode()
521 		err_code = pack_uint8(param->list[i].qos, buf);  in subscribe_encode()
530 int unsubscribe_encode(const struct mqtt_subscription_list *param,  in unsubscribe_encode()  argument
542 	err_code = pack_uint16(param->message_id, buf);  in unsubscribe_encode()
547 	for (i = 0; i < param->list_count; i++) {  in unsubscribe_encode()
548 		err_code = pack_utf8_str(&param->list[i].topic, buf);  in unsubscribe_encode()