Skip to content

Commit

Permalink
Rename Device::UnblockTransports to Device::InterruptTransports
Browse files Browse the repository at this point in the history
  • Loading branch information
rbx committed Feb 22, 2023
1 parent 1076fbf commit da1c9e4
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions fairmq/Device.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ Device::Device(ProgOptions* config, tools::Version version)

switch (transition) {
case Transition::Stop:
UnblockTransports();
InterruptTransports();
break;
default:
break;
Expand Down Expand Up @@ -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);
}

Expand Down Expand Up @@ -771,7 +771,7 @@ void Device::LogSocketRates()
}
}

void Device::UnblockTransports()
void Device::InterruptTransports()
{
for (auto& transport : fTransports) {
transport.second->Interrupt();
Expand Down
2 changes: 1 addition & 1 deletion fairmq/Device.h
Original file line number Diff line number Diff line change
Expand Up @@ -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() {}
Expand Down

0 comments on commit da1c9e4

Please sign in to comment.