diff --git a/fairmq/devices/GenericFileSink.h b/fairmq/devices/GenericFileSink.h index c58e6bb8..d6135e40 100644 --- a/fairmq/devices/GenericFileSink.h +++ b/fairmq/devices/GenericFileSink.h @@ -16,9 +16,9 @@ template class GenericFileSink : public FairMQDevice, public InputPolicy, public OutputPolicy { - using InputPolicy::message; + //using InputPolicy::message; //using OutputPolicy::InitOutFile; - using OutputPolicy::AddToFile; + //using OutputPolicy::AddToFile; public: GenericFileSink(); diff --git a/fairmq/devices/GenericFileSink.tpl b/fairmq/devices/GenericFileSink.tpl index 33bf1556..4a28a32d 100644 --- a/fairmq/devices/GenericFileSink.tpl +++ b/fairmq/devices/GenericFileSink.tpl @@ -56,7 +56,7 @@ void GenericFileSink::Run() received = fPayloadInputs->at(0)->Receive(msg); if(received>0) { - AddToFile(message(msg)); + OutputPolicy::AddToFile(InputPolicy::DeSerializeMsg(msg)); receivedMsg++; } delete msg; diff --git a/fairmq/devices/GenericProcessor.h b/fairmq/devices/GenericProcessor.h index 96420316..82b4710a 100644 --- a/fairmq/devices/GenericProcessor.h +++ b/fairmq/devices/GenericProcessor.h @@ -58,7 +58,7 @@ class GenericProcessor: public FairMQDevice, void SendPart() { - fPayloadOutputs->at(0)->Send(OutputPolicy::message(TaskPolicy::GetData()), "snd-more"); + fPayloadOutputs->at(0)->Send(OutputPolicy::SerializeMsg(TaskPolicy::GetData()), "snd-more"); OutputPolicy::CloseMessage(); } @@ -108,9 +108,9 @@ class GenericProcessor: public FairMQDevice, received = fPayloadInputs->at(0)->Receive(msg); receivedMsgs++; - // InputPolicy::message(msg) --> deserialize data of msg and fill output container - // TaskPolicy::ExecuteTask( ... ) --> process output container - TaskPolicy::ExecuteTask(InputPolicy::message(msg)); + // InputPolicy::DeSerializeMsg(msg) --> deserialize data of msg and fill output container + // TaskPolicy::ExecuteTask( ... ) --> process output container + TaskPolicy::ExecuteTask(InputPolicy::DeSerializeMsg(msg)); // OutputPolicy::fMessage point to msg OutputPolicy::SetMessage(msg); @@ -119,7 +119,7 @@ class GenericProcessor: public FairMQDevice, { // TaskPolicy::GetOutputData() --> Get processed output container // 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++; received = 0; } diff --git a/fairmq/devices/GenericSampler.h b/fairmq/devices/GenericSampler.h index 56b74f03..f5eefe90 100644 --- a/fairmq/devices/GenericSampler.h +++ b/fairmq/devices/GenericSampler.h @@ -42,8 +42,8 @@ template class GenericSampler: public FairMQDevice, public SamplerPolicy, public OutputPolicy { - using SamplerPolicy::GetDataBranch; // get data from file - using OutputPolicy::message; // serialize method + //using SamplerPolicy::GetDataBranch; // get data from file + //using OutputPolicy::message; // serialize method public: enum { diff --git a/fairmq/devices/GenericSampler.tpl b/fairmq/devices/GenericSampler.tpl index fd01a05a..2fbcbdf0 100644 --- a/fairmq/devices/GenericSampler.tpl +++ b/fairmq/devices/GenericSampler.tpl @@ -62,7 +62,8 @@ void GenericSampler::Run() //fSamplerTask->SetEventIndex(eventNr); FairMQMessage* msg = fTransportFactory->CreateMessage(); OutputPolicy::SetMessage(msg); - fPayloadOutputs->at(0)->Send(message(GetDataBranch(eventNr))); + fPayloadOutputs->at(0)->Send(OutputPolicy::SerializeMsg( + SamplerPolicy::GetDataBranch(eventNr))); ++sentMsgs; if(msg)