From 784b1f41edced9a71fe757eee3394f079ce7fffb Mon Sep 17 00:00:00 2001
From: Filip Leonarski <filip.leonarski@psi.ch>
Date: Wed, 20 Sep 2023 14:28:24 +0200
Subject: [PATCH] jfjoch_receiver: Allow to set NUMA policy

---
 etc/recv.json                | 3 ++-
 receiver/jfjoch_receiver.cpp | 5 +++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/etc/recv.json b/etc/recv.json
index f96f357f..5ba68c5b 100644
--- a/etc/recv.json
+++ b/etc/recv.json
@@ -31,5 +31,6 @@
                      "tcp://10.10.1.243:5405"],
   "preview_zmq_addr": "tcp://0.0.0.0:5400",
   "preview_indexed_zmq_addr": "tcp://0.0.0.0:5401",
-  "grpc_addr": "unix:/opt/jfjoch/.jfjoch-fpga-receiver"
+  "grpc_addr": "unix:/opt/jfjoch/.jfjoch-fpga-receiver",
+  "numa_policy": "n2g2"
 }
diff --git a/receiver/jfjoch_receiver.cpp b/receiver/jfjoch_receiver.cpp
index 6d8271fa..4350cc7c 100644
--- a/receiver/jfjoch_receiver.cpp
+++ b/receiver/jfjoch_receiver.cpp
@@ -162,6 +162,11 @@ int main(int argc, char **argv) {
         logger.Info("Compression threads {}", input["compression_threads"].get<int64_t>());
     }
 
+    if (input.contains("numa_policy")) {
+        service.NUMAPolicy(input["numa_policy"].get<std::string>());
+        logger.Info("NUMA policy {}", input["numa_policy"].get<std::string>());
+    }
+
     if (input.contains("send_buffer_count")) {
         service.SendBufferCount(input["send_buffer_count"].get<int64_t>());
         logger.Info("Send buffer count {}", input["send_buffer_count"].get<int64_t>());