Commit 8f2980b5cccb5292381783d0825723c72427c418
1 parent
2e26e00c
Fix buffer bug
Showing
1 changed file
with
1 additions
and
1 deletions
client.cpp
| @@ -128,7 +128,7 @@ bool Client::bufferToMqttPackets(std::vector<MqttPacket> &packetQueueIn) | @@ -128,7 +128,7 @@ bool Client::bufferToMqttPackets(std::vector<MqttPacket> &packetQueueIn) | ||
| 128 | { | 128 | { |
| 129 | if (remaining_length_i >= getReadBufBytesUsed()) | 129 | if (remaining_length_i >= getReadBufBytesUsed()) |
| 130 | break; | 130 | break; |
| 131 | - encodedByte = readbuf[remaining_length_i++]; | 131 | + encodedByte = readbuf[ri + remaining_length_i++]; |
| 132 | packet_length += (encodedByte & 127) * multiplier; | 132 | packet_length += (encodedByte & 127) * multiplier; |
| 133 | multiplier *= 128; | 133 | multiplier *= 128; |
| 134 | if (multiplier > 128*128*128) | 134 | if (multiplier > 128*128*128) |