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

Fix CIDs 350447, 321250 (uncaught exception)

Browse Source
This commit is contained in:
Alexey Rybalchenko 2020-01-14 12:29:38 +01:00 committed by Dennis Klein
parent b6d9c949ae
commit 692ec4e997
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
fairmq/shmem/Message.cxx
View File

@ -235,6 +235,17 @@ void Message::CloseMessage()
static_cast<TransportFactory*>(GetTransport())->DecrementMsgCounter(); static_cast<TransportFactory*>(GetTransport())->DecrementMsgCounter();
} }
Message::~Message()
{
try {
CloseMessage();
} catch(SharedMemoryError& sme) {
LOG(error) << "error closing message: " << sme.what();
} catch(bipc::lock_exception& le) {
LOG(error) << "error closing message: " << le.what();
}
}
} }
} }
} }

2
fairmq/shmem/Message.h
View File

@ -56,7 +56,7 @@ class Message final : public fair::mq::Message
void Copy(const fair::mq::Message& msg) override; void Copy(const fair::mq::Message& msg) override;
~Message() override { CloseMessage(); } ~Message() override;
private: private:
Manager& fManager; Manager& fManager;