diff --git a/src/apps/mqtt/mqtt.c b/src/apps/mqtt/mqtt.c index 49367e78..1adcab0b 100644 --- a/src/apps/mqtt/mqtt.c +++ b/src/apps/mqtt/mqtt.c @@ -204,7 +204,7 @@ mqtt_ringbuf_advance_get_idx(struct mqtt_ringbuf_t *rb, u16_t len) LWIP_ASSERT("mqtt_ringbuf_advance_get_idx: len < MQTT_OUTPUT_RINGBUF_SIZE", len < MQTT_OUTPUT_RINGBUF_SIZE); rb->get += len; - if (rb->get > MQTT_OUTPUT_RINGBUF_SIZE) { + if (rb->get >= MQTT_OUTPUT_RINGBUF_SIZE) { rb->get = rb->get - MQTT_OUTPUT_RINGBUF_SIZE; } }