gras: more debug assers to aid sanity

2 files changed, 4 insertions, 0 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 4d85aaf..2509925 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -241,6 +241,7 @@ void BlockActor::produce(const size_t i, const size_t items)
     std::cerr << name << " produce " << items << std::endl;
     #endif
     SBuffer &buff = this->output_queues.front(i);
+    ASSERT((buff.length % output_configs[i].item_size) == 0);
     this->stats.items_produced[i] += items;
     const size_t bytes = items*this->output_configs[i].item_size;
     buff.length += bytes;
@@ -250,6 +251,7 @@ void BlockActor::produce(const size_t i, const size_t items)
 void BlockActor::produce_buffer(const size_t i, const SBuffer &buffer)
 {
     this->flush_output(i);
+    ASSERT((buffer.length % output_configs[i].item_size) == 0);
     const size_t items = buffer.length/output_configs[i].item_size;
     this->stats.items_produced[i] += items;
     InputBufferMessage buff_msg;
diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp
index 0db5cb4..0a85045 100644
--- a/lib/gras_impl/input_buffer_queues.hpp
+++ b/lib/gras_impl/input_buffer_queues.hpp
@@ -175,6 +175,7 @@ inline void InputBufferQueues::update_config(
     const size_t maximum_bytes
 )
 {
+    ASSERT(item_size != 0);
     _items_sizes[i] = item_size;
 
     //first allocate the aux buffer
@@ -293,6 +294,7 @@ GRAS_FORCE_INLINE void InputBufferQueues::consume(const size_t i, const size_t b
     if (bytes_consumed == 0) return;
 
     ASSERT(not _queues[i].empty());
+    ASSERT((bytes_consumed % _items_sizes[i]) == 0);
     SBuffer &front = _queues[i].front();
 
     //assert that we dont consume past the bounds of the buffer