summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorJosh Blum2013-03-02 00:38:49 -0600
committerJosh Blum2013-03-02 00:38:49 -0600
commit77e829ec2b25844402c0781cb3f85ca8cfd8b182 (patch)
tree736348a7af706c9269c3740fcc2f29e8c833f21f /lib
parent556b1f2edf445d8c80e830e454b1ab8542ff14d3 (diff)
downloadsandhi-77e829ec2b25844402c0781cb3f85ca8cfd8b182.tar.gz
sandhi-77e829ec2b25844402c0781cb3f85ca8cfd8b182.tar.bz2
sandhi-77e829ec2b25844402c0781cb3f85ca8cfd8b182.zip
gras: copy name into queues for debug purposes
Diffstat (limited to 'lib')
-rw-r--r--lib/gras_impl/input_buffer_queues.hpp2
-rw-r--r--lib/gras_impl/output_buffer_queues.hpp1
-rw-r--r--lib/topology_handler.cpp4
3 files changed, 7 insertions, 0 deletions
diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp
index 0a85045..76e00a2 100644
--- a/lib/gras_impl/input_buffer_queues.hpp
+++ b/lib/gras_impl/input_buffer_queues.hpp
@@ -20,6 +20,8 @@ namespace gras
struct InputBufferQueues
{
+ std::string name; //for debug
+
enum {MAX_AUX_BUFF_BYTES=(1<<16)};
static SBuffer make_null_buff(void)
diff --git a/lib/gras_impl/output_buffer_queues.hpp b/lib/gras_impl/output_buffer_queues.hpp
index 3618b1b..deea0e1 100644
--- a/lib/gras_impl/output_buffer_queues.hpp
+++ b/lib/gras_impl/output_buffer_queues.hpp
@@ -12,6 +12,7 @@ namespace gras
struct OutputBufferQueues
{
+ std::string name; //for debug
void set_buffer_queue(const size_t i, BufferQueueSptr queue)
{
diff --git a/lib/topology_handler.cpp b/lib/topology_handler.cpp
index a3d7e6a..1696f27 100644
--- a/lib/topology_handler.cpp
+++ b/lib/topology_handler.cpp
@@ -49,6 +49,10 @@ void BlockActor::handle_topology(
this->produce_outputs.resize(num_outputs, false);
if (num_inputs == 0) this->inputs_available.resize(1, true); //so its always "available"
+ //copy the name into the queues for debug purposes
+ this->input_queues.name = this->name;
+ this->output_queues.name = this->name;
+
this->input_tokens.resize(num_inputs);
this->output_tokens.resize(num_outputs);
this->inputs_done.resize(num_inputs);