mx/Jungfraujoch
0
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases 37 Wiki Activity

jfjoch_receiver: Allow to set NUMA policy

Browse Source
This commit is contained in:
leonarski_f
2023-09-20 14:28:24 +02:00
parent 494ccba73d
commit 784b1f41ed
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
etc/recv.json
View File

@@ -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"
}

5
receiver/jfjoch_receiver.cpp
View File

@@ -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>());