From 68fba75f837246e555b53f78d5468a81c42b0a1b Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Wed, 22 Feb 2023 12:21:33 +0100 Subject: [PATCH] Rename Device::UnblockTransports to Device::InterruptTransports --- fairmq/Device.cxx | 6 +++--- fairmq/Device.h | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) 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() {}