diff options
| author | Josh Blum | 2012-12-01 00:34:27 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-12-01 00:34:27 -0800 |
| commit | f38298e9e5d930a16d27b3e2ef12931a7eff52eb (patch) | |
| tree | bca743e2f3a4ed3c9cb6ece31850c6421da6c763 /lib/block_task.cpp | |
| parent | 0dea1563a4e13bd6081acc2ed5f4c611bdfbb9af (diff) | |
| download | sandhi-f38298e9e5d930a16d27b3e2ef12931a7eff52eb.tar.gz sandhi-f38298e9e5d930a16d27b3e2ef12931a7eff52eb.tar.bz2 sandhi-f38298e9e5d930a16d27b3e2ef12931a7eff52eb.zip | |
mark fail: not ready until a new buffer appears
Diffstat (limited to 'lib/block_task.cpp')
| -rw-r--r-- | lib/block_task.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index b2b08db..9e5917d 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -79,6 +79,9 @@ void BlockActor::input_fail(const size_t i) { throw std::runtime_error("input_fail called on maximum_items buffer"); } + + //mark fail: not ready until a new buffer appears + this->input_queues.fail(i); } void BlockActor::output_fail(const size_t i) |