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

Call region event callback with local_only event for zmq

Browse Source
This commit is contained in:
Alexey Rybalchenko 2020-05-08 10:38:32 +02:00
parent 9992811822
commit a3afadb824
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fairmq/FairMQUnmanagedRegion.h
View File

@ -19,7 +19,8 @@ class FairMQTransportFactory;
enum class FairMQRegionEvent : int enum class FairMQRegionEvent : int
{ {
created, created,
destroyed destroyed,
local_only
}; };
struct FairMQRegionInfo struct FairMQRegionInfo
@ -72,10 +73,15 @@ using FairMQUnmanagedRegionPtr = std::unique_ptr<FairMQUnmanagedRegion>;
inline std::ostream& operator<<(std::ostream& os, const FairMQRegionEvent& event) inline std::ostream& operator<<(std::ostream& os, const FairMQRegionEvent& event)
{ {
if (event == FairMQRegionEvent::created) { switch (event) {
case FairMQRegionEvent::created:
return os << "created"; return os << "created";
} else { case FairMQRegionEvent::destroyed:
return os << "destroyed"; return os << "destroyed";
case FairMQRegionEvent::local_only:
return os << "local_only";
default:
return os << "unrecognized event";
} }
} }

1
fairmq/zeromq/FairMQTransportFactoryZMQ.cxx
View File

@ -50,6 +50,7 @@ FairMQTransportFactoryZMQ::FairMQTransportFactoryZMQ(const string& id, const fai
LOG(error) << "failed configuring context, reason: " << zmq_strerror(errno); LOG(error) << "failed configuring context, reason: " << zmq_strerror(errno);
} }
fRegionEvents.emplace(0, nullptr, 0, 0, fair::mq::RegionEvent::local_only);
} }
FairMQMessagePtr FairMQTransportFactoryZMQ::CreateMessage() FairMQMessagePtr FairMQTransportFactoryZMQ::CreateMessage()