added global block config for buffer affinity

2 files changed, 7 insertions, 0 deletions

diff --git a/lib/block_handlers.cpp b/lib/block_handlers.cpp
index 1366e68..ad0d721 100644
--- a/lib/block_handlers.cpp
+++ b/lib/block_handlers.cpp
@@ -123,6 +123,12 @@ void BlockActor::handle_top_config(
         }
     }
 
+    //overwrite with global node affinity setting for buffers if not set
+    if (this->buffer_affinity == -1)
+    {
+        this->buffer_affinity = message.buffer_affinity;
+    }
+
     this->Send(0, from); //ACK
 }
 
diff --git a/lib/top_block.cpp b/lib/top_block.cpp
index 4973b59..bcce1bf 100644
--- a/lib/top_block.cpp
+++ b/lib/top_block.cpp
@@ -23,6 +23,7 @@ using namespace gnuradio;
 GlobalBlockConfig::GlobalBlockConfig(void)
 {
     maximum_output_items = 0;
+    buffer_affinity = -1;
 }
 
 TopBlock::TopBlock(void)