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

Add Device::ResumeTransports

Browse Source
This commit is contained in:
Alexey Rybalchenko 2023-02-22 12:23:28 +01:00
parent da1c9e4400
commit ae51ecc659
2 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
fairmq/Device.cxx
View File

@ -457,11 +457,8 @@ void Device::RunWrapper()
if (rateLogging && rateLogger->joinable()) { rateLogger->join(); } if (rateLogging && rateLogger->joinable()) { rateLogger->join(); }
}); });
// notify transports to resume transfers // notify transports to resume transfers
for (auto& t : fTransports) { ResumeTransports();
t.second->Resume();
}
// change to Error state in case of an exception, to release LogSocketRates // change to Error state in case of an exception, to release LogSocketRates
tools::CallOnDestruction cod([&](){ tools::CallOnDestruction cod([&](){
@ -773,8 +770,15 @@ void Device::LogSocketRates()
void Device::InterruptTransports() void Device::InterruptTransports()
{ {
for (auto& transport : fTransports) { for (auto& [transportType, transport] : fTransports) {
transport.second->Interrupt(); transport->Interrupt();
}
}
void Device::ResumeTransports()
{
for (auto& [transportType, transport] : fTransports) {
transport->Resume();
} }
} }
@ -789,8 +793,8 @@ void Device::ResetTaskWrapper()
void Device::ResetWrapper() void Device::ResetWrapper()
{ {
for (auto& transport : fTransports) { for (auto& [transportType, transport] : fTransports) {
transport.second->Reset(); transport->Reset();
} }
Reset(); Reset();

3
fairmq/Device.h
View File

@ -590,6 +590,9 @@ class Device
/// Notifies transports to cease any blocking activity /// Notifies transports to cease any blocking activity
void InterruptTransports(); void InterruptTransports();
/// Notifies transports to resume any blocking activity
void ResumeTransports();
/// Shuts down the transports and the device /// Shuts down the transports and the device
void Exit() {} void Exit() {}