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

Split serializer policies into serializer and deserializer policies, and change serializer method names message() to SerializeMsg() and DeserializeMsg()

Browse Source 
Improve boost serializer performance
This commit is contained in:
winckler 2015-02-11 10:32:40 +01:00
parent 6518b7cd41
commit 6d65c4313a
5 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fairmq/devices/GenericFileSink.h
View File

@ -16,9 +16,9 @@
template <typename InputPolicy, typename OutputPolicy> template <typename InputPolicy, typename OutputPolicy>
class GenericFileSink : public FairMQDevice, public InputPolicy, public OutputPolicy class GenericFileSink : public FairMQDevice, public InputPolicy, public OutputPolicy
{ {
using InputPolicy::message; //using InputPolicy::message;
//using OutputPolicy::InitOutFile; //using OutputPolicy::InitOutFile;
using OutputPolicy::AddToFile; //using OutputPolicy::AddToFile;
public: public:
GenericFileSink(); GenericFileSink();

2
fairmq/devices/GenericFileSink.tpl
View File

@ -56,7 +56,7 @@ void GenericFileSink<InputPolicy, OutputPolicy>::Run()
received = fPayloadInputs->at(0)->Receive(msg); received = fPayloadInputs->at(0)->Receive(msg);
if(received>0) if(received>0)
{ {
AddToFile(message(msg)); OutputPolicy::AddToFile(InputPolicy::DeSerializeMsg(msg));
receivedMsg++; receivedMsg++;
} }
delete msg; delete msg;

10
fairmq/devices/GenericProcessor.h
View File

@ -58,7 +58,7 @@ class GenericProcessor: public FairMQDevice,
void SendPart() void SendPart()
{ {
fPayloadOutputs->at(0)->Send(OutputPolicy::message(TaskPolicy::GetData()), "snd-more"); fPayloadOutputs->at(0)->Send(OutputPolicy::SerializeMsg(TaskPolicy::GetData()), "snd-more");
OutputPolicy::CloseMessage(); OutputPolicy::CloseMessage();
} }
@ -108,9 +108,9 @@ class GenericProcessor: public FairMQDevice,
received = fPayloadInputs->at(0)->Receive(msg); received = fPayloadInputs->at(0)->Receive(msg);
receivedMsgs++; receivedMsgs++;
// InputPolicy::message(msg) --> deserialize data of msg and fill output container // InputPolicy::DeSerializeMsg(msg) --> deserialize data of msg and fill output container
// TaskPolicy::ExecuteTask( ... ) --> process output container // TaskPolicy::ExecuteTask( ... ) --> process output container
TaskPolicy::ExecuteTask(InputPolicy::message(msg)); TaskPolicy::ExecuteTask(InputPolicy::DeSerializeMsg(msg));
// OutputPolicy::fMessage point to msg // OutputPolicy::fMessage point to msg
OutputPolicy::SetMessage(msg); OutputPolicy::SetMessage(msg);
@ -119,7 +119,7 @@ class GenericProcessor: public FairMQDevice,
{ {
// TaskPolicy::GetOutputData() --> Get processed output container // TaskPolicy::GetOutputData() --> Get processed output container
// OutputPolicy::message(...) --> Serialize output container and fill fMessage // OutputPolicy::message(...) --> Serialize output container and fill fMessage
fPayloadOutputs->at(0)->Send(OutputPolicy::message(TaskPolicy::GetOutputData())); fPayloadOutputs->at(0)->Send(OutputPolicy::SerializeMsg(TaskPolicy::GetOutputData()));
sentMsgs++; sentMsgs++;
received = 0; received = 0;
} }

4
fairmq/devices/GenericSampler.h
View File

@ -42,8 +42,8 @@
template <typename SamplerPolicy, typename OutputPolicy> template <typename SamplerPolicy, typename OutputPolicy>
class GenericSampler: public FairMQDevice, public SamplerPolicy, public OutputPolicy class GenericSampler: public FairMQDevice, public SamplerPolicy, public OutputPolicy
{ {
using SamplerPolicy::GetDataBranch; // get data from file //using SamplerPolicy::GetDataBranch; // get data from file
using OutputPolicy::message; // serialize method //using OutputPolicy::message; // serialize method
public: public:
enum { enum {

3
fairmq/devices/GenericSampler.tpl
View File

@ -62,7 +62,8 @@ void GenericSampler<SamplerPolicy,OutputPolicy>::Run()
//fSamplerTask->SetEventIndex(eventNr); //fSamplerTask->SetEventIndex(eventNr);
FairMQMessage* msg = fTransportFactory->CreateMessage(); FairMQMessage* msg = fTransportFactory->CreateMessage();
OutputPolicy::SetMessage(msg); OutputPolicy::SetMessage(msg);
fPayloadOutputs->at(0)->Send(message(GetDataBranch(eventNr))); fPayloadOutputs->at(0)->Send(OutputPolicy::SerializeMsg(
SamplerPolicy::GetDataBranch(eventNr)));
++sentMsgs; ++sentMsgs;
if(msg) if(msg)