Skip to content

Commit

Permalink
fix for 1590313, 1590213, 1588539, 1588497, 1588220
Browse files Browse the repository at this point in the history
  • Loading branch information
wangleis committed Jan 20, 2025
1 parent f935476 commit c0008c2
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ class OPENVINO_RUNTIME_API IStreamsExecutor : virtual public ITaskExecutor {
_cpu_pinning{cpu_pinning},
_cores_limit{cores_limit},
_streams_info_table{std::move(streams_info_table)},
_rank{rank},
_rank{std::move(rank)},
_add_lock(add_lock) {
update_executor_config(_add_lock);
}
Expand Down
4 changes: 2 additions & 2 deletions src/inference/src/dev/threading/cpu_streams_executor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ struct CPUStreamsExecutor::Impl {
: custom::task_scheduler_observer(arena),
_mask{std::move(mask)},
_ncpus(ncpus),
_cpu_ids(cpu_ids) {}
_cpu_ids(std::move(cpu_ids)) {}
void on_scheduler_entry(bool) override {
pin_thread_to_vacant_core(tbb::this_task_arena::current_thread_index(),
_threadBindingStep,
Expand Down Expand Up @@ -167,7 +167,7 @@ struct CPUStreamsExecutor::Impl {
_rank = _impl->_config.get_rank();
get_cur_stream_info(stream_id,
_impl->_config.get_cpu_pinning(),
org_proc_type_table,
std::move(org_proc_type_table),
_impl->_config.get_streams_info_table(),
stream_type,
concurrency,
Expand Down
2 changes: 1 addition & 1 deletion src/inference/src/dev/threading/istreams_executor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ void IStreamsExecutor::Config::update_executor_config() {
if (_thread_preferred_core_type == ov::hint::SchedulingCoreType::ECORE_ONLY) {
stream_info[PROC_TYPE] = EFFICIENT_CORE_PROC;
stream_info[NUMBER_OF_STREAMS] = _streams;
_streams_info_table.push_back(stream_info);
_streams_info_table.push_back(std::move(stream_info));
} else {
int start = proc_type_table.size() > 1 ? 1 : 0;
std::vector<int> core_types;
Expand Down
6 changes: 3 additions & 3 deletions src/plugins/intel_cpu/src/cpu_streams_calculation.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,7 @@ std::vector<std::vector<int>> get_streams_info_table(
ALL_PROC);
} else if (stream_info[PROC_TYPE] == MAIN_CORE_PROC) {
if (stream_info[THREADS_PER_STREAM] == proc_socket_table[0][MAIN_CORE_PROC]) {
streams_info_table.push_back(stream_info);
streams_info_table.push_back(std::move(stream_info));
} else {
stream_info[PROC_TYPE] = ALL_PROC;
streams_info_table.push_back(stream_info);
Expand All @@ -524,10 +524,10 @@ std::vector<std::vector<int>> get_streams_info_table(
streams_info_table.push_back(stream_info);
stream_info[PROC_TYPE] = HYPER_THREADING_PROC;
stream_info[THREADS_PER_STREAM] = proc_socket_table[0][HYPER_THREADING_PROC];
streams_info_table.push_back(stream_info);
streams_info_table.push_back(std::move(stream_info));
}
} else {
streams_info_table.push_back(stream_info);
streams_info_table.push_back(std::move(stream_info));
}
}

Expand Down

0 comments on commit c0008c2

Please sign in to comment.