Skip to content

Commit

Permalink
#1672: lb: move CommMsg to baselb messages
Browse files Browse the repository at this point in the history
  • Loading branch information
cz4rs committed May 31, 2022
1 parent e68ed98 commit f787829
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 16 deletions.
16 changes: 0 additions & 16 deletions src/vt/vrt/collection/balance/baselb/baselb.h
Original file line number Diff line number Diff line change
Expand Up @@ -179,22 +179,6 @@ struct BaseLB {
std::shared_ptr<balance::Reassignment> pending_reassignment_ = nullptr;
};

struct CommMsg : vt::Message {
using MessageParentType = vt::Message;
vt_msg_serialize_required();

CommMsg() = default;
explicit CommMsg(lb::BaseLB::ElementCommType in_comm) : comm_(in_comm) { }

lb::BaseLB::ElementCommType comm_;

template <typename SerializerT>
void serialize(SerializerT& s) {
MessageParentType::serialize(s);
s | comm_;
}
};

}}}} // namespace vt::vrt::collection::lb

#endif /*INCLUDED_VT_VRT_COLLECTION_BALANCE_BASELB_BASELB_H*/
16 changes: 16 additions & 0 deletions src/vt/vrt/collection/balance/baselb/baselb_msgs.h
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,22 @@ struct CountMsg : vt::collective::ReduceTMsg<int32_t> {
{}
};

struct CommMsg : vt::Message {
using MessageParentType = vt::Message;
vt_msg_serialize_required();

CommMsg() = default;
explicit CommMsg(elm::CommMapType const& in_comm) : comm_(in_comm) { }

elm::CommMapType comm_;

template <typename SerializerT>
void serialize(SerializerT& s) {
MessageParentType::serialize(s);
s | comm_;
}
};

}}}} /* end namespace vt::vrt::collection::lb */

#endif /*INCLUDED_VT_VRT_COLLECTION_BALANCE_BASELB_BASELB_MSGS_H*/

0 comments on commit f787829

Please sign in to comment.