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

Rename Device::UnblockTransports to Device::InterruptTransports

Browse Source
This commit is contained in:
Alexey Rybalchenko 2023-02-22 12:21:33 +01:00
parent 1076fbf824
commit da1c9e4400
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fairmq/Device.cxx
View File

@ -90,7 +90,7 @@ Device::Device(ProgOptions* config, tools::Version version)
switch (transition) { switch (transition) {
case Transition::Stop: case Transition::Stop:
UnblockTransports(); InterruptTransports();
break; break;
default: default:
break; break;
@ -492,7 +492,7 @@ void Device::RunWrapper()
// if Run() exited and the state is still RUNNING, transition to READY. // if Run() exited and the state is still RUNNING, transition to READY.
if (!NewStatePending()) { if (!NewStatePending()) {
UnblockTransports(); InterruptTransports();
ChangeState(Transition::Stop); ChangeState(Transition::Stop);
} }
@ -771,7 +771,7 @@ void Device::LogSocketRates()
} }
} }
void Device::UnblockTransports() void Device::InterruptTransports()
{ {
for (auto& transport : fTransports) { for (auto& transport : fTransports) {
transport.second->Interrupt(); transport.second->Interrupt();

2
fairmq/Device.h
View File

@ -588,7 +588,7 @@ class Device
void ResetWrapper(); void ResetWrapper();
/// Notifies transports to cease any blocking activity /// Notifies transports to cease any blocking activity
void UnblockTransports(); void InterruptTransports();
/// Shuts down the transports and the device /// Shuts down the transports and the device
void Exit() {} void Exit() {}