@@ -29,6 +29,9 @@ std::string writeTemperedLBConfig(std::string transfer_strategy,
29
29
if (mem_constraints) {
30
30
cfg_file_ << " memory_threshold=20.0" ;
31
31
}
32
+ if (transfer_strategy == " SwapClusters" ) {
33
+ cfg_file_ << " rollback=false" ;
34
+ }
32
35
cfg_file_.close ();
33
36
}
34
37
return config_file;
@@ -37,7 +40,6 @@ std::string writeTemperedLBConfig(std::string transfer_strategy,
37
40
void runTemperedLBTest (std::string config_file, double expected_imb = 0.0 ) {
38
41
// Set configuration
39
42
theConfig ()->vt_lb = true ;
40
- theConfig ()->vt_lb_name = " TemperedLB" ;
41
43
theConfig ()->vt_lb_data_in = true ;
42
44
theConfig ()->vt_lb_file_name = config_file;
43
45
theConfig ()->vt_lb_data_file_in =" synthetic-dataset-blocks.%p.json" ;
@@ -54,8 +56,7 @@ void runTemperedLBTest(std::string config_file, double expected_imb = 0.0) {
54
56
auto phase_info = theLBManager ()->getPhaseInfo ();
55
57
56
58
// Assert that temperedLB found the correct imbalance
57
- auto imb = (phase_info->max_load / phase_info->avg_load ) - 1 ;
58
- EXPECT_EQ (imb, expected_imb);
59
+ EXPECT_EQ (phase_info->imb_load_post_lb , expected_imb);
59
60
60
61
// Clear the LB config ahead of next test
61
62
vrt::collection::balance::ReadLBConfig::clear ();
@@ -78,7 +79,7 @@ TEST_F(TestTemperedLB, test_load_memory_homing_swapclusters) {
78
79
79
80
TEST_F (TestTemperedLB, test_load_memory_homing_comms) {
80
81
auto cfg = writeTemperedLBConfig (" SwapClusters" , true , 1.0 , 1.0 );
81
- double expected_imbalance = 0.25 ; // placeholder for value from MILP
82
+ double expected_imbalance = 0.0 ; // placeholder for value from MILP
82
83
runTemperedLBTest (cfg, expected_imbalance);
83
84
}
84
85
0 commit comments