Lines Matching refs:fixed_hdr_len
667 * @param fixed_hdr_len length of fixed header
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_length)
676 u8_t *var_hdr_payload = client->rx_buffer + fixed_hdr_len;
677 size_t var_hdr_payload_bufsize = sizeof(client->rx_buffer) - fixed_hdr_len;
683 LWIP_ASSERT("fixed_hdr_len <= client->msg_idx", fixed_hdr_len <= client->msg_idx);
684 LWIP_ERROR("buffer length mismatch", fixed_hdr_len + length <= MQTT_VAR_HEADER_BUFFER_LEN,
844 u8_t fixed_hdr_len = 0;
851 if ((fixed_hdr_len < 2) || ((b & 0x80) != 0)) {
853 if (fixed_hdr_len < client->msg_idx) {
855 b = client->rx_buffer[fixed_hdr_len];
862 fixed_hdr_len++;
864 if (fixed_hdr_len >= 2) {
868 msg_rem_len |= (u32_t)(b & 0x7f) << ((fixed_hdr_len - 2) * 7);
874 mqtt_message_received(client, fixed_hdr_len, 0, 0);
876 fixed_hdr_len = 0;
880 msg_rem_len = (msg_rem_len + fixed_hdr_len) - client->msg_idx;
892 buffer_space = MQTT_VAR_HEADER_BUFFER_LEN - fixed_hdr_len;
896 pbuf_copy_partial(p, client->rx_buffer + fixed_hdr_len, cpy_len, in_offset);
906 mqtt_connection_status_t res = mqtt_message_received(client, fixed_hdr_len, cpy_len, msg_rem_len);
914 fixed_hdr_len = 0;