Skip to content

Commit

Permalink
#1024: Fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
JacobDomagala committed Sep 22, 2020
1 parent 2cd870f commit 9f3d0d2
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 6 deletions.
6 changes: 4 additions & 2 deletions src/vt/vrt/collection/manager.h
Original file line number Diff line number Diff line change
Expand Up @@ -916,7 +916,8 @@ struct CollectionManager
*/
template <
typename MsgT,
ActiveColTypedFnType<MsgT,typename MsgT::CollectionType> *f>
ActiveColTypedFnType<MsgT,typename MsgT::CollectionType> *f
>
messaging::PendingSend broadcastMsgCollective(
CollectionProxyWrapType<typename MsgT::CollectionType> const& proxy,
MsgT* msg, bool instrument = true);
Expand All @@ -933,7 +934,8 @@ struct CollectionManager
*/
template <
typename MsgT,
ActiveColMemberTypedFnType<MsgT, typename MsgT::CollectionType> f>
ActiveColMemberTypedFnType<MsgT, typename MsgT::CollectionType> f
>
messaging::PendingSend broadcastMsgCollective(
CollectionProxyWrapType<typename MsgT::CollectionType> const& proxy,
MsgT* msg, bool instrument = true);
Expand Down
11 changes: 7 additions & 4 deletions src/vt/vrt/collection/manager.impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -874,7 +874,8 @@ messaging::PendingSend CollectionManager::broadcastMsgCollective(
using ColT = typename MsgT::CollectionType;

msg->setVrtHandler(
auto_registry::makeAutoHandlerCollectionMem<ColT, MsgT, f>());
auto_registry::makeAutoHandlerCollectionMem<ColT, MsgT, f>()
);
msg->setMember(true);

return broadcastMsgCollectiveImpl<MsgT, ColT>(proxy, msg, instrument);
Expand All @@ -898,7 +899,8 @@ messaging::PendingSend CollectionManager::broadcastMsgCollectiveImpl(
auto_registry::RegistryTypeEnum::RegVrtCollection;
auto msg_size = vt::serialization::MsgSizer<MsgT>::get(msg.get());
auto event = theMsg()->makeTraceCreationSend(
msg, msg->getVrtHandler(), reg_type, msg_size, true);
msg, msg->getVrtHandler(), reg_type, msg_size, true
);
msg->setFromTraceEvent(event);
#endif

Expand All @@ -910,7 +912,7 @@ messaging::PendingSend CollectionManager::broadcastMsgCollectiveImpl(
theMsg()->setupEpochMsg(msg);

return messaging::PendingSend(
msg, [proxy](MsgSharedPtr<BaseMsgType>& msgIn) {
msg, [proxy](MsgSharedPtr<BaseMsgType>& msgIn){
auto col_msg = reinterpret_cast<MsgT*>(msgIn.get());

auto elm_holder = theCollection()->findElmHolder<ColT, IndexT>(proxy);
Expand All @@ -920,7 +922,8 @@ messaging::PendingSend CollectionManager::broadcastMsgCollectiveImpl(
theMsg()->markAsCollectionMessage(col_msg);

collectionBcastHandler<ColT, IndexT, MsgT>(col_msg);
});
}
);
}

template <
Expand Down

0 comments on commit 9f3d0d2

Please sign in to comment.