From 3cb80de773c3100f358734a3e87a4a052cc36ada Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Sat, 13 May 2017 16:47:21 +0200 Subject: [PATCH] add channel name setter --- fairmq/FairMQChannel.cxx | 16 ++++++++++++++++ fairmq/FairMQChannel.h | 4 ++++ 2 files changed, 20 insertions(+) diff --git a/fairmq/FairMQChannel.cxx b/fairmq/FairMQChannel.cxx index 521010e8..8972dac7 100644 --- a/fairmq/FairMQChannel.cxx +++ b/fairmq/FairMQChannel.cxx @@ -424,6 +424,22 @@ auto FairMQChannel::SetModified(const bool modified) -> void } } +void FairMQChannel::UpdateChannelName(const string& name) +{ + try + { + unique_lock lock(fChannelMutex); + fIsValid = false; + fName = name; + fModified = true; + } + catch (exception& e) + { + LOG(ERROR) << "Exception caught in FairMQChannel::UpdateChannelName: " << e.what(); + exit(EXIT_FAILURE); + } +} + bool FairMQChannel::IsValid() const { try diff --git a/fairmq/FairMQChannel.h b/fairmq/FairMQChannel.h index 2dc5095d..95c1de67 100644 --- a/fairmq/FairMQChannel.h +++ b/fairmq/FairMQChannel.h @@ -135,6 +135,10 @@ class FairMQChannel /// @param rateLogging Socket rate logging interval (in seconds) void UpdateRateLogging(const int rateLogging); + /// Set channel name + /// @param name Arbitrary channel name + void UpdateChannelName(const std::string& name); + /// Checks if the configured channel settings are valid (checks the validity parameter, without running full validation (as oposed to ValidateChannel())) /// @return true if channel settings are valid, false otherwise. bool IsValid() const;