diff options
Diffstat (limited to 'lib/input_handlers.cpp')
| -rw-r--r-- | lib/input_handlers.cpp | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/lib/input_handlers.cpp b/lib/input_handlers.cpp index 02f62f3..f6a81bc 100644 --- a/lib/input_handlers.cpp +++ b/lib/input_handlers.cpp @@ -66,8 +66,21 @@ void BlockActor::handle_input_alloc(const InputAllocMessage &message, const Ther //handle the upstream block allocation request OutputAllocMessage new_msg; - new_msg.token = block_ptr->input_buffer_allocator( + new_msg.queue = block_ptr->input_buffer_allocator( index, message.token, message.recommend_length ); - if (new_msg.token) this->post_upstream(index, new_msg); + if (new_msg.queue) this->post_upstream(index, new_msg); +} + +void BlockActor::handle_input_update(const InputUpdateMessage &message, const Theron::Address) +{ + MESSAGE_TRACER(); + const size_t i = message.index; + + //update buffer queue configuration + if (i >= this->input_queues.size()) return; + const size_t preload_bytes = this->input_items_sizes[i]*this->input_configs[i].preload_items; + const size_t reserve_bytes = this->input_items_sizes[i]*this->input_configs[i].reserve_items; + const size_t maximum_bytes = this->input_items_sizes[i]*this->input_configs[i].maximum_items; + this->input_queues.update_config(i, this->input_items_sizes[i], preload_bytes, reserve_bytes, maximum_bytes); } |