diff --git a/fairmq/Device.cxx b/fairmq/Device.cxx index c56e342a..f097dc99 100644 --- a/fairmq/Device.cxx +++ b/fairmq/Device.cxx @@ -90,7 +90,7 @@ Device::Device(ProgOptions* config, tools::Version version) switch (transition) { case Transition::Stop: - UnblockTransports(); + InterruptTransports(); break; default: break; @@ -492,7 +492,7 @@ void Device::RunWrapper() // if Run() exited and the state is still RUNNING, transition to READY. if (!NewStatePending()) { - UnblockTransports(); + InterruptTransports(); ChangeState(Transition::Stop); } @@ -771,7 +771,7 @@ void Device::LogSocketRates() } } -void Device::UnblockTransports() +void Device::InterruptTransports() { for (auto& transport : fTransports) { transport.second->Interrupt(); diff --git a/fairmq/Device.h b/fairmq/Device.h index e7b0b8bb..5eba4564 100644 --- a/fairmq/Device.h +++ b/fairmq/Device.h @@ -588,7 +588,7 @@ class Device void ResetWrapper(); /// Notifies transports to cease any blocking activity - void UnblockTransports(); + void InterruptTransports(); /// Shuts down the transports and the device void Exit() {}