partially revert 4e970cd

Author: bknueven

mpisppy/extensions/cross_scen_extension.py

@@ -126,11 +126,11 @@ def _check_bound(self):
             cached_ph_obj[k].activate()
 
     def get_from_cross_cuts(self):
-        # self.opt.spcomm.get_receive_buffer(
-        #     self.cuts,
-        #     Field.CROSS_SCENARIO_CUT,
-        #     self.cross_scenario_index,
-        # )
+        self.opt.spcomm.get_receive_buffer(
+            self.cuts,
+            Field.CROSS_SCENARIO_CUT,
+            self.cross_scenario_index,
+        )
         if self.cuts.is_new():
             self.make_cuts(self.cuts.array())
 

mpisppy/extensions/reduced_costs_fixer.py

@@ -118,16 +118,16 @@ def sync_with_spokes(self, pre_iter0 = False):
         # NOTE: If we do this, then the heuristic reduced cost fixing might fix
         #       different variables in different subproblems. But this might be
         #       fine.
-        # self.opt.spcomm.get_receive_buffer(
-        #     self.reduced_cost_buf,
-        #     Field.EXPECTED_REDUCED_COST,
-        #     self.reduced_costs_spoke_index,
-        # )
-        # self.opt.spcomm.get_receive_buffer(
-        #     self.outer_bound_buf,
-        #     Field.OBJECTIVE_OUTER_BOUND,
-        #     self.reduced_costs_spoke_index,
-        # )
+        self.opt.spcomm.get_receive_buffer(
+            self.reduced_cost_buf,
+            Field.EXPECTED_REDUCED_COST,
+            self.reduced_costs_spoke_index,
+        )
+        self.opt.spcomm.get_receive_buffer(
+            self.outer_bound_buf,
+            Field.OBJECTIVE_OUTER_BOUND,
+            self.reduced_costs_spoke_index,
+        )
         if self.reduced_cost_buf.is_new() and self.reduced_cost_buf.id() == self.outer_bound_buf.id():
             reduced_costs = self.reduced_cost_buf.value_array()
             this_outer_bound = self.outer_bound_buf.value_array()[0]

mpisppy/extensions/reduced_costs_rho.py

@@ -54,11 +54,11 @@ def register_receive_fields(self):
         )
 
     def sync_with_spokes(self):
-        # self.opt.spcomm.get_receive_buffer(
-        #     self.scenario_reduced_cost_buf,
-        #     Field.SCENARIO_REDUCED_COST,
-        #     self.reduced_costs_spoke_index,
-        # )
+        self.opt.spcomm.get_receive_buffer(
+            self.scenario_reduced_cost_buf,
+            Field.SCENARIO_REDUCED_COST,
+            self.reduced_costs_spoke_index,
+        )
         if self.scenario_reduced_cost_buf.is_new():
             self._scenario_rc_buffer[:] = self.scenario_reduced_cost_buf.value_array()
             # print(f"In ReducedCostsRho; {self._scenario_rc_buffer=}")