|
|
@ -251,20 +251,6 @@ _calculate_thread_counts(int *read_thread_count_, |
|
|
|
*process_thread_queue_depth_ *= *process_thread_count_; |
|
|
|
} |
|
|
|
|
|
|
|
static |
|
|
|
void |
|
|
|
pin_threads_R1L(const CPU::ThreadIdVec read_threads_) |
|
|
|
{ |
|
|
|
CPU::CPUVec cpus; |
|
|
|
|
|
|
|
cpus = CPU::cpus(); |
|
|
|
if(cpus.empty()) |
|
|
|
return; |
|
|
|
|
|
|
|
for(auto const thread_id : read_threads_) |
|
|
|
CPU::setaffinity(thread_id,cpus.front()); |
|
|
|
} |
|
|
|
|
|
|
|
static |
|
|
|
void |
|
|
|
pin_threads_R1P(const CPU::ThreadIdVec read_threads_) |
|
|
|