aboutsummaryrefslogtreecommitdiffstats
path: root/host/lib/usrp/common/io_service_mgr.cpp
diff options
context:
space:
mode:
authorCiro Nishiguchi <ciro.nishiguchi@ni.com>2019-11-07 16:19:01 -0600
committerMartin Braun <martin.braun@ettus.com>2019-11-26 12:21:33 -0800
commit837b89e2ec6be2735cede0a8ecc55caeff302b7f (patch)
treea656c22bb85e9227b14723b511de31a327c65fbf /host/lib/usrp/common/io_service_mgr.cpp
parent16c2bea50d0dfe5d2439a73baac5b0dde9b5634f (diff)
downloaduhd-837b89e2ec6be2735cede0a8ecc55caeff302b7f.tar.gz
uhd-837b89e2ec6be2735cede0a8ecc55caeff302b7f.tar.bz2
uhd-837b89e2ec6be2735cede0a8ecc55caeff302b7f.zip
rfnoc: Rename thread affinity args
Rename thread affinity args such that they do not end with an integer. Arg names ending with an integer are interpreted as being targeted at a specific motherboard index in device_addr methods.
Diffstat (limited to 'host/lib/usrp/common/io_service_mgr.cpp')
-rw-r--r--host/lib/usrp/common/io_service_mgr.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/host/lib/usrp/common/io_service_mgr.cpp b/host/lib/usrp/common/io_service_mgr.cpp
index 437d77423..707618c11 100644
--- a/host/lib/usrp/common/io_service_mgr.cpp
+++ b/host/lib/usrp/common/io_service_mgr.cpp
@@ -247,13 +247,13 @@ io_service::sptr blocking_io_service_mgr::_create_new_io_service(
? offload_io_service::RECV_ONLY
: offload_io_service::SEND_ONLY;
- const auto& cpu_vtr = (link_type == link_type_t::RX_DATA)
+ const auto& cpu_map = (link_type == link_type_t::RX_DATA)
? args.recv_offload_thread_cpu
: args.send_offload_thread_cpu;
std::string cpu_affinity_str;
- if (cpu_vtr.size() > thread_index && cpu_vtr[thread_index]) {
- const size_t cpu = *cpu_vtr[thread_index];
+ if (cpu_map.count(thread_index) != 0) {
+ const size_t cpu = cpu_map.at(thread_index);
params.cpu_affinity_list = {cpu};
cpu_affinity_str = ", cpu affinity: " + std::to_string(cpu);
} else {
@@ -381,11 +381,11 @@ io_service::sptr polling_io_service_mgr::_create_new_io_service(
params.client_type = offload_io_service::BOTH_SEND_AND_RECV;
params.wait_mode = offload_io_service::POLL;
- const auto& cpu_vtr = args.poll_offload_thread_cpu;
+ const auto& cpu_map = args.poll_offload_thread_cpu;
std::string cpu_affinity_str;
- if (cpu_vtr.size() > thread_index && cpu_vtr[thread_index]) {
- const size_t cpu = *cpu_vtr[thread_index];
+ if (cpu_map.count(thread_index) != 0) {
+ const size_t cpu = cpu_map.at(thread_index);
params.cpu_affinity_list = {cpu};
cpu_affinity_str = ", cpu affinity: " + std::to_string(cpu);
} else {