Adapt to the changed API n FairMQ

MohammadAlTurany · MohammadAlTurany · commit f44efbde4250 · 2016-03-30T10:21:01.000+02:00
remove memory leak
diff --git a/devices/flp2epn-distributed/FLPSender.cxx b/devices/flp2epn-distributed/FLPSender.cxx
@@ -97,7 +97,6 @@ void FLPSender::Run()
   // boost::thread heartbeatReceiver(boost::bind(&FLPSender::receiveHeartbeats, this));
 
   // base buffer, to be copied from for every timeframe body (zero-copy)
-  void* buffer = operator new[](fEventSize);
   unique_ptr<FairMQMessage> baseMsg(fTransportFactory->CreateMessage(fEventSize));
 
   uint16_t timeFrameId = 0;
@@ -130,7 +129,8 @@ void FLPSender::Run()
       }
     }
 
-    unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(sizeof(f2eHeader)));
+   // unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(sizeof(f2eHeader)));
+    unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(h, sizeof(f2eHeader), [](void* data, void* hint){ delete static_cast<f2eHeader*>(hint); }, h));
     unique_ptr<FairMQMessage> dataPart(fTransportFactory->CreateMessage());
 
     // save the arrival time of the message.

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,6 @@ void FLPSender::Run()`
`97`	`97`	`// boost::thread heartbeatReceiver(boost::bind(&FLPSender::receiveHeartbeats, this));`
`98`	`98`
`99`	`99`	`// base buffer, to be copied from for every timeframe body (zero-copy)`
`100`		`- void* buffer = operator new[](fEventSize);`
`101`	`100`	`unique_ptr<FairMQMessage> baseMsg(fTransportFactory->CreateMessage(fEventSize));`
`102`	`101`
`103`	`102`	`uint16_t timeFrameId = 0;`
`@@ -130,7 +129,8 @@ void FLPSender::Run()`
`130`	`129`	`}`
`131`	`130`	`}`
`132`	`131`
`133`		`- unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(sizeof(f2eHeader)));`
	`132`	`+ // unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(sizeof(f2eHeader)));`
	`133`	`+ unique_ptr<FairMQMessage> headerPart(fTransportFactory->CreateMessage(h, sizeof(f2eHeader), [](void* data, void* hint){ delete static_cast<f2eHeader*>(hint); }, h));`
`134`	`134`	`unique_ptr<FairMQMessage> dataPart(fTransportFactory->CreateMessage());`
`135`	`135`
`136`	`136`	`// save the arrival time of the message.`