Lines Matching defs:fixed_hdr_idx
667 * @param fixed_hdr_idx header index
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_idx, u16_t length, u32_t remaining_length)
676 u8_t *var_hdr_payload = client->rx_buffer + fixed_hdr_idx;
677 size_t var_hdr_payload_bufsize = sizeof(client->rx_buffer) - fixed_hdr_idx;
684 LWIP_ASSERT("fixed_hdr_idx <= client->msg_idx", fixed_hdr_idx <= client->msg_idx);
685 LWIP_ERROR("buffer length mismatch", fixed_hdr_idx + length <= MQTT_VAR_HEADER_BUFFER_LEN,
843 u8_t fixed_hdr_idx = 0;
850 if ((fixed_hdr_idx < 2) || ((b & 0x80) != 0)) {
852 if (fixed_hdr_idx < client->msg_idx) {
854 b = client->rx_buffer[fixed_hdr_idx];
861 fixed_hdr_idx++;
863 if (fixed_hdr_idx >= 2) {
867 msg_rem_len |= (u32_t)(b & 0x7f) << ((fixed_hdr_idx - 2) * 7);
873 mqtt_message_received(client, fixed_hdr_idx, 0, 0);
875 fixed_hdr_idx = 0;
879 msg_rem_len = (msg_rem_len + fixed_hdr_idx) - client->msg_idx;
887 cpy_start = (client->msg_idx - fixed_hdr_idx) % (MQTT_VAR_HEADER_BUFFER_LEN - fixed_hdr_idx) + fixed_hdr_idx;
907 mqtt_connection_status_t res = mqtt_message_received(client, fixed_hdr_idx, (cpy_start + cpy_len) - fixed_hdr_idx, msg_rem_len);
915 fixed_hdr_idx = 0;