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

Enable DHT time measurement

Browse Source
This commit is contained in:
rastogi 2025-11-06 11:49:10 +01:00
parent b82054eed6
commit f4e846d6dc
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/Control/ControlModule.cpp
View File

@ -39,13 +39,13 @@ void poet::ControlModule::initiateWarmupPhase(bool dht_enabled,
chem->SetWarmupEnabled(true);
chem->SetDhtEnabled(false);
chem->SetInterpEnabled(false);
// MSG("Warmup enabled until next control interval at iteration " +
// std::to_string(control_interval) + ".");
MSG("Warmup enabled until next control interval at iteration " +
std::to_string(control_interval) + ".");
if (rollback_enabled) {
if (sur_disabled_counter > 0) {
--sur_disabled_counter;
//MSG("Rollback counter: " + std::to_string(sur_disabled_counter));
MSG("Rollback counter: " + std::to_string(sur_disabled_counter));
} else {
rollback_enabled = false;
}
@ -64,16 +64,17 @@ void poet::ControlModule::applyControlLogic(ChemistryModule &chem,
return;
}
writeCheckpointAndMetrics(chem, iter);
if (checkAndRollback(chem, iter) /* && rollback_count < 4*/) {
if (checkAndRollback(chem, iter) && rollback_count < 3) {
rollback_enabled = true;
rollback_count++;
sur_disabled_counter = control_interval;
/*
MSG("Interpolation disabled for the next " +
std::to_string(control_interval) + ".");
*/
}
}
void poet::ControlModule::writeCheckpointAndMetrics(ChemistryModule &chem,

4
src/poet.cpp
View File

@ -439,13 +439,13 @@ static Rcpp::List RunMasterLoop(RInsidePOET &R, RuntimeParameters &params,
Rcpp::wrap(chem.GetWorkerControlTimings());
if (params.use_dht) {
//if (params.use_dht) {
chem_profiling["dht_hits"] = Rcpp::wrap(chem.GetWorkerDHTHits());
chem_profiling["dht_evictions"] = Rcpp::wrap(chem.GetWorkerDHTEvictions());
chem_profiling["dht_get_time"] = Rcpp::wrap(chem.GetWorkerDHTGetTimings());
chem_profiling["dht_fill_time"] =
Rcpp::wrap(chem.GetWorkerDHTFillTimings());
}
//}
if (params.use_interp) {
chem_profiling["interp_w"] =