Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-12 16:21:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

support inproc addresses

Browse Source
This commit is contained in:
Dennis Klein 2017-05-13 16:49:36 +02:00 committed by Mohammad Al-Turany
parent 3cb80de773
commit 8b85dd2191
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fairmq/FairMQChannel.cxx
View File

@ -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