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

Fix return value of multipart send/receive methods

Browse Source
This commit is contained in:
Alexey Rybalchenko 2016-03-03 15:35:39 +01:00 committed by Mohammad Al-Turany
parent c564a3f066
commit 1ad58653e7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
fairmq/FairMQDevice.h
View File

@ -94,7 +94,7 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
/// @param chan channel name /// @param chan channel name
/// @param i channel index /// @param i channel index
/// @return Number of bytes that have been queued. -2 If queueing was not possible or timed out. In case of errors, returns -1. /// @return Number of bytes that have been queued. -2 If queueing was not possible or timed out. In case of errors, returns -1.
inline uint64_t Send(const std::vector<std::unique_ptr<FairMQMessage>>& msgVec, const std::string& chan, const int i = 0) const inline int64_t Send(const std::vector<std::unique_ptr<FairMQMessage>>& msgVec, const std::string& chan, const int i = 0) const
{ {
return fChannels.at(chan).at(i).Send(msgVec); return fChannels.at(chan).at(i).Send(msgVec);
} }
@ -104,7 +104,7 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
/// @param chan channel name /// @param chan channel name
/// @param i channel index /// @param i channel index
/// @return Number of bytes that have been received. -2 If reading from the queue was not possible or timed out. In case of errors, returns -1. /// @return Number of bytes that have been received. -2 If reading from the queue was not possible or timed out. In case of errors, returns -1.
inline uint64_t Receive(std::vector<std::unique_ptr<FairMQMessage>>& msgVec, const std::string& chan, const int i = 0) const inline int64_t Receive(std::vector<std::unique_ptr<FairMQMessage>>& msgVec, const std::string& chan, const int i = 0) const
{ {
return fChannels.at(chan).at(i).Receive(msgVec); return fChannels.at(chan).at(i).Receive(msgVec);
} }
@ -114,7 +114,7 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
/// @param chan channel name /// @param chan channel name
/// @param i channel index /// @param i channel index
/// @return Number of bytes that have been queued. -2 If queueing was not possible or timed out. In case of errors, returns -1. /// @return Number of bytes that have been queued. -2 If queueing was not possible or timed out. In case of errors, returns -1.
inline uint64_t Send(const FairMQParts& parts, const std::string& chan, const int i = 0) const inline int64_t Send(const FairMQParts& parts, const std::string& chan, const int i = 0) const
{ {
return fChannels.at(chan).at(i).Send(parts.fParts); return fChannels.at(chan).at(i).Send(parts.fParts);
} }
@ -124,7 +124,7 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
/// @param chan channel name /// @param chan channel name
/// @param i channel index /// @param i channel index
/// @return Number of bytes that have been received. -2 If reading from the queue was not possible or timed out. In case of errors, returns -1. /// @return Number of bytes that have been received. -2 If reading from the queue was not possible or timed out. In case of errors, returns -1.
inline uint64_t Receive(FairMQParts& parts, const std::string& chan, const int i = 0) const inline int64_t Receive(FairMQParts& parts, const std::string& chan, const int i = 0) const
{ {
return fChannels.at(chan).at(i).Receive(parts.fParts); return fChannels.at(chan).at(i).Receive(parts.fParts);
} }