Bug fixing

Author: mirkosertic

lib/lpfuart/src/lumpparser.cpp

@@ -82,9 +82,20 @@ void LumpParser::feedByte(uint8_t byte) {
 }
 
 void LumpParser::feedBytes(const uint8_t *data, int len) {
+    // Add all bytes to the ring buffer first, then process once.
+    // This ensures onDataFrameDispatched() fires only after the last
+    // frame in the batch (count_ == 0), not after each individual frame.
     for (int i = 0; i < len; i++) {
-        feedByte(data[i]);
+        if (count_ >= ringBufSize) {
+            stats_.bufferOverflows++;
+            head_ = (head_ + 1) % ringBufSize;
+            count_--;
+        }
+        uint16_t tail = (head_ + count_) % ringBufSize;
+        buf_[tail] = data[i];
+        count_++;
     }
+    processBuffer();
 }
 
 auto LumpParser::stats() const -> const LumpParserStats & {

test/test_lumpparser/test_main.cpp

@@ -376,7 +376,20 @@ class LumpParserT {
     }
 
     void feedBytes(const uint8_t *data, int len) {
-        for (int i = 0; i < len; i++) feedByte(data[i]);
+        // Pre-load all bytes into the ring buffer, then process once.
+        // This ensures onDataFrameDispatched() fires only after the last
+        // frame in the batch (count_ == 0), not after each individual frame.
+        for (int i = 0; i < len; i++) {
+            if (count_ >= RING_BUF_SIZE) {
+                stats_.bufferOverflows++;
+                head_  = (head_ + 1) % RING_BUF_SIZE;
+                count_--;
+            }
+            uint16_t tail = (head_ + count_) % RING_BUF_SIZE;
+            buf_[tail] = data[i];
+            count_++;
+        }
+        processBuffer();
     }
 
     const LumpParserStats &stats() const { return stats_; }