diff options
| author | Josh Blum | 2012-11-22 21:32:20 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-11-22 21:32:20 -0800 |
| commit | 784e7dcf40bd3502f228fbc59d023c49110cd09f (patch) | |
| tree | c47b4164e9c4cabf424a899fa0ca64e218b509c1 /lib/block_task.cpp | |
| parent | 284252b1b34c93b6eb2b4344eee285415b96887a (diff) | |
| download | sandhi-784e7dcf40bd3502f228fbc59d023c49110cd09f.tar.gz sandhi-784e7dcf40bd3502f228fbc59d023c49110cd09f.tar.bz2 sandhi-784e7dcf40bd3502f228fbc59d023c49110cd09f.zip | |
extra asserts for sign on consume/produce
Diffstat (limited to 'lib/block_task.cpp')
| -rw-r--r-- | lib/block_task.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index 192ea40..7f40f47 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -163,6 +163,7 @@ void BlockActor::handle_task(void) { ASSERT(this->output_queues.ready(i)); SBuffer &buff = this->output_queues.front(i); + ASSERT(buff.length == 0); //assumes it was flushed last call void *mem = buff.get(); const size_t bytes = buff.get_actual_length() - buff.offset; size_t items = bytes/this->output_items_sizes[i]; |