diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/block_task.cpp | 2 | ||||
| -rw-r--r-- | lib/gras_impl/input_buffer_queues.hpp | 2 |
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 |