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

add FairMQParts Send/Receive apis

Browse Source
This commit is contained in:
Dennis Klein 2017-05-13 16:54:56 +02:00 committed by Mohammad Al-Turany
parent 8b85dd2191
commit f522dc1717
1 changed files with 31 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
fairmq/FairMQChannel.h
View File

@ -26,9 +26,7 @@
#include "FairMQPoller.h" #include "FairMQPoller.h"
#include "FairMQTransports.h" #include "FairMQTransports.h"
#include "FairMQLogger.h" #include "FairMQLogger.h"
#include "FairMQParts.h"
class FairMQPoller;
class FairMQTransportFactory;
class FairMQChannel class FairMQChannel
{ {
@ -222,6 +220,36 @@ class FairMQChannel
/// In case of errors, returns -1. /// In case of errors, returns -1.
int64_t ReceiveAsync(std::vector<std::unique_ptr<FairMQMessage>>& msgVec) const; int64_t ReceiveAsync(std::vector<std::unique_ptr<FairMQMessage>>& msgVec) const;
int64_t Send(FairMQParts& parts) const
{
return Send(parts.fParts);
}
int64_t Receive(FairMQParts& parts) const
{
return Receive(parts.fParts);
}
int64_t Send(FairMQParts& parts, int sndTimeoutInMs) const
{
return Send(parts.fParts, sndTimeoutInMs);
}
int64_t Receive(FairMQParts& parts, int rcvTimeoutInMs) const
{
return Receive(parts.fParts, rcvTimeoutInMs);
}
int64_t SendAsync(FairMQParts& parts) const
{
return SendAsync(parts.fParts);
}
int64_t ReceiveAsync(FairMQParts& parts) const
{
return ReceiveAsync(parts.fParts);
}
// TODO: this might go to some base utility library // TODO: this might go to some base utility library
static void Tokenize(std::vector<std::string>& output, const std::string& input, const std::string delimiters = ","); static void Tokenize(std::vector<std::string>& output, const std::string& input, const std::string delimiters = ",");