From ccbbc9591df77bb25704361f318069170c457ffa Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Fri, 15 Dec 2017 14:44:17 +0100 Subject: [PATCH] FairMQ: Add hint argument to the region callback, settable per message. --- examples/advanced/Region/FairMQExampleRegionSampler.cxx | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/examples/advanced/Region/FairMQExampleRegionSampler.cxx b/examples/advanced/Region/FairMQExampleRegionSampler.cxx index e5bd2743..217a23c6 100644 --- a/examples/advanced/Region/FairMQExampleRegionSampler.cxx +++ b/examples/advanced/Region/FairMQExampleRegionSampler.cxx @@ -38,7 +38,7 @@ void FairMQExampleRegionSampler::InitTask() fRegion = FairMQUnmanagedRegionPtr(NewUnmanagedRegionFor("data", 0, 10000000, - [this](void* data, size_t size) { // callback to be called when message buffers no longer needed by transport + [this](void* data, size_t size, void* hint) { // callback to be called when message buffers no longer needed by transport --fNumUnackedMsgs; if (fMaxIterations > 0) { @@ -54,8 +54,10 @@ bool FairMQExampleRegionSampler::ConditionalRun() 0, // sub-channel fRegion, // region fRegion->GetData(), // ptr within region - fMsgSize // offset from ptr + fMsgSize, // offset from ptr + nullptr // hint )); + if (Send(msg, "data", 0) > 0) { ++fNumUnackedMsgs;