diff options
author | Ciro Nishiguchi <ciro.nishiguchi@ni.com> | 2019-11-07 16:19:01 -0600 |
---|---|---|
committer | Martin Braun <martin.braun@ettus.com> | 2019-11-26 12:21:33 -0800 |
commit | 837b89e2ec6be2735cede0a8ecc55caeff302b7f (patch) | |
tree | a656c22bb85e9227b14723b511de31a327c65fbf /host/lib/usrp/common/io_service_mgr.cpp | |
parent | 16c2bea50d0dfe5d2439a73baac5b0dde9b5634f (diff) | |
download | uhd-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.cpp | 12 |
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 { |