max/poet
1
0
Fork 0
mirror of https://git.gfz-potsdam.de/naaice/poet.git synced 2025-12-16 04:48:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Refactor WorkerRunWorkPackage to copy input instead of overwriting

Browse Source
This commit is contained in:
Max Luebke 2024-04-02 20:24:04 +00:00
parent 90287ab445
commit e380e8fd19
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/Chemistry/WorkerFunctions.cpp
View File

@ -288,22 +288,20 @@ void poet::ChemistryModule::WorkerRunWorkPackage(WorkPackage &work_package,
continue; continue;
} }
const auto &input = work_package.input[wp_id]; auto curr_input = work_package.input[wp_id];
const auto pqc_id = input[0]; const auto pqc_id = curr_input[0];
auto &phreeqc_instance = this->phreeqc_instances[pqc_id]; auto &phreeqc_instance = this->phreeqc_instances[pqc_id];
work_package.output[wp_id] = work_package.input[wp_id]; work_package.output[wp_id] = work_package.input[wp_id];
work_package.input[wp_id].erase(work_package.input[wp_id].begin()); curr_input.erase(curr_input.begin());
// remove NaNs from the input // remove NaNs from the input
work_package.input[wp_id].erase( curr_input.erase(std::remove_if(curr_input.begin(), curr_input.end(),
std::remove_if(work_package.input[wp_id].begin(), [](double d) { return std::isnan(d); }),
work_package.input[wp_id].end(), curr_input.end());
[](double d) { return std::isnan(d); }),
work_package.input[wp_id].end());
phreeqc_instance->queueCell(work_package.input[wp_id]); phreeqc_instance->queueCell(curr_input);
zone_mapping[pqc_id].push_back(wp_id); zone_mapping[pqc_id].push_back(wp_id);
} }