From 85aab51bd4e1be0d907f6731ba813cd2ea90087f Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Tue, 28 Nov 2017 15:37:41 +0100 Subject: [PATCH] FairMQ: Add test for example/advanced/Region. Also fix a regression in nanomsg transport. --- fairmq/nanomsg/FairMQSocketNN.cxx | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx index 04f51cd0..365732b3 100644 --- a/fairmq/nanomsg/FairMQSocketNN.cxx +++ b/fairmq/nanomsg/FairMQSocketNN.cxx @@ -244,7 +244,10 @@ int64_t FairMQSocketNN::Send(vector>& msgVec, const in packer.pack_bin(msgVec[i]->GetSize()); packer.pack_bin_body(static_cast(msgVec[i]->GetData()), msgVec[i]->GetSize()); // call region callback - static_cast(static_cast(msgVec[i].get())->fRegionPtr)->fCallback(msgVec[i]->GetMessage(), msgVec[i]->GetSize()); + if (static_cast(msgVec[i].get())->fRegionPtr) + { + static_cast(static_cast(msgVec[i].get())->fRegionPtr)->fCallback(msgVec[i]->GetMessage(), msgVec[i]->GetSize()); + } } int64_t nbytes = -1;