Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-15 09:31:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Simplify Tutorial3 structure.

Browse Source 
Use same executable for bin/boost/protobuf/root data format,
configured now via `--data-format <binary/boost/protobuf/tmessage>`
command line parameter.
This commit is contained in:
Alexey Rybalchenko
2015-09-09 16:57:04 +02:00
committed by Mohammad Al-Turany
parent 8b71e4d20b
commit 5136c88d3a
3 changed files with 10 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fairmq/FairMQChannel.cxx
View File

@@ -551,7 +551,10 @@ bool FairMQChannel::ExpectsAnotherPart() const
inline bool FairMQChannel::HandleUnblock() const
{
FairMQMessage* cmd = fTransportFactory->CreateMessage();
fCmdSocket->Receive(cmd, 0);
if (fCmdSocket->Receive(cmd, 0) >= 0)
{
LOG(DEBUG) << "unblocked";
}
delete cmd;
return true;
}