summaryrefslogtreecommitdiff
path: root/lib/block_task.cpp
diff options
context:
space:
mode:
authorJosh Blum2012-12-15 09:53:25 -0800
committerJosh Blum2012-12-15 09:53:25 -0800
commitb7c0a59c0a86f289f55935b19efaf448e892eefb (patch)
tree1e641f9816237481124835ac2fbf2792a8b1d50f /lib/block_task.cpp
parent6a03c661ede88203ff90eb01bf1e678b87cb6056 (diff)
downloadsandhi-b7c0a59c0a86f289f55935b19efaf448e892eefb.tar.gz
sandhi-b7c0a59c0a86f289f55935b19efaf448e892eefb.tar.bz2
sandhi-b7c0a59c0a86f289f55935b19efaf448e892eefb.zip
work on the buffer queue api
Diffstat (limited to 'lib/block_task.cpp')
-rw-r--r--lib/block_task.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 9e5917d..6b18798 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -31,9 +31,6 @@ void BlockActor::mark_done(void)
//release upstream, downstream, and executor tokens
this->token_pool.clear();
- //release allocator tokens, buffers can now call deleters
- this->output_buffer_tokens.clear();
-
//release all buffers in queues
this->input_queues.flush_all();
this->output_queues.flush_all();
@@ -156,7 +153,8 @@ void BlockActor::handle_task(void)
this->input_items.max() = std::max(this->input_items.max(), items);
//inline dealings, how and when input buffers can be inlined into output buffers
- //continue;
+ continue; //FIXME to implement needs change
+ /*
if (
buff.unique() and
input_configs[i].inline_buffer and
@@ -170,6 +168,7 @@ void BlockActor::handle_task(void)
this->output_queues.push_front(output_inline_index, new_obuff); //you got inlined!
output_inline_index++; //done do this output port again
}
+ */
}
//------------------------------------------------------------------