diff options
author | Ivan Blinkov <ivan@blinkov.ru> | 2022-02-10 16:47:10 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:10 +0300 |
commit | 1aeb9a455974457866f78722ad98114bafc84e8a (patch) | |
tree | e4340eaf1668684d83a0a58c36947c5def5350ad /library/cpp/actors/core/log_settings.cpp | |
parent | bd5ef432f5cfb1e18851381329d94665a4c22470 (diff) | |
download | ydb-1aeb9a455974457866f78722ad98114bafc84e8a.tar.gz |
Restoring authorship annotation for Ivan Blinkov <ivan@blinkov.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/core/log_settings.cpp')
-rw-r--r-- | library/cpp/actors/core/log_settings.cpp | 88 |
1 files changed, 44 insertions, 44 deletions
diff --git a/library/cpp/actors/core/log_settings.cpp b/library/cpp/actors/core/log_settings.cpp index f52f2fc5d2..4868521fb7 100644 --- a/library/cpp/actors/core/log_settings.cpp +++ b/library/cpp/actors/core/log_settings.cpp @@ -17,12 +17,12 @@ namespace NActors { , MaxVal(0) , Mask(0) , DefPriority(defPriority) - , DefSamplingPriority(defSamplingPriority) - , DefSamplingRate(defSamplingRate) + , DefSamplingPriority(defSamplingPriority) + , DefSamplingRate(defSamplingRate) , UseLocalTimestamps(false) - , Format(PLAIN_FULL_FORMAT) - , ShortHostName("") - , ClusterName("") + , Format(PLAIN_FULL_FORMAT) + , ShortHostName("") + , ClusterName("") { Append(minVal, maxVal, func); } @@ -39,14 +39,14 @@ namespace NActors { , MaxVal(0) , Mask(0) , DefPriority(defPriority) - , DefSamplingPriority(defSamplingPriority) - , DefSamplingRate(defSamplingRate) + , DefSamplingPriority(defSamplingPriority) + , DefSamplingRate(defSamplingRate) , UseLocalTimestamps(false) - , Format(PLAIN_FULL_FORMAT) - , ShortHostName("") - , ClusterName("") - { - } + , Format(PLAIN_FULL_FORMAT) + , ShortHostName("") + , ClusterName("") + { + } void TSettings::Append(EComponent minVal, EComponent maxVal, EComponentToStringFunc func) { Y_VERIFY(minVal >= 0, "NLog::TSettings: minVal must be non-negative"); @@ -87,17 +87,17 @@ namespace NActors { } } - int TSettings::SetLevelImpl( + int TSettings::SetLevelImpl( const TString& name, bool isSampling, EPriority priority, EComponent component, TString& explanation) { TString titleName(name); - titleName.to_title(); - + titleName.to_title(); + // check priority if (!IsValidPriority(priority)) { - TStringStream str; - str << "Invalid " << name; - explanation = str.Str(); + TStringStream str; + str << "Invalid " << name; + explanation = str.Str(); return 1; } @@ -113,9 +113,9 @@ namespace NActors { } TStringStream str; - - str << titleName - << " for all components has been changed to " + + str << titleName + << " for all components has been changed to " << PriorityToString(EPrio(priority)); explanation = str.Str(); return 0; @@ -135,7 +135,7 @@ namespace NActors { } AtomicSet(ComponentInfo[component], settings.Raw.Data); TStringStream str; - str << titleName << " for the component " << ComponentNames[component] + str << titleName << " for the component " << ComponentNames[component] << " has been changed from " << PriorityToString(EPrio(oldPriority)) << " to " << PriorityToString(EPrio(priority)); explanation = str.Str(); @@ -146,41 +146,41 @@ namespace NActors { int TSettings::SetLevel(EPriority priority, EComponent component, TString& explanation) { return SetLevelImpl("priority", false, priority, component, explanation); - } - + } + int TSettings::SetSamplingLevel(EPriority priority, EComponent component, TString& explanation) { return SetLevelImpl("sampling priority", true, priority, component, explanation); - } - + } + int TSettings::SetSamplingRate(ui32 sampling, EComponent component, TString& explanation) { - if (component == InvalidComponent) { - for (int i = 0; i < Mask + 1; i++) { + if (component == InvalidComponent) { + for (int i = 0; i < Mask + 1; i++) { TComponentSettings settings = AtomicGet(ComponentInfo[i]); settings.Raw.X.SamplingRate = sampling; AtomicSet(ComponentInfo[i], settings.Raw.Data); - } - TStringStream str; - str << "Sampling rate for all components has been changed to " << sampling; - explanation = str.Str(); - } else { - if (!IsValidComponent(component)) { - explanation = "Invalid component"; - return 1; - } + } + TStringStream str; + str << "Sampling rate for all components has been changed to " << sampling; + explanation = str.Str(); + } else { + if (!IsValidComponent(component)) { + explanation = "Invalid component"; + return 1; + } TComponentSettings settings = AtomicGet(ComponentInfo[component]); ui32 oldSampling = settings.Raw.X.SamplingRate; settings.Raw.X.SamplingRate = sampling; AtomicSet(ComponentInfo[component], settings.Raw.Data); - TStringStream str; - str << "Sampling rate for the component " << ComponentNames[component] + TStringStream str; + str << "Sampling rate for the component " << ComponentNames[component] << " has been changed from " << oldSampling << " to " << sampling; - explanation = str.Str(); - } - return 0; - } - + explanation = str.Str(); + } + return 0; + } + int TSettings::PowerOf2Mask(int val) { int mask = 1; while ((val & mask) != val) { |