From a3bb5fb4b0b3f0d5c66b71115946f20d600f77f7 Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Wed, 3 Nov 2021 12:31:01 +0100 Subject: [PATCH] feat: Add Device::GetNumSubChannels(channel) --- fairmq/Device.h | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/fairmq/Device.h b/fairmq/Device.h index 77a563935..6ec0d6c33 100644 --- a/fairmq/Device.h +++ b/fairmq/Device.h @@ -324,6 +324,14 @@ class Device throw; } + size_t GetNumSubChannels(const std::string& channelName) + try { + return fChannels.at(channelName).size(); + } catch (const std::out_of_range& oor) { + LOG(error) << "GetNumSubChannels(): '" << channelName << "' does not exist."; + throw; + } + /// @brief Get numbers of connected peers for the given channel /// @param name channel name /// @param index sub-channel