Lines Matching refs:param
563 struct mqtt_connack_param *param) in connack_properties_decode() argument
567 ¶m->prop.session_expiry_interval, in connack_properties_decode()
568 ¶m->prop.rx.has_session_expiry_interval, in connack_properties_decode()
572 ¶m->prop.receive_maximum, in connack_properties_decode()
573 ¶m->prop.rx.has_receive_maximum, in connack_properties_decode()
577 ¶m->prop.maximum_qos, in connack_properties_decode()
578 ¶m->prop.rx.has_maximum_qos, in connack_properties_decode()
582 ¶m->prop.retain_available, in connack_properties_decode()
583 ¶m->prop.rx.has_retain_available, in connack_properties_decode()
587 ¶m->prop.maximum_packet_size, in connack_properties_decode()
588 ¶m->prop.rx.has_maximum_packet_size, in connack_properties_decode()
592 ¶m->prop.assigned_client_id, in connack_properties_decode()
593 ¶m->prop.rx.has_assigned_client_id, in connack_properties_decode()
597 ¶m->prop.topic_alias_maximum, in connack_properties_decode()
598 ¶m->prop.rx.has_topic_alias_maximum, in connack_properties_decode()
602 ¶m->prop.reason_string, in connack_properties_decode()
603 ¶m->prop.rx.has_reason_string, in connack_properties_decode()
607 ¶m->prop.user_prop, in connack_properties_decode()
608 ¶m->prop.rx.has_user_prop, in connack_properties_decode()
612 ¶m->prop.wildcard_sub_available, in connack_properties_decode()
613 ¶m->prop.rx.has_wildcard_sub_available, in connack_properties_decode()
617 ¶m->prop.subscription_ids_available, in connack_properties_decode()
618 ¶m->prop.rx.has_subscription_ids_available, in connack_properties_decode()
622 ¶m->prop.shared_sub_available, in connack_properties_decode()
623 ¶m->prop.rx.has_shared_sub_available, in connack_properties_decode()
627 ¶m->prop.server_keep_alive, in connack_properties_decode()
628 ¶m->prop.rx.has_server_keep_alive, in connack_properties_decode()
632 ¶m->prop.response_information, in connack_properties_decode()
633 ¶m->prop.rx.has_response_information, in connack_properties_decode()
637 ¶m->prop.server_reference, in connack_properties_decode()
638 ¶m->prop.rx.has_server_reference, in connack_properties_decode()
642 ¶m->prop.auth_method, in connack_properties_decode()
643 ¶m->prop.rx.has_auth_method, in connack_properties_decode()
647 ¶m->prop.auth_data, in connack_properties_decode()
648 ¶m->prop.rx.has_auth_data, in connack_properties_decode()
657 struct mqtt_connack_param *param) in connack_properties_decode() argument
659 ARG_UNUSED(param); in connack_properties_decode()
667 struct mqtt_connack_param *param) in connect_ack_decode() argument
682 param->return_code = ret_code; in connect_ack_decode()
688 param->session_present_flag = flags & MQTT_CONNACK_FLAG_SESSION_PRESENT; in connect_ack_decode()
690 param->session_present_flag); in connect_ack_decode()
693 err_code = connack_properties_decode(buf, param); in connect_ack_decode()
705 struct mqtt_publish_param *param) in publish_properties_decode() argument
709 ¶m->prop.payload_format_indicator, in publish_properties_decode()
710 ¶m->prop.rx.has_payload_format_indicator, in publish_properties_decode()
714 ¶m->prop.message_expiry_interval, in publish_properties_decode()
715 ¶m->prop.rx.has_message_expiry_interval, in publish_properties_decode()
719 ¶m->prop.topic_alias, in publish_properties_decode()
720 ¶m->prop.rx.has_topic_alias, in publish_properties_decode()
724 ¶m->prop.response_topic, in publish_properties_decode()
725 ¶m->prop.rx.has_response_topic, in publish_properties_decode()
729 ¶m->prop.correlation_data, in publish_properties_decode()
730 ¶m->prop.rx.has_correlation_data, in publish_properties_decode()
734 ¶m->prop.user_prop, in publish_properties_decode()
735 ¶m->prop.rx.has_user_prop, in publish_properties_decode()
739 ¶m->prop.subscription_identifier, in publish_properties_decode()
740 ¶m->prop.rx.has_subscription_identifier, in publish_properties_decode()
744 ¶m->prop.content_type, in publish_properties_decode()
745 ¶m->prop.rx.has_content_type, in publish_properties_decode()
754 struct mqtt_publish_param *param) in publish_topic_alias_check() argument
756 uint16_t alias = param->prop.topic_alias; in publish_topic_alias_check()
757 struct mqtt_utf8 *topic_str = ¶m->message.topic.topic; in publish_topic_alias_check()
806 struct mqtt_publish_param *param) in publish_properties_decode() argument
808 ARG_UNUSED(param); in publish_properties_decode()
815 struct mqtt_publish_param *param) in publish_topic_alias_check() argument
818 ARG_UNUSED(param); in publish_topic_alias_check()
826 struct mqtt_publish_param *param) in publish_decode() argument
831 param->dup_flag = flags & MQTT_HEADER_DUP_MASK; in publish_decode()
832 param->retain_flag = flags & MQTT_HEADER_RETAIN_MASK; in publish_decode()
833 param->message.topic.qos = ((flags & MQTT_HEADER_QOS_MASK) >> 1); in publish_decode()
835 err_code = unpack_utf8_str(buf, ¶m->message.topic.topic); in publish_decode()
840 var_header_length = param->message.topic.topic.size + sizeof(uint16_t); in publish_decode()
842 if (param->message.topic.qos > MQTT_QOS_0_AT_MOST_ONCE) { in publish_decode()
843 err_code = unpack_uint16(buf, ¶m->message_id); in publish_decode()
852 err_code = publish_properties_decode(buf, param); in publish_decode()
860 err_code = publish_topic_alias_check(client, param); in publish_decode()
873 param->message.payload.data = NULL; in publish_decode()
874 param->message.payload.len = var_length - var_header_length; in publish_decode()
944 struct mqtt_puback_param *param) in publish_ack_decode() argument
951 prop = ¶m->prop; in publish_ack_decode()
952 reason_code = ¶m->reason_code; in publish_ack_decode()
956 return common_pub_ack_decode(buf, ¶m->message_id, reason_code, prop); in publish_ack_decode()
960 struct mqtt_pubrec_param *param) in publish_receive_decode() argument
967 prop = ¶m->prop; in publish_receive_decode()
968 reason_code = ¶m->reason_code; in publish_receive_decode()
972 return common_pub_ack_decode(buf, ¶m->message_id, reason_code, prop); in publish_receive_decode()
976 struct mqtt_pubrel_param *param) in publish_release_decode() argument
983 prop = ¶m->prop; in publish_release_decode()
984 reason_code = ¶m->reason_code; in publish_release_decode()
988 return common_pub_ack_decode(buf, ¶m->message_id, reason_code, prop); in publish_release_decode()
992 struct mqtt_pubcomp_param *param) in publish_complete_decode() argument
999 prop = ¶m->prop; in publish_complete_decode()
1000 reason_code = ¶m->reason_code; in publish_complete_decode()
1004 return common_pub_ack_decode(buf, ¶m->message_id, reason_code, prop); in publish_complete_decode()
1009 struct mqtt_suback_param *param) in suback_properties_decode() argument
1011 return common_ack_properties_decode(buf, ¶m->prop); in suback_properties_decode()
1015 struct mqtt_suback_param *param) in suback_properties_decode() argument
1017 ARG_UNUSED(param); in suback_properties_decode()
1025 struct mqtt_suback_param *param) in subscribe_ack_decode() argument
1029 err_code = unpack_uint16(buf, ¶m->message_id); in subscribe_ack_decode()
1035 err_code = suback_properties_decode(buf, param); in subscribe_ack_decode()
1041 return unpack_raw_data(buf->end - buf->cur, buf, ¶m->return_codes); in subscribe_ack_decode()
1046 struct mqtt_unsuback_param *param) in unsuback_5_0_decode() argument
1050 err = common_ack_properties_decode(buf, ¶m->prop); in unsuback_5_0_decode()
1055 return unpack_raw_data(buf->end - buf->cur, buf, ¶m->reason_codes); in unsuback_5_0_decode()
1059 struct mqtt_unsuback_param *param) in unsuback_5_0_decode() argument
1061 ARG_UNUSED(param); in unsuback_5_0_decode()
1069 struct mqtt_unsuback_param *param) in unsubscribe_ack_decode() argument
1073 err = unpack_uint16(buf, ¶m->message_id); in unsubscribe_ack_decode()
1079 return unsuback_5_0_decode(buf, param); in unsubscribe_ack_decode()
1087 struct mqtt_disconnect_param *param) in disconnect_properties_decode() argument
1091 ¶m->prop.session_expiry_interval, in disconnect_properties_decode()
1092 ¶m->prop.rx.has_session_expiry_interval, in disconnect_properties_decode()
1096 ¶m->prop.reason_string, in disconnect_properties_decode()
1097 ¶m->prop.rx.has_reason_string, in disconnect_properties_decode()
1101 ¶m->prop.user_prop, in disconnect_properties_decode()
1102 ¶m->prop.rx.has_user_prop, in disconnect_properties_decode()
1106 ¶m->prop.server_reference, in disconnect_properties_decode()
1107 ¶m->prop.rx.has_server_reference, in disconnect_properties_decode()
1116 struct mqtt_disconnect_param *param) in disconnect_decode() argument
1135 param->reason_code = reason_code; in disconnect_decode()
1139 err = disconnect_properties_decode(buf, param); in disconnect_decode()
1149 struct mqtt_auth_param *param) in auth_properties_decode() argument
1153 ¶m->prop.auth_method, in auth_properties_decode()
1154 ¶m->prop.rx.has_auth_method, in auth_properties_decode()
1158 ¶m->prop.auth_data, in auth_properties_decode()
1159 ¶m->prop.rx.has_auth_data, in auth_properties_decode()
1163 ¶m->prop.reason_string, in auth_properties_decode()
1164 ¶m->prop.rx.has_reason_string, in auth_properties_decode()
1168 ¶m->prop.user_prop, in auth_properties_decode()
1169 ¶m->prop.rx.has_user_prop, in auth_properties_decode()
1178 struct mqtt_auth_param *param) in auth_decode() argument
1196 param->reason_code = reason_code; in auth_decode()
1200 err = auth_properties_decode(buf, param); in auth_decode()