From 07aed04b14c1f744f6ddc1d3697f1710f0a324f9 Mon Sep 17 00:00:00 2001 From: winckler Date: Thu, 31 Mar 2016 19:35:56 +0200 Subject: [PATCH] add deleter in FairMQ example 8 --- examples/MQ/8-multipart/FairMQExample8Sampler.cxx | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/examples/MQ/8-multipart/FairMQExample8Sampler.cxx b/examples/MQ/8-multipart/FairMQExample8Sampler.cxx index 8067601f..45106c20 100644 --- a/examples/MQ/8-multipart/FairMQExample8Sampler.cxx +++ b/examples/MQ/8-multipart/FairMQExample8Sampler.cxx @@ -41,6 +41,13 @@ void FairMQExample8Sampler::Run() LOG(INFO) << "Sending header with stopFlag: " << header->stopFlag; FairMQParts parts; + + parts.AddPart(NewMessage(header, // data pointer + sizeof(Ex8Header), // data size + [](void* data, void* hint) { delete static_cast(data); } // callback to deallocate after the transfer + )); + parts.AddPart(NewMessage(1000)); + LOG(INFO) << "Sending body of size: " << parts.At(1)->GetSize(); Send(parts, "data-out");