diff options
| author | Josh Blum | 2012-11-21 21:11:31 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-11-21 21:11:31 -0800 |
| commit | 8cf5baeac93a2c8e908126055ba0c96f2bfd2510 (patch) | |
| tree | e9e55391af382b22706a8d0510474f3aad6daaed /lib/input_handlers.cpp | |
| parent | 6d4c752aa0aaf41d7e764dbd81708f343a38c650 (diff) | |
| download | sandhi-8cf5baeac93a2c8e908126055ba0c96f2bfd2510.tar.gz sandhi-8cf5baeac93a2c8e908126055ba0c96f2bfd2510.tar.bz2 sandhi-8cf5baeac93a2c8e908126055ba0c96f2bfd2510.zip | |
implement buffer stitching on input, output always flushes
Diffstat (limited to 'lib/input_handlers.cpp')
| -rw-r--r-- | lib/input_handlers.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/input_handlers.cpp b/lib/input_handlers.cpp index 74ed8da..0069f5b 100644 --- a/lib/input_handlers.cpp +++ b/lib/input_handlers.cpp @@ -13,6 +13,7 @@ void BlockActor::handle_input_tag(const InputTagMessage &message, const Theron:: //handle incoming stream tag, push into the tag storage this->input_tags[index].push_back(message.tag); this->input_tags_changed[index] = true; + this->handle_task(); } void BlockActor::handle_input_buffer(const InputBufferMessage &message, const Theron::Address) |