Lines Matching refs:remaining_length
669 * @param remaining_length Remaining length of complete message
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_length)
763 qos, topic, remaining_length + payload_length));
765 client->pub_cb(client->inpub_arg, (const char *)topic, remaining_length + payload_length);
770 if (payload_length > 0 || remaining_length == 0) {
776 client->data_cb(client->inpub_arg, var_hdr_payload + payload_offset, payload_length, remaining_length == 0 ? MQTT_DATA_FLAG_LAST : 0);
779 if (remaining_length == 0 && qos > 0) {
1104 u16_t remaining_length;
1125 remaining_length = (u16_t)total_len;
1134 if (mqtt_output_check_space(&client->output, remaining_length) == 0) {
1139 mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_length);
1177 u16_t remaining_length;
1191 remaining_length = (u16_t)total_len;
1205 if (mqtt_output_check_space(&client->output, remaining_length) == 0) {
1212 mqtt_output_append_fixed_header(&client->output, sub ? MQTT_MSG_TYPE_SUBSCRIBE : MQTT_MSG_TYPE_UNSUBSCRIBE, 0, 1, 0, remaining_length);
1289 u16_t remaining_length = 2 + 4 + 1 + 1 + 2;
1325 len = remaining_length + 2 + will_topic_len + 2 + will_msg_len;
1326 LWIP_ERROR("mqtt_client_connect: remaining_length overflow", len <= 0xFFFF, return ERR_VAL);
1327 remaining_length = (u16_t)len;
1335 len = remaining_length + 2 + client_user_len;
1336 LWIP_ERROR("mqtt_client_connect: remaining_length overflow", len <= 0xFFFF, return ERR_VAL);
1337 remaining_length = (u16_t)len;
1345 len = remaining_length + 2 + client_pass_len;
1346 LWIP_ERROR("mqtt_client_connect: remaining_length overflow", len <= 0xFFFF, return ERR_VAL);
1347 remaining_length = (u16_t)len;
1356 len = remaining_length + 2 + client_id_length;
1357 LWIP_ERROR("mqtt_client_connect: remaining_length overflow", len <= 0xFFFF, return ERR_VAL);
1358 remaining_length = (u16_t)len;
1360 if (mqtt_output_check_space(&client->output, remaining_length) == 0) {
1397 mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_CONNECT, 0, 0, 0, remaining_length);