diff options
| author | Josh Blum | 2012-11-21 20:15:06 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-11-21 20:15:06 -0800 |
| commit | 6d4c752aa0aaf41d7e764dbd81708f343a38c650 (patch) | |
| tree | 0f631463320fa6e0780e4b06f1731d886e760975 /lib/block_task.cpp | |
| parent | fc2d9cf48d9d09ee42d817ab14ec0146474630c7 (diff) | |
| download | sandhi-6d4c752aa0aaf41d7e764dbd81708f343a38c650.tar.gz sandhi-6d4c752aa0aaf41d7e764dbd81708f343a38c650.tar.bz2 sandhi-6d4c752aa0aaf41d7e764dbd81708f343a38c650.zip | |
guard against empty consumes
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 1a6c447..a0d4ba8 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -229,6 +229,7 @@ void BlockActor::handle_task(void) void BlockActor::consume(const size_t i, const size_t items) { + if (items == 0) return; this->items_consumed[i] += items; const size_t bytes = items*this->input_items_sizes[i]; this->input_queues.consume(i, bytes); |