Commit 7f051f8 1 parent 9789a48 commit 7f051f8 Copy full SHA for 7f051f8
File tree 2 files changed +13
-0
lines changed
src/vt/vrt/collection/balance
2 files changed +13
-0
lines changed Original file line number Diff line number Diff line change @@ -256,6 +256,18 @@ struct NodeLBData : runtime::component::Component<NodeLBData> {
256
256
*/
257
257
LBDataHolder* getLBData () { return lb_data_.get (); }
258
258
259
+ /* *
260
+ * \brief Set the LB data
261
+ *
262
+ * \note Used for replay
263
+ * \warning Squashes all the existing data!
264
+ *
265
+ * \param[in] lb_data LB data to override
266
+ */
267
+ void setLBData (LBDataHolder const & lb_data) {
268
+ lb_data_ = std::make_unique<LBDataHolder>(lb_data);
269
+ }
270
+
259
271
template <typename SerializerT>
260
272
void serialize (SerializerT& s) {
261
273
s | proxy_
Original file line number Diff line number Diff line change @@ -222,6 +222,7 @@ void replayWorkloads(
222
222
auto cb = theCB ()->makeFunc <ReassignmentMsg>(
223
223
vt::pipe ::LifetimeEnum::Once, postLBWork
224
224
);
225
+ theNodeLBData ()->setLBData (*workloads.get ());
225
226
theLBManager ()->selectStartLB (phase, cb);
226
227
});
227
228
runInEpochCollective (" WorkloadReplayDriver -> destroyLB" , [&] {
You can’t perform that action at this time.
0 commit comments