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()); } + if (input.contains("numa_policy")) { + service.NUMAPolicy(input["numa_policy"].get()); + logger.Info("NUMA policy {}", input["numa_policy"].get()); + } + if (input.contains("send_buffer_count")) { service.SendBufferCount(input["send_buffer_count"].get()); logger.Info("Send buffer count {}", input["send_buffer_count"].get());