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 ca1f8a19bb
commit 853888a19b
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;
}
const auto &input = work_package.input[wp_id];
const auto pqc_id = input[0];
auto curr_input = work_package.input[wp_id];
const auto pqc_id = curr_input[0];
auto &phreeqc_instance = this->phreeqc_instances[pqc_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
work_package.input[wp_id].erase(
std::remove_if(work_package.input[wp_id].begin(),
work_package.input[wp_id].end(),
[](double d) { return std::isnan(d); }),
work_package.input[wp_id].end());
curr_input.erase(std::remove_if(curr_input.begin(), curr_input.end(),
[](double d) { return std::isnan(d); }),
curr_input.end());
phreeqc_instance->queueCell(work_package.input[wp_id]);
phreeqc_instance->queueCell(curr_input);
zone_mapping[pqc_id].push_back(wp_id);
}