Lines Matching refs:param
858 static uint32_t publish_properties_length(const struct mqtt_publish_param *param) in publish_properties_length() argument
861 param->prop.payload_format_indicator) + in publish_properties_length()
862 uint32_property_length(param->prop.message_expiry_interval) + in publish_properties_length()
863 uint16_property_length(param->prop.topic_alias) + in publish_properties_length()
864 string_property_length(¶m->prop.response_topic) + in publish_properties_length()
865 binary_property_length(¶m->prop.correlation_data) + in publish_properties_length()
866 user_properties_length(param->prop.user_prop) + in publish_properties_length()
868 string_property_length(¶m->prop.content_type); in publish_properties_length()
871 static int publish_properties_encode(const struct mqtt_publish_param *param, in publish_properties_encode() argument
878 properties_len = publish_properties_length(param); in publish_properties_encode()
885 param->prop.payload_format_indicator, buf); in publish_properties_encode()
891 param->prop.message_expiry_interval, buf); in publish_properties_encode()
897 param->prop.topic_alias, buf); in publish_properties_encode()
903 ¶m->prop.response_topic, buf); in publish_properties_encode()
909 ¶m->prop.correlation_data, buf); in publish_properties_encode()
914 err = encode_user_properties(param->prop.user_prop, buf); in publish_properties_encode()
922 ¶m->prop.content_type, buf); in publish_properties_encode()
930 static int publish_properties_encode(const struct mqtt_publish_param *param, in publish_properties_encode() argument
933 ARG_UNUSED(param); in publish_properties_encode()
941 const struct mqtt_publish_param *param, in publish_encode() argument
945 MQTT_PKT_TYPE_PUBLISH, param->dup_flag, in publish_encode()
946 param->message.topic.qos, param->retain_flag); in publish_encode()
951 if ((param->message.topic.qos) && (param->message_id == 0U)) { in publish_encode()
959 err_code = pack_utf8_str(¶m->message.topic.topic, buf); in publish_encode()
964 if (param->message.topic.qos) { in publish_encode()
965 err_code = pack_uint16(param->message_id, buf); in publish_encode()
972 err_code = publish_properties_encode(param, buf); in publish_encode()
981 buf->cur += param->message.payload.len; in publish_encode()
988 buf->end -= param->message.payload.len; in publish_encode()
1099 const struct mqtt_puback_param *param, in publish_ack_encode() argument
1109 prop = ¶m->prop; in publish_ack_encode()
1110 reason_code = param->reason_code; in publish_ack_encode()
1114 return common_ack_encode(message_type, param->message_id, in publish_ack_encode()
1119 const struct mqtt_pubrec_param *param, in publish_receive_encode() argument
1129 prop = ¶m->prop; in publish_receive_encode()
1130 reason_code = param->reason_code; in publish_receive_encode()
1134 return common_ack_encode(message_type, param->message_id, in publish_receive_encode()
1139 const struct mqtt_pubrel_param *param, in publish_release_encode() argument
1149 prop = ¶m->prop; in publish_release_encode()
1150 reason_code = param->reason_code; in publish_release_encode()
1154 return common_ack_encode(message_type, param->message_id, in publish_release_encode()
1159 const struct mqtt_pubcomp_param *param, in publish_complete_encode() argument
1169 prop = ¶m->prop; in publish_complete_encode()
1170 reason_code = param->reason_code; in publish_complete_encode()
1174 return common_ack_encode(message_type, param->message_id, in publish_complete_encode()
1194 static uint32_t disconnect_properties_length(const struct mqtt_disconnect_param *param) in disconnect_properties_length() argument
1196 return uint32_property_length(param->prop.session_expiry_interval) + in disconnect_properties_length()
1197 string_property_length(¶m->prop.reason_string) + in disconnect_properties_length()
1198 user_properties_length(param->prop.user_prop) + in disconnect_properties_length()
1199 string_property_length(¶m->prop.server_reference); in disconnect_properties_length()
1202 static int disconnect_properties_encode(const struct mqtt_disconnect_param *param, in disconnect_properties_encode() argument
1209 properties_len = disconnect_properties_length(param); in disconnect_properties_encode()
1221 param->prop.session_expiry_interval, buf); in disconnect_properties_encode()
1227 ¶m->prop.reason_string, buf); in disconnect_properties_encode()
1232 err = encode_user_properties(param->prop.user_prop, buf); in disconnect_properties_encode()
1238 ¶m->prop.server_reference, buf); in disconnect_properties_encode()
1246 static int disconnect_5_0_encode(const struct mqtt_disconnect_param *param, in disconnect_5_0_encode() argument
1257 if ((param->reason_code == MQTT_DISCONNECT_NORMAL) && in disconnect_5_0_encode()
1258 (disconnect_properties_length(param) == 0U)) { in disconnect_5_0_encode()
1266 err = pack_uint8(param->reason_code, buf); in disconnect_5_0_encode()
1271 err = disconnect_properties_encode(param, buf); in disconnect_5_0_encode()
1284 static int disconnect_5_0_encode(const struct mqtt_disconnect_param *param, in disconnect_5_0_encode() argument
1287 ARG_UNUSED(param); in disconnect_5_0_encode()
1295 const struct mqtt_disconnect_param *param, in disconnect_encode() argument
1298 if (!mqtt_is_version_5_0(client) || param == NULL) { in disconnect_encode()
1302 return disconnect_5_0_encode(param, buf); in disconnect_encode()
1307 const struct mqtt_subscription_list *param) in subscribe_properties_length() argument
1309 return var_int_property_length(param->prop.subscription_identifier) + in subscribe_properties_length()
1310 user_properties_length(param->prop.user_prop); in subscribe_properties_length()
1313 static int subscribe_properties_encode(const struct mqtt_subscription_list *param, in subscribe_properties_encode() argument
1320 properties_len = subscribe_properties_length(param); in subscribe_properties_encode()
1327 param->prop.subscription_identifier, in subscribe_properties_encode()
1333 err = encode_user_properties(param->prop.user_prop, buf); in subscribe_properties_encode()
1341 static int subscribe_properties_encode(const struct mqtt_subscription_list *param, in subscribe_properties_encode() argument
1344 ARG_UNUSED(param); in subscribe_properties_encode()
1352 const struct mqtt_subscription_list *param, in subscribe_encode() argument
1361 if (param->message_id == 0U) { in subscribe_encode()
1369 err_code = pack_uint16(param->message_id, buf); in subscribe_encode()
1375 err_code = subscribe_properties_encode(param, buf); in subscribe_encode()
1381 for (i = 0; i < param->list_count; i++) { in subscribe_encode()
1382 err_code = pack_utf8_str(¶m->list[i].topic, buf); in subscribe_encode()
1387 err_code = pack_uint8(param->list[i].qos, buf); in subscribe_encode()
1398 const struct mqtt_subscription_list *param) in unsubscribe_properties_length() argument
1400 return user_properties_length(param->prop.user_prop); in unsubscribe_properties_length()
1404 const struct mqtt_subscription_list *param, struct buf_ctx *buf) in unsubscribe_properties_encode() argument
1410 properties_len = unsubscribe_properties_length(param); in unsubscribe_properties_encode()
1416 err = encode_user_properties(param->prop.user_prop, buf); in unsubscribe_properties_encode()
1425 const struct mqtt_subscription_list *param, struct buf_ctx *buf) in unsubscribe_properties_encode() argument
1427 ARG_UNUSED(param); in unsubscribe_properties_encode()
1435 const struct mqtt_subscription_list *param, in unsubscribe_encode() argument
1447 err_code = pack_uint16(param->message_id, buf); in unsubscribe_encode()
1453 err_code = unsubscribe_properties_encode(param, buf); in unsubscribe_encode()
1459 for (i = 0; i < param->list_count; i++) { in unsubscribe_encode()
1460 err_code = pack_utf8_str(¶m->list[i].topic, buf); in unsubscribe_encode()
1485 static uint32_t auth_properties_length(const struct mqtt_auth_param *param) in auth_properties_length() argument
1487 return string_property_length(¶m->prop.auth_method) + in auth_properties_length()
1488 binary_property_length(¶m->prop.auth_data) + in auth_properties_length()
1489 string_property_length(¶m->prop.reason_string) + in auth_properties_length()
1490 user_properties_length(param->prop.user_prop); in auth_properties_length()
1493 static int auth_properties_encode(const struct mqtt_auth_param *param, in auth_properties_encode() argument
1500 properties_len = auth_properties_length(param); in auth_properties_encode()
1511 ¶m->prop.auth_method, buf); in auth_properties_encode()
1517 ¶m->prop.auth_data, buf); in auth_properties_encode()
1523 ¶m->prop.reason_string, buf); in auth_properties_encode()
1528 err = encode_user_properties(param->prop.user_prop, buf); in auth_properties_encode()
1555 int auth_encode(const struct mqtt_auth_param *param, struct buf_ctx *buf) in auth_encode() argument
1566 if ((param->reason_code == MQTT_AUTH_SUCCESS) && in auth_encode()
1567 (auth_properties_length(param) == 0U)) { in auth_encode()
1571 err = pack_uint8(param->reason_code, buf); in auth_encode()
1576 err = auth_properties_encode(param, buf); in auth_encode()