Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 08:41:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Require std::move when adding existing message to FairMQParts.

Browse Source
This commit is contained in:
Alexey Rybalchenko 2017-01-05 14:15:05 +01:00 committed by Mohammad Al-Turany
parent 65c19f07bf
commit ac1da4db66
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
fairmq/FairMQParts.h
View File

@ -41,10 +41,10 @@ class FairMQParts
/// Adds part (std::unique_ptr<FairMQMessage>&) to the container (move) /// Adds part (std::unique_ptr<FairMQMessage>&) to the container (move)
/// @param msg unique pointer to FairMQMessage /// @param msg unique pointer to FairMQMessage
/// lvalue ref (move not required when passing argument) /// lvalue ref (move not required when passing argument)
inline void AddPart(std::unique_ptr<FairMQMessage>& msg) // inline void AddPart(std::unique_ptr<FairMQMessage>& msg)
{ // {
fParts.push_back(std::move(msg)); // fParts.push_back(std::move(msg));
} // }
/// Adds part (std::unique_ptr<FairMQMessage>&) to the container (move) /// Adds part (std::unique_ptr<FairMQMessage>&) to the container (move)
/// @param msg unique pointer to FairMQMessage /// @param msg unique pointer to FairMQMessage

4
fairmq/devices/FairMQMultiplier.cxx
View File

@ -81,7 +81,7 @@ bool FairMQMultiplier::HandleMultipartData(FairMQParts& payload, int /*index*/)
{ {
FairMQMessagePtr msgCopy(fTransportFactory->CreateMessage()); FairMQMessagePtr msgCopy(fTransportFactory->CreateMessage());
msgCopy->Copy(payload.At(k)); msgCopy->Copy(payload.At(k));
parts.AddPart(msgCopy); parts.AddPart(std::move(msgCopy));
} }
Send(parts, fOutChannelNames.at(i), j); Send(parts, fOutChannelNames.at(i), j);
@ -98,7 +98,7 @@ bool FairMQMultiplier::HandleMultipartData(FairMQParts& payload, int /*index*/)
{ {
FairMQMessagePtr msgCopy(fTransportFactory->CreateMessage()); FairMQMessagePtr msgCopy(fTransportFactory->CreateMessage());
msgCopy->Copy(payload.At(k)); msgCopy->Copy(payload.At(k));
parts.AddPart(msgCopy); parts.AddPart(std::move(msgCopy));
} }
Send(parts, fOutChannelNames.back(), i); Send(parts, fOutChannelNames.back(), i);