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

Implement Reset signal

Browse Source
This commit is contained in:
Dennis Klein 2019-02-26 17:08:53 +01:00 committed by Dennis Klein
parent 241bf08337
commit ee890a7a46
3 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fairmq/ofi/Context.cxx
View File

@ -54,9 +54,13 @@ auto Context::InitThreadPool(int numberIoThreads) -> void
} }
} }
Context::~Context() auto Context::Reset() -> void
{ {
fIoContext.stop(); fIoContext.stop();
}
Context::~Context()
{
for (auto& thread : fThreadPool) for (auto& thread : fThreadPool)
thread.join(); thread.join();
} }

1
fairmq/ofi/Context.h
View File

@ -69,6 +69,7 @@ class Context
static auto VerifyAddress(const std::string& address) -> Address; static auto VerifyAddress(const std::string& address) -> Address;
auto Interrupt() -> void { LOG(debug) << "OFI transport: Interrupted (NOOP - not implemented)."; } auto Interrupt() -> void { LOG(debug) << "OFI transport: Interrupted (NOOP - not implemented)."; }
auto Resume() -> void { LOG(debug) << "OFI transport: Resumed (NOOP - not implemented)."; } auto Resume() -> void { LOG(debug) << "OFI transport: Resumed (NOOP - not implemented)."; }
auto Reset() -> void;
auto MakeReceiveMessage(size_t size) -> MessagePtr; auto MakeReceiveMessage(size_t size) -> MessagePtr;
auto MakeSendMessage(size_t size) -> MessagePtr; auto MakeSendMessage(size_t size) -> MessagePtr;

2
fairmq/ofi/TransportFactory.h
View File

@ -52,7 +52,7 @@ class TransportFactory final : public FairMQTransportFactory
void Interrupt() override { fContext.Interrupt(); } void Interrupt() override { fContext.Interrupt(); }
void Resume() override { fContext.Resume(); } void Resume() override { fContext.Resume(); }
void Reset() override {} void Reset() override { fContext.Reset(); }
private: private:
mutable Context fContext; mutable Context fContext;