From 8b85dd21918ee5b0139ca99e889ebdb68fbeda25 Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Sat, 13 May 2017 16:49:36 +0200 Subject: [PATCH] support inproc addresses --- fairmq/FairMQChannel.cxx | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/fairmq/FairMQChannel.cxx b/fairmq/FairMQChannel.cxx index 8972dac7..54040f8a 100644 --- a/fairmq/FairMQChannel.cxx +++ b/fairmq/FairMQChannel.cxx @@ -541,6 +541,18 @@ bool FairMQChannel::ValidateChannel() return false; } } + else if (address.compare(0, 9, "inproc://") == 0) + { + // check if IPC address is not empty + string addressString = address.substr(9); + if (addressString == "") + { + ss << "INVALID"; + LOG(DEBUG) << ss.str(); + LOG(ERROR) << "invalid channel address: \"" << address << "\" (empty inproc address?)"; + return false; + } + } else { // if neither TCP or IPC is specified, return invalid