Fixed circular buffer resizing bug.

1 files changed, 20 insertions, 16 deletions

diff --git a/src/rt/circular_buffer.cpp b/src/rt/circular_buffer.cpp
index 0e1979c1..415a966b 100644
--- a/src/rt/circular_buffer.cpp
+++ b/src/rt/circular_buffer.cpp
@@ -7,7 +7,7 @@
 circular_buffer::circular_buffer(rust_dom *dom, size_t unit_sz) :
     dom(dom),
     _buffer_sz(INITIAL_CIRCULAR_BUFFFER_SIZE_IN_UNITS * unit_sz),
-    unit_sz(unit_sz),
+    _unit_sz(unit_sz),
     _next(0),
     _unread(0),
     _buffer((uint8_t *)dom->calloc(_buffer_sz)) {
@@ -27,7 +27,7 @@ circular_buffer::~circular_buffer() {
              "~circular_buffer 0x%" PRIxPTR,
              this);
     I(dom, _buffer);
-    // I(dom, unread == 0);
+    // I(dom, _unread == 0);
     dom->free(_buffer);
 }
 
@@ -38,8 +38,8 @@ void
 circular_buffer::transfer(void *dst) {
     I(dom, dst);
     uint8_t *ptr = (uint8_t *) dst;
-    for (size_t i = 0; i < _unread; i += unit_sz) {
-        memcpy(&ptr[i], &_buffer[_next + i % _buffer_sz], unit_sz);
+    for (size_t i = 0; i < _unread; i += _unit_sz) {
+        memcpy(&ptr[i], &_buffer[(_next + i) % _buffer_sz], _unit_sz);
     }
 }
 
@@ -65,15 +65,15 @@ circular_buffer::enqueue(void *src) {
     dom->log(rust_log::MEM | rust_log::COMM,
              "circular_buffer enqueue "
              "unread: %d, buffer_sz: %d, unit_sz: %d",
-             _unread, _buffer_sz, unit_sz);
+             _unread, _buffer_sz, _unit_sz);
 
     I(dom, _unread < _buffer_sz);
-    I(dom, _unread + unit_sz <= _buffer_sz);
+    I(dom, _unread + _unit_sz <= _buffer_sz);
 
     // Copy data
     size_t i = (_next + _unread) % _buffer_sz;
-    memcpy(&_buffer[i], src, unit_sz);
-    _unread += unit_sz;
+    memcpy(&_buffer[i], src, _unit_sz);
+    _unread += _unit_sz;
 
     dom->log(rust_log::MEM | rust_log::COMM,
              "circular_buffer pushed data at index: %d", i);
@@ -86,30 +86,34 @@ circular_buffer::enqueue(void *src) {
 void
 circular_buffer::dequeue(void *dst) {
     I(dom, dst);
-    I(dom, unit_sz > 0);
-    I(dom, _unread >= unit_sz);
+    I(dom, _unit_sz > 0);
+    I(dom, _unread >= _unit_sz);
     I(dom, _unread <= _buffer_sz);
     I(dom, _buffer);
-    size_t i = _next;
-    memcpy(dst, &_buffer[i], unit_sz);
+
+    memcpy(dst, &_buffer[_next], _unit_sz);
     dom->log(rust_log::MEM | rust_log::COMM,
-             "shifted data from index %d", i);
-    _unread -= unit_sz;
-    _next += unit_sz;
+             "shifted data from index %d", _next);
+    _unread -= _unit_sz;
+    _next += _unit_sz;
     I(dom, _next <= _buffer_sz);
     if (_next == _buffer_sz) {
         _next = 0;
     }
 
     // Shrink if possible.
-    if (_buffer_sz >= INITIAL_CIRCULAR_BUFFFER_SIZE_IN_UNITS * unit_sz &&
+    if (_buffer_sz >= INITIAL_CIRCULAR_BUFFFER_SIZE_IN_UNITS * _unit_sz &&
         _unread <= _buffer_sz / 4) {
+        dom->log(rust_log::MEM | rust_log::COMM,
+                 "circular_buffer is shrinking to %d bytes", _buffer_sz / 2);
         void *tmp = dom->malloc(_buffer_sz / 2);
         transfer(tmp);
         _buffer_sz >>= 1;
         dom->free(_buffer);
         _buffer = (uint8_t *)tmp;
+        _next = 0;
     }
+
 }
 
 bool